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 937a557280d SQL E2E compatible with com.mysql:mysql-connector-j:8.0
(#28874)
937a557280d is described below
commit 937a557280dd7511516ece450ae61bf22dfd39d6
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Thu Oct 26 17:16:57 2023 +0800
SQL E2E compatible with com.mysql:mysql-connector-j:8.0 (#28874)
---
.../org/apache/shardingsphere/test/e2e/engine/type/RALE2EIT.java | 3 ++-
.../org/apache/shardingsphere/test/e2e/engine/type/RQLE2EIT.java | 9 +++++----
2 files changed, 7 insertions(+), 5 deletions(-)
diff --git
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RALE2EIT.java
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RALE2EIT.java
index c86fbc37391..cf2c3951ccb 100644
---
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RALE2EIT.java
+++
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RALE2EIT.java
@@ -124,7 +124,8 @@ class RALE2EIT {
}
private void assertResultSet(final SingleE2EContainerComposer
containerComposer, final Statement statement, final String sql) throws
SQLException {
- try (ResultSet resultSet = statement.executeQuery(sql)) {
+ statement.execute(sql);
+ try (ResultSet resultSet = statement.getResultSet()) {
assertResultSet(containerComposer, resultSet);
}
}
diff --git
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RQLE2EIT.java
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RQLE2EIT.java
index 51b31512064..8da1eff7781 100644
---
a/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RQLE2EIT.java
+++
b/test/e2e/sql/src/test/java/org/apache/shardingsphere/test/e2e/engine/type/RQLE2EIT.java
@@ -59,10 +59,11 @@ class RQLE2EIT {
}
private void assertExecute(final SingleE2EContainerComposer
containerComposer) throws SQLException {
- try (Connection connection =
containerComposer.getTargetDataSource().getConnection()) {
- try (
- Statement statement = connection.createStatement();
- ResultSet resultSet =
statement.executeQuery(containerComposer.getSQL())) {
+ try (
+ Connection connection =
containerComposer.getTargetDataSource().getConnection();
+ Statement statement = connection.createStatement()) {
+ statement.execute(containerComposer.getSQL());
+ try (ResultSet resultSet = statement.getResultSet()) {
assertResultSet(containerComposer, resultSet);
}
}