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 ac73b9e1417 Refactor DriverExecutorFacade (#31768)
ac73b9e1417 is described below

commit ac73b9e141787ba29f077af988cbbdbf4d438374
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Jun 19 22:47:42 2024 +0800

    Refactor DriverExecutorFacade (#31768)
---
 .../shardingsphere/driver/executor/engine/DriverExecutorFacade.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecutorFacade.java
 
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecutorFacade.java
index 1c016153596..d4829cd9118 100644
--- 
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecutorFacade.java
+++ 
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecutorFacade.java
@@ -72,10 +72,10 @@ public final class DriverExecutorFacade implements 
AutoCloseable {
         this.statementManager = statementManager;
         this.jdbcDriverType = jdbcDriverType;
         JDBCExecutor jdbcExecutor = new 
JDBCExecutor(connection.getContextManager().getExecutorEngine(), 
connection.getDatabaseConnectionManager().getConnectionContext());
-        RawExecutor rawExecutor = new 
RawExecutor(connection.getContextManager().getExecutorEngine(), 
connection.getDatabaseConnectionManager().getConnectionContext());
         ShardingSphereMetaData metaData = 
connection.getContextManager().getMetaDataContexts().getMetaData();
         String schemaName = new 
DatabaseTypeRegistry(metaData.getDatabase(connection.getDatabaseName()).getProtocolType()).getDefaultSchemaName(connection.getDatabaseName());
         sqlFederationEngine = new 
SQLFederationEngine(connection.getDatabaseName(), schemaName, metaData, 
connection.getContextManager().getMetaDataContexts().getStatistics(), 
jdbcExecutor);
+        RawExecutor rawExecutor = new 
RawExecutor(connection.getContextManager().getExecutorEngine(), 
connection.getDatabaseConnectionManager().getConnectionContext());
         queryExecutor = new DriverExecuteQueryExecutor(connection, metaData, 
jdbcExecutor, rawExecutor, sqlFederationEngine);
         updateExecutor = new DriverExecuteUpdateExecutor(connection, metaData, 
jdbcExecutor, rawExecutor);
         executeExecutor = new DriverExecuteExecutor(connection, metaData, 
jdbcExecutor, rawExecutor, sqlFederationEngine);

Reply via email to