ignore exist

pkg/schema/tracker.go

@@ -294,19 +294,9 @@ func cloneTableInfo(ti *model.TableInfo) *model.TableInfo {
 
 // CreateTableIfNotExists creates a TABLE of the given name if it did not exist.
 func (tr *Tracker) CreateTableIfNotExists(db, table string, ti *model.TableInfo) error {
-	infoSchema := tr.dom.InfoSchema()
 	dbName := model.NewCIStr(db)
 	tableName := model.NewCIStr(table)
-	if infoSchema.TableExists(dbName, tableName) {
-		return nil
-	}
-
-	dbInfo, exists := infoSchema.SchemaByName(dbName)
-	if !exists || dbInfo == nil {
-		return infoschema.ErrDatabaseNotExists.GenWithStackByArgs(dbName)
-	}
-
 	ti = cloneTableInfo(ti)
 	ti.Name = tableName
-	return tr.dom.DDL().CreateTableWithInfo(tr.se, dbName, ti, ddl.OnExistError, false)
+	return tr.dom.DDL().CreateTableWithInfo(tr.se, dbName, ti, ddl.OnExistIgnore, false)
 }

pkg/schema/tracker_test.go

@@ -395,6 +395,10 @@ func (s *trackerSuite) TestCreateTableIfNotExists(c *C) {
 	err = tracker.CreateTableIfNotExists("testdb", "foo", ti1)
 	c.Assert(err, IsNil)
 
+	// error if db not exist
+	err = tracker.CreateTableIfNotExists("test-another-db", "foo", ti1)
+	c.Assert(err, ErrorMatches, ".*Unknown database.*")
+
 	// Can use the table info to recover a table using a different name.
 	err = tracker.CreateTableIfNotExists("testdb", "bar", ti1)
 	c.Assert(err, IsNil)