[shardingsphere] branch master updated: Add useServerPrepStmts=false for pipeline job on MySQL (#24505)

[azexin]

This is an automated email from the ASF dual-hosted git repository.

azexin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 63ea4c0a2a3 Add useServerPrepStmts=false for pipeline job on MySQL 
(#24505)
63ea4c0a2a3 is described below

commit 63ea4c0a2a376a055ad77305ce80516b31eb0426
Author: Hongsheng Zhong <zhonghongsh...@apache.org>
AuthorDate: Wed Mar 8 21:15:36 2023 +0800

    Add useServerPrepStmts=false for pipeline job on MySQL (#24505)
---
 .../pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtension.java   | 1 +
 .../mysql/datasource/MySQLJdbcQueryPropertiesExtensionTest.java        | 3 ++-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtension.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtension.java
index 1cebabab5ff..488b3204f1b 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtension.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtension.java
@@ -35,6 +35,7 @@ public final class MySQLJdbcQueryPropertiesExtension 
implements JdbcQueryPropert
     
     public MySQLJdbcQueryPropertiesExtension() {
         queryProps.setProperty("useSSL", Boolean.FALSE.toString());
+        queryProps.setProperty("useServerPrepStmts", Boolean.FALSE.toString());
         queryProps.setProperty("rewriteBatchedStatements", 
Boolean.TRUE.toString());
         queryProps.setProperty("yearIsDateType", Boolean.FALSE.toString());
         queryProps.setProperty("zeroDateTimeBehavior", 
getZeroDateTimeBehavior());
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtensionTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtensionTest.java
index dcc669859d1..44fba0577ce 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtensionTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/datasource/MySQLJdbcQueryPropertiesExtensionTest.java
@@ -45,8 +45,9 @@ public final class MySQLJdbcQueryPropertiesExtensionTest {
     }
     
     private void assertQueryProperties(final Properties actual) {
-        assertThat(actual.size(), equalTo(7));
+        assertThat(actual.size(), equalTo(8));
         assertThat(actual.getProperty("useSSL"), 
equalTo(Boolean.FALSE.toString()));
+        assertThat(actual.getProperty("useServerPrepStmts"), 
equalTo(Boolean.FALSE.toString()));
         assertThat(actual.getProperty("rewriteBatchedStatements"), 
equalTo(Boolean.TRUE.toString()));
         assertThat(actual.getProperty("yearIsDateType"), 
equalTo(Boolean.FALSE.toString()));
         assertThat(actual.getProperty("zeroDateTimeBehavior"), 
equalTo("convertToNull"));