This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 7f80f90199a For codes format (#31747)
7f80f90199a is described below
commit 7f80f90199a6693d46c676c48bd9d291381a11cd
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Jun 18 17:43:10 2024 +0800
For codes format (#31747)
* For code format
* For codes format
* For codes format
---
.../opengauss/check/datasource/OpenGaussDataSourceChecker.java | 4 +++-
.../postgresql/check/datasource/PostgreSQLDataSourceChecker.java | 4 +++-
.../test/e2e/driver/statement/ShardingPreparedStatementTest.java | 4 +++-
.../test/e2e/driver/statement/ShardingStatementTest.java | 4 +++-
.../transaction/cases/classictransfer/ClassicTransferTestCase.java | 4 +++-
5 files changed, 15 insertions(+), 5 deletions(-)
diff --git
a/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/check/datasource/OpenGaussDataSourceChecker.java
b/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/check/datasource/OpenGaussDataSourceChecker.java
index f9819c42f46..c098fe3c580 100644
---
a/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/check/datasource/OpenGaussDataSourceChecker.java
+++
b/kernel/data-pipeline/dialect/opengauss/src/main/java/org/apache/shardingsphere/data/pipeline/opengauss/check/datasource/OpenGaussDataSourceChecker.java
@@ -40,7 +40,9 @@ public final class OpenGaussDataSourceChecker implements
DialectDataSourceChecke
@Override
public void checkPrivilege(final DataSource dataSource) {
- try (Connection connection = dataSource.getConnection();
PreparedStatement preparedStatement =
connection.prepareStatement(SHOW_GRANTS_SQL)) {
+ try (
+ Connection connection = dataSource.getConnection();
+ PreparedStatement preparedStatement =
connection.prepareStatement(SHOW_GRANTS_SQL)) {
DatabaseMetaData metaData = connection.getMetaData();
preparedStatement.setString(1, metaData.getUserName());
try (ResultSet resultSet = preparedStatement.executeQuery()) {
diff --git
a/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/check/datasource/PostgreSQLDataSourceChecker.java
b/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/check/datasource/PostgreSQLDataSourceChecker.java
index 693afc16076..b51f9ba14cc 100644
---
a/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/check/datasource/PostgreSQLDataSourceChecker.java
+++
b/kernel/data-pipeline/dialect/postgresql/src/main/java/org/apache/shardingsphere/data/pipeline/postgresql/check/datasource/PostgreSQLDataSourceChecker.java
@@ -42,7 +42,9 @@ public final class PostgreSQLDataSourceChecker implements
DialectDataSourceCheck
@Override
public void checkPrivilege(final DataSource dataSource) {
- try (Connection connection = dataSource.getConnection();
PreparedStatement preparedStatement =
connection.prepareStatement(SHOW_GRANTS_SQL)) {
+ try (
+ Connection connection = dataSource.getConnection();
+ PreparedStatement preparedStatement =
connection.prepareStatement(SHOW_GRANTS_SQL)) {
DatabaseMetaData metaData = connection.getMetaData();
preparedStatement.setString(1, metaData.getUserName());
try (ResultSet resultSet = preparedStatement.executeQuery()) {
diff --git
a/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingPreparedStatementTest.java
b/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingPreparedStatementTest.java
index cd119bf312e..57c4ef93ae4 100644
---
a/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingPreparedStatementTest.java
+++
b/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingPreparedStatementTest.java
@@ -621,7 +621,9 @@ class ShardingPreparedStatementTest extends
AbstractShardingDriverTest {
@Test
void assertExecuteBatchRepeatedly() throws SQLException {
- try (Connection connection =
getShardingSphereDataSource().getConnection(); PreparedStatement
preparedStatement = connection.prepareStatement(INSERT_WITH_GENERATE_KEY_SQL)) {
+ try (
+ Connection connection =
getShardingSphereDataSource().getConnection();
+ PreparedStatement preparedStatement =
connection.prepareStatement(INSERT_WITH_GENERATE_KEY_SQL)) {
preparedStatement.setInt(1, 3101);
preparedStatement.setInt(2, 11);
preparedStatement.setInt(3, 11);
diff --git
a/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingStatementTest.java
b/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingStatementTest.java
index cd8db1a672c..e346c7e924d 100644
---
a/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingStatementTest.java
+++
b/test/e2e/driver/src/test/java/org/apache/shardingsphere/test/e2e/driver/statement/ShardingStatementTest.java
@@ -129,7 +129,9 @@ class ShardingStatementTest extends
AbstractShardingDriverTest {
@Test
void assertExecuteBatch() throws SQLException {
- try (Connection connection =
getShardingSphereDataSource().getConnection(); Statement statement =
connection.createStatement()) {
+ try (
+ Connection connection =
getShardingSphereDataSource().getConnection();
+ Statement statement = connection.createStatement()) {
statement.addBatch("UPDATE t_order SET status = 'closed' WHERE
order_id = 1001");
statement.addBatch("UPDATE t_order SET status = 'closed' WHERE
order_id = 1100 OR order_id = 1101");
statement.addBatch("DELETE FROM t_order WHERE order_id = 1000");
diff --git
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/classictransfer/ClassicTransferTestCase.java
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/classictransfer/ClassicTransferTestCase.java
index 88c7638554e..2d5a275969a 100644
---
a/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/classictransfer/ClassicTransferTestCase.java
+++
b/test/e2e/operation/transaction/src/test/java/org/apache/shardingsphere/test/e2e/transaction/cases/classictransfer/ClassicTransferTestCase.java
@@ -75,7 +75,9 @@ public final class ClassicTransferTestCase extends
BaseTransactionTestCase {
private int getBalanceSum() throws SQLException {
int result = 0;
- try (Connection connection = getDataSource().getConnection();
Statement statement = connection.createStatement()) {
+ try (
+ Connection connection = getDataSource().getConnection();
+ Statement statement = connection.createStatement()) {
connection.setAutoCommit(false);
ResultSet resultSet = statement.executeQuery("select sum(balance)
as a from account where transaction_id in (1, 2)");
if (resultSet.next()) {
