[shardingsphere] branch master updated: Add netTimeoutForStreamingResults param at MySQLJdbcQueryPropertiesExtension (#24356)

[zhonghongsheng]

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

zhonghongsheng 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 d5d4a3707f1 Add netTimeoutForStreamingResults param at 
MySQLJdbcQueryPropertiesExtension (#24356)
d5d4a3707f1 is described below

commit d5d4a3707f13d2e8700c369c71d36920f20fd242
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Mon Feb 27 12:42:54 2023 +0800

    Add netTimeoutForStreamingResults param at 
MySQLJdbcQueryPropertiesExtension (#24356)
---
 .../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 b202edf176a..1cebabab5ff 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
@@ -40,6 +40,7 @@ public final class MySQLJdbcQueryPropertiesExtension 
implements JdbcQueryPropert
         queryProps.setProperty("zeroDateTimeBehavior", 
getZeroDateTimeBehavior());
         queryProps.setProperty("noDatetimeStringSync", 
Boolean.TRUE.toString());
         queryProps.setProperty("jdbcCompliantTruncation", 
Boolean.FALSE.toString());
+        queryProps.setProperty("netTimeoutForStreamingResults", "600");
     }
     
     private String 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 7d693c3ae22..213d222f8d5 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,12 +45,13 @@ public final class MySQLJdbcQueryPropertiesExtensionTest {
     }
     
     private void assertQueryProperties(final Properties actual) {
-        assertThat(actual.size(), equalTo(6));
+        assertThat(actual.size(), equalTo(7));
         assertThat(actual.getProperty("useSSL"), 
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"));
         assertThat(actual.getProperty("noDatetimeStringSync"), 
equalTo(Boolean.TRUE.toString()));
         assertThat(actual.getProperty("jdbcCompliantTruncation"), 
equalTo(Boolean.FALSE.toString()));
+        assertThat(actual.getProperty("netTimeoutForStreamingResults"), 
equalTo("600"));
     }
 }