From 076f7bbf08221b6bcad6afaa9cb290c17e318fbc Mon Sep 17 00:00:00 2001 From: Lunny Xiao Date: Tue, 3 Mar 2015 15:06:48 +0800 Subject: [PATCH] add MustDropTable method for dialect --- dialect.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/dialect.go b/dialect.go index 29486d5d..dc8b73ca 100644 --- a/dialect.go +++ b/dialect.go @@ -56,21 +56,17 @@ type Dialect interface { IsColumnExist(tableName string, col *Column) (bool, error) CreateTableSql(table *Table, tableName, storeEngine, charset string) string - DropTableSql(tableName string) string + //DropTableSql(tableName string) string CreateIndexSql(tableName string, index *Index) string DropIndexSql(tableName string, index *Index) string ModifyColumnSql(tableName string, col *Column) string + MustDropTable(tableName string) error GetColumns(tableName string) ([]string, map[string]*Column, error) GetTables() ([]*Table, error) GetIndexes(tableName string) (map[string]*Index, error) - // Get data from db cell to a struct's field - //GetData(col *Column, fieldValue *reflect.Value, cellData interface{}) error - // Set field data to db - //SetData(col *Column, fieldValue *refelct.Value) (interface{}, error) - Filters() []Filter } @@ -145,6 +141,11 @@ func (db *Base) DropTableSql(tableName string) string { return fmt.Sprintf("DROP TABLE IF EXISTS `%s`", tableName) } +func (db *Base) MustDropTable(tableName string) error { + _, err := db.db.Exec(db.DropTableSql(tableName)) + return err +} + func (db *Base) HasRecords(query string, args ...interface{}) (bool, error) { rows, err := db.DB().Query(query, args...) if db.Logger != nil {