Skip to content

Commit ac73b9e

Browse files
authored
Refactor DriverExecutorFacade (#31768)
1 parent d465975 commit ac73b9e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecutorFacade.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,10 +72,10 @@ public DriverExecutorFacade(final ShardingSphereConnection connection, final Sta
7272
this.statementManager = statementManager;
7373
this.jdbcDriverType = jdbcDriverType;
7474
JDBCExecutor jdbcExecutor = new JDBCExecutor(connection.getContextManager().getExecutorEngine(), connection.getDatabaseConnectionManager().getConnectionContext());
75-
RawExecutor rawExecutor = new RawExecutor(connection.getContextManager().getExecutorEngine(), connection.getDatabaseConnectionManager().getConnectionContext());
7675
ShardingSphereMetaData metaData = connection.getContextManager().getMetaDataContexts().getMetaData();
7776
String schemaName = new DatabaseTypeRegistry(metaData.getDatabase(connection.getDatabaseName()).getProtocolType()).getDefaultSchemaName(connection.getDatabaseName());
7877
sqlFederationEngine = new SQLFederationEngine(connection.getDatabaseName(), schemaName, metaData, connection.getContextManager().getMetaDataContexts().getStatistics(), jdbcExecutor);
78+
RawExecutor rawExecutor = new RawExecutor(connection.getContextManager().getExecutorEngine(), connection.getDatabaseConnectionManager().getConnectionContext());
7979
queryExecutor = new DriverExecuteQueryExecutor(connection, metaData, jdbcExecutor, rawExecutor, sqlFederationEngine);
8080
updateExecutor = new DriverExecuteUpdateExecutor(connection, metaData, jdbcExecutor, rawExecutor);
8181
executeExecutor = new DriverExecuteExecutor(connection, metaData, jdbcExecutor, rawExecutor, sqlFederationEngine);

0 commit comments

Comments
 (0)