From 24eb7fc9248ed266a2725e170faca8431be1711b Mon Sep 17 00:00:00 2001
From: eldenmoon <15605149486@163.com>
Date: Mon, 26 Aug 2024 11:40:18 +0800
Subject: [PATCH] [regression-test](PreparedStatement) fix unstable cases when
 session var changed

---
 .../suites/prepared_stmt_p0/prepared_stmt.groovy           | 7 +++++++
 .../suites/prepared_stmt_p0/prepared_stmt_in_list.groovy   | 1 +
 2 files changed, 8 insertions(+)

diff --git a/regression-test/suites/prepared_stmt_p0/prepared_stmt.groovy b/regression-test/suites/prepared_stmt_p0/prepared_stmt.groovy
index 9e557c0dc6938b..b403b3a2f51ee2 100644
--- a/regression-test/suites/prepared_stmt_p0/prepared_stmt.groovy
+++ b/regression-test/suites/prepared_stmt_p0/prepared_stmt.groovy
@@ -58,6 +58,7 @@ suite("test_prepared_stmt", "nonConcurrent") {
         qt_sql """select * from  ${tableName} order by 1, 2, 3"""
         qt_sql """select * from  ${tableName} order by 1, 2, 3"""
         sql "set global max_prepared_stmt_count = 10000"
+        sql "set enable_fallback_to_original_planner = false"
 
         def stmt_read = prepareStatement "select * from ${tableName} where k1 = ? order by k1"
         assertEquals(com.mysql.cj.jdbc.ServerPreparedStatement, stmt_read.class)
@@ -239,5 +240,11 @@ suite("test_prepared_stmt", "nonConcurrent") {
         // not stable
         // qe_select16 stmt_read
         stmt_read.close()
+
+        stmt_read = prepareStatement "SELECT connection_id()" 
+        assertEquals(com.mysql.cj.jdbc.ServerPreparedStatement, stmt_read.class)
+        result = stmt_read.execute()
+        logger.info("connection_id: ${result}")
+        // qe_select16 stmt_read
     }
 }
diff --git a/regression-test/suites/prepared_stmt_p0/prepared_stmt_in_list.groovy b/regression-test/suites/prepared_stmt_p0/prepared_stmt_in_list.groovy
index d83e644af270ae..630fe7fa72002b 100644
--- a/regression-test/suites/prepared_stmt_p0/prepared_stmt_in_list.groovy
+++ b/regression-test/suites/prepared_stmt_p0/prepared_stmt_in_list.groovy
@@ -22,6 +22,7 @@ suite("test_prepared_stmt_in_list", "nonConcurrent") {
     def user = context.config.jdbcUser
     def password = context.config.jdbcPassword
     def url = context.config.jdbcUrl + "&useServerPrepStmts=true"
+    sql """set global max_prepared_stmt_count = 1024"""
     def result1 = connect(user=user, password=password, url=url) {
         sql """DROP TABLE IF EXISTS ${tableName} """
         sql """