From 4439ae4ed94119f3275129a26defd6449b7a488a Mon Sep 17 00:00:00 2001
From: Ti Chi Robot <ti-community-prow-bot@tidb.io>
Date: Mon, 30 Oct 2023 14:26:06 +0800
Subject: [PATCH] mysql(ticdc): use string join to build multi statement sql.
 (#9936) (#9937)

close pingcap/tiflow#9935
---
 cdc/sink/dmlsink/txn/mysql/mysql.go | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

diff --git a/cdc/sink/dmlsink/txn/mysql/mysql.go b/cdc/sink/dmlsink/txn/mysql/mysql.go
index b9960c65fc7..31d3b45bd81 100644
--- a/cdc/sink/dmlsink/txn/mysql/mysql.go
+++ b/cdc/sink/dmlsink/txn/mysql/mysql.go
@@ -20,6 +20,7 @@ import (
 	"fmt"
 	"math"
 	"net/url"
+	"strings"
 	"time"
 
 	dmysql "github.com/go-sql-driver/mysql"
@@ -655,20 +656,17 @@ func (s *mysqlBackend) prepareDMLs() *preparedDMLs {
 func (s *mysqlBackend) multiStmtExecute(
 	ctx context.Context, dmls *preparedDMLs, tx *sql.Tx, writeTimeout time.Duration,
 ) error {
-	start := time.Now()
-	multiStmtSQL := ""
-	multiStmtArgs := []any{}
-	for i, query := range dmls.sqls {
-		multiStmtSQL += query
-		if i != len(dmls.sqls)-1 {
-			multiStmtSQL += ";"
-		}
-		multiStmtArgs = append(multiStmtArgs, dmls.values[i]...)
+	var multiStmtArgs []any
+	for _, value := range dmls.values {
+		multiStmtArgs = append(multiStmtArgs, value...)
 	}
+	multiStmtSQL := strings.Join(dmls.sqls, ";")
+
 	log.Debug("exec row", zap.Int("workerID", s.workerID),
 		zap.String("sql", multiStmtSQL), zap.Any("args", multiStmtArgs))
 	ctx, cancel := context.WithTimeout(ctx, writeTimeout)
 	defer cancel()
+	start := time.Now()
 	_, execError := tx.ExecContext(ctx, multiStmtSQL, multiStmtArgs...)
 	if execError != nil {
 		err := logDMLTxnErr(