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 b491c9719dd Refactor DriverExecuteExecutor (#32667)
b491c9719dd is described below
commit b491c9719ddf52905ca12e5d8cbca029e7bd463f
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Aug 25 12:13:57 2024 +0800
Refactor DriverExecuteExecutor (#32667)
---
.../driver/executor/engine/DriverExecuteExecutor.java | 14 ++++++++++----
1 file changed, 10 insertions(+), 4 deletions(-)
diff --git
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
index e39a9e54706..e35912b15a4 100644
---
a/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
+++
b/jdbc/src/main/java/org/apache/shardingsphere/driver/executor/engine/DriverExecuteExecutor.java
@@ -100,6 +100,16 @@ public final class DriverExecuteExecutor {
metaDataRefreshEngine.refresh(queryContext.getSqlStatementContext());
return true;
}
+ return executePushDown(database, queryContext, prepareEngine,
executeCallback, addCallback, replayCallback);
+ }
+
+ private MetaDataRefreshEngine getMetaDataRefreshEngine(final
ShardingSphereDatabase database) {
+ return new
MetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(),
database, metaData.getProps());
+ }
+
+ @SuppressWarnings("rawtypes")
+ private boolean executePushDown(final ShardingSphereDatabase database,
final QueryContext queryContext, final
DriverExecutionPrepareEngine<JDBCExecutionUnit, Connection> prepareEngine,
+ final StatementExecuteCallback
executeCallback, final StatementAddCallback addCallback, final
StatementReplayCallback replayCallback) throws SQLException {
ExecutionContext executionContext =
new KernelProcessor().generateExecutionContext(queryContext,
metaData.getGlobalRuleMetaData(), metaData.getProps(),
connection.getDatabaseConnectionManager().getConnectionContext());
if
(database.getRuleMetaData().getAttributes(RawExecutionRuleAttribute.class).isEmpty())
{
@@ -110,10 +120,6 @@ public final class DriverExecuteExecutor {
return rawPushDownExecutor.execute(database, executionContext);
}
- private MetaDataRefreshEngine getMetaDataRefreshEngine(final
ShardingSphereDatabase database) {
- return new
MetaDataRefreshEngine(connection.getContextManager().getPersistServiceFacade().getMetaDataManagerPersistService(),
database, metaData.getProps());
- }
-
/**
* Get result set.
*
