diff --git a/regression-test/suites/insert_p0/txn_insert_concurrent_insert.groovy b/regression-test/suites/insert_p0/txn_insert_concurrent_insert.groovy
index 60cffc4d0dfad9b..e628f14acb58d26 100644
--- a/regression-test/suites/insert_p0/txn_insert_concurrent_insert.groovy
+++ b/regression-test/suites/insert_p0/txn_insert_concurrent_insert.groovy
@@ -83,14 +83,20 @@ suite("txn_insert_concurrent_insert") {
     def url = getServerPrepareJdbcUrl(context.config.jdbcUrl, dbName).replace("&useServerPrepStmts=true", "") + "&useLocalSessionState=true"
     logger.info("url: ${url}")
 
+    def sqls = [
+            "begin",
+            "insert into ${tableName}_0 select * from ${tableName}_1 where L_ORDERKEY < 30000;",
+            "insert into ${tableName}_1 select * from ${tableName}_2 where L_ORDERKEY > 500000;",
+            "insert into ${tableName}_0 select * from ${tableName}_2 where L_ORDERKEY < 30000;",
+            "commit"
+    ]
     def txn_insert = { ->
         try (Connection conn = DriverManager.getConnection(url, context.config.jdbcUser, context.config.jdbcPassword);
              Statement stmt = conn.createStatement()) {
-            stmt.execute("begin")
-            stmt.execute("insert into ${tableName}_0 select * from ${tableName}_1 where L_ORDERKEY < 30000;")
-            stmt.execute("insert into ${tableName}_1 select * from ${tableName}_2 where L_ORDERKEY > 500000;")
-            stmt.execute("insert into ${tableName}_0 select * from ${tableName}_2 where L_ORDERKEY < 30000;")
-            stmt.execute("commit")
+            for (def sql : sqls) {
+                logger.info(Thread.currentThread().getName() + " execute sql: " + sql)
+                stmt.execute(sql)
+            }
             logger.info("finish txn insert for " + Thread.currentThread().getName())
         } catch (Throwable e) {
             logger.error("txn insert failed", e)