From 33b0b83b8a1043b4c4b683bfb1f4166c3a038dc8 Mon Sep 17 00:00:00 2001 From: nhsmw Date: Fri, 31 Jan 2025 22:11:27 +0800 Subject: [PATCH] Update main.go --- tests/integration_tests/multi_source/main.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/tests/integration_tests/multi_source/main.go b/tests/integration_tests/multi_source/main.go index 4627a04240e..635a583cafb 100644 --- a/tests/integration_tests/multi_source/main.go +++ b/tests/integration_tests/multi_source/main.go @@ -212,8 +212,9 @@ func dml(ctx context.Context, db *sql.DB, table string, id int) { var deleteSuccess int insertSQL := fmt.Sprintf("insert into test.`%s`(id1, id2) values(?,?)", table) deleteSQL := fmt.Sprintf("delete from test.`%s` where id1 = ? or id2 = ?", table) - for i = 0; ; i++ { - _, err = db.Exec(insertSQL, i+id*100000000, i+id*100000000+1) + k := 100000000 + for i = 0; i < k; i++ { + _, err = db.Exec(insertSQL, i+id*k, i+id*k+1) if err == nil { insertSuccess++ if insertSuccess%100 == 0 { @@ -225,7 +226,7 @@ func dml(ctx context.Context, db *sql.DB, table string, id int) { } if i%2 == 0 { - result, err := db.Exec(deleteSQL, i+id*100000000, i+id*100000000+1) + result, err := db.Exec(deleteSQL, i+id*k, i+id*k+1) if err == nil { rows, _ := result.RowsAffected() if rows != 0 {