From 0cee18574c35f764ef89be216a9d61e1973f6bb8 Mon Sep 17 00:00:00 2001 From: Csong Date: Fri, 17 Apr 2026 13:06:14 +0800 Subject: [PATCH] =?UTF-8?q?Update=20default=20SQL=20mode=20and=20parser=20?= =?UTF-8?q?initialization=20in=20downstream=20tracker=EF=BC=8CRemove=20NO?= =?UTF-8?q?=5FAUTO=5FCREATE=5FUSER=20in=20default=20SQL=20mode.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dm/pkg/schema/tracker.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/dm/pkg/schema/tracker.go b/dm/pkg/schema/tracker.go index 55e0e5fcf7..9ea536a5ee 100644 --- a/dm/pkg/schema/tracker.go +++ b/dm/pkg/schema/tracker.go @@ -853,14 +853,15 @@ func getColumnsByNames(ti *model.TableInfo, names []ast.CIStr) ([]*model.ColumnI // initDownStreamTrackerParser init downstream tracker parser by default sql_mode. func (dt *downstreamTracker) initDownStreamSQLModeAndParser(tctx *tcontext.Context) error { - setSQLMode := fmt.Sprintf("SET SESSION SQL_MODE = '%s'", mysql.DefaultSQLMode) + var DefaultSQLMode = "ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION" + setSQLMode := fmt.Sprintf("SET SESSION SQL_MODE = '%s'", DefaultSQLMode) _, err := dt.downstreamConn.ExecuteSQL(tctx, nil, []string{setSQLMode}) if err != nil { - return dmterror.ErrSchemaTrackerCannotSetDownstreamSQLMode.Delegate(err, mysql.DefaultSQLMode) + return dmterror.ErrSchemaTrackerCannotSetDownstreamSQLMode.Delegate(err, DefaultSQLMode) } - stmtParser, err := conn.GetParserFromSQLModeStr(mysql.DefaultSQLMode) + stmtParser, err := conn.GetParserFromSQLModeStr(DefaultSQLMode) if err != nil { - return dmterror.ErrSchemaTrackerCannotInitDownstreamParser.Delegate(err, mysql.DefaultSQLMode) + return dmterror.ErrSchemaTrackerCannotInitDownstreamParser.Delegate(err, DefaultSQLMode) } dt.stmtParser = stmtParser return nil