(shardingsphere) branch master updated: Refactor DriverJDBCExecutor (#31635)

[zhangliang]

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

zhangliang 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 c8c7278dede Refactor DriverJDBCExecutor (#31635)
c8c7278dede is described below

commit c8c7278dede6a5d34895538836b1943a54d88529
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sat Jun 8 16:33:22 2024 +0800

    Refactor DriverJDBCExecutor (#31635)
---
 .../driver/executor/engine/DriverJDBCExecutor.java            | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git 
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverJDBCExecutor.java
 
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverJDBCExecutor.java
index 0e3ea6fd44c..cf0e791d03a 100644
--- 
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverJDBCExecutor.java
+++ 
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverJDBCExecutor.java
@@ -49,17 +49,18 @@ public final class DriverJDBCExecutor {
     
     private final ShardingSphereMetaData metaData;
     
-    private final MetaDataManagerPersistService metaDataManagerPersistService;
+    private final MetaDataManagerPersistService persistService;
     
     private final JDBCExecutor jdbcExecutor;
     
-    private final ProcessEngine processEngine = new ProcessEngine();
+    private final ProcessEngine processEngine;
     
     public DriverJDBCExecutor(final String databaseName, final ContextManager 
contextManager, final JDBCExecutor jdbcExecutor) {
         this.databaseName = databaseName;
-        this.jdbcExecutor = jdbcExecutor;
         metaData = contextManager.getMetaDataContexts().getMetaData();
-        metaDataManagerPersistService = 
contextManager.getPersistServiceFacade().getMetaDataManagerPersistService();
+        persistService = 
contextManager.getPersistServiceFacade().getMetaDataManagerPersistService();
+        this.jdbcExecutor = jdbcExecutor;
+        processEngine = new ProcessEngine();
     }
     
     /**
@@ -149,7 +150,7 @@ public final class DriverJDBCExecutor {
     private <T> List<T> doExecute(final 
ExecutionGroupContext<JDBCExecutionUnit> executionGroupContext, final 
QueryContext queryContext, final Collection<RouteUnit> routeUnits,
                                   final JDBCExecutorCallback<T> callback) 
throws SQLException {
         List<T> results = jdbcExecutor.execute(executionGroupContext, 
callback);
-        new MetaDataRefreshEngine(metaDataManagerPersistService,
+        new MetaDataRefreshEngine(persistService,
                 
metaData.getDatabase(queryContext.getDatabaseNameFromSQLStatement().orElse(databaseName)),
 metaData.getProps()).refresh(queryContext.getSqlStatementContext(), 
routeUnits);
         return results;
     }