From 4c9df6460434d58658ad45917b4089b3f4920e7e Mon Sep 17 00:00:00 2001 From: meiyi Date: Wed, 15 May 2024 17:13:14 +0800 Subject: [PATCH] modify case --- .../txn_insert_concurrent_insert.groovy | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) 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 60cffc4d0dfad9..e628f14acb58d2 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)