Refactor DriverExecutor

apache · May 27, 2024 · bd9a507 · bd9a507
1 parent 28350a5
commit bd9a507
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/DriverExecutor.java b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/DriverExecutor.java
@@ -112,7 +112,7 @@ public Optional<ResultSet> executeAdvanceQuery(final ShardingSphereMetaData meta
      * @throws SQLException SQL exception
      */
     public Optional<Integer> executeAdvanceUpdate(final ShardingSphereMetaData metaData, final ShardingSphereDatabase database, final QueryContext queryContext,
-                                                   final DriverExecutionPrepareEngine<JDBCExecutionUnit, Connection> prepareEngine) throws SQLException {
+                                                  final DriverExecutionPrepareEngine<JDBCExecutionUnit, Connection> prepareEngine) throws SQLException {
         Optional<String> trafficInstanceId = connection.getTrafficInstanceId(metaData.getGlobalRuleMetaData().getSingleRule(TrafficRule.class), queryContext);
         if (trafficInstanceId.isPresent()) {
             return Optional.of(trafficExecutor.execute(connection.getProcessId(), database.getName(),
@@ -154,8 +154,8 @@ public Optional<Integer> executeAdvanceUpdate(final ShardingSphereMetaData metaD
      * @throws SQLException SQL exception
      */
     public Optional<Boolean> executeAdvance(final ShardingSphereMetaData metaData, final ShardingSphereDatabase database,
-                                              final QueryContext queryContext, final DriverExecutionPrepareEngine<JDBCExecutionUnit, Connection> prepareEngine,
-                                              final TrafficExecutorCallback<Boolean> trafficCallback) throws SQLException {
+                                            final QueryContext queryContext, final DriverExecutionPrepareEngine<JDBCExecutionUnit, Connection> prepareEngine,
+                                            final TrafficExecutorCallback<Boolean> trafficCallback) throws SQLException {
         Optional<String> trafficInstanceId = connection.getTrafficInstanceId(metaData.getGlobalRuleMetaData().getSingleRule(TrafficRule.class), queryContext);
         if (trafficInstanceId.isPresent()) {
             executeType = ExecuteType.TRAFFIC;