diff --git a/dialect.go b/dialect.go index 8615f17d..45bc5c20 100644 --- a/dialect.go +++ b/dialect.go @@ -63,6 +63,8 @@ type Dialect interface { ModifyColumnSql(tableName string, col *Column) string + ForUpdateSql(query string) string + //CreateTableIfNotExists(table *Table, tableName, storeEngine, charset string) error //MustDropTable(tableName string) error @@ -271,6 +273,10 @@ func (b *Base) CreateTableSql(table *Table, tableName, storeEngine, charset stri return sql } +func (b *Base) ForUpdateSql(query string) string { + return query + " FOR UPDATE" +} + var ( dialects = map[DbType]func() Dialect{} )