You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2025/06/15 13:38:03 UTC
(shardingsphere) branch master updated: Rename ExplainStatementContext.explainableSQLStatementContext (#35718)
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 89b80267c75 Rename ExplainStatementContext.explainableSQLStatementContext (#35718)
89b80267c75 is described below
commit 89b80267c756ae50d4fdef6d7c3a2a0ae12b8451
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Sun Jun 15 21:37:57 2025 +0800
Rename ExplainStatementContext.explainableSQLStatementContext (#35718)
---
.../shardingsphere/sharding/decider/ShardingSQLFederationDecider.java | 4 ++--
.../binder/context/statement/type/dal/ExplainStatementContext.java | 4 ++--
.../shardingsphere/single/decider/SingleSQLFederationDecider.java | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/decider/ShardingSQLFederationDecider.java b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/decider/ShardingSQLFederationDecider.java
index e97103f029f..160c40320c0 100644
--- a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/decider/ShardingSQLFederationDecider.java
+++ b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/decider/ShardingSQLFederationDecider.java
@@ -48,10 +48,10 @@ public final class ShardingSQLFederationDecider implements SQLFederationDecider<
return decide0((SelectStatementContext) sqlStatementContext, database, rule, includedDataNodes);
} else if (sqlStatementContext instanceof ExplainStatementContext) {
ExplainStatementContext explainStatementContext = (ExplainStatementContext) sqlStatementContext;
- ShardingSpherePreconditions.checkState(explainStatementContext.getSqlStatementContext() instanceof SelectStatementContext,
+ ShardingSpherePreconditions.checkState(explainStatementContext.getExplainableSQLStatementContext() instanceof SelectStatementContext,
() -> new UnsupportedSQLOperationException(
String.format("unsupported Explain %s statement in sql federation", explainStatementContext.getSqlStatement().getExplainableSQLStatement())));
- return decide0((SelectStatementContext) explainStatementContext.getSqlStatementContext(), database, rule, includedDataNodes);
+ return decide0((SelectStatementContext) explainStatementContext.getExplainableSQLStatementContext(), database, rule, includedDataNodes);
}
throw new UnsupportedSQLOperationException(String.format("unsupported SQL statement %s in sql federation", sqlStatementContext.getSqlStatement()));
}
diff --git a/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dal/ExplainStatementContext.java b/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dal/ExplainStatementContext.java
index 8d9ab6c81d8..fd08d542c9e 100644
--- a/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dal/ExplainStatementContext.java
+++ b/infra/binder/core/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/type/dal/ExplainStatementContext.java
@@ -39,13 +39,13 @@ public final class ExplainStatementContext extends CommonSQLStatementContext {
private final TablesContext tablesContext;
- private final SQLStatementContext sqlStatementContext;
+ private final SQLStatementContext explainableSQLStatementContext;
public ExplainStatementContext(final ShardingSphereMetaData metaData, final DatabaseType databaseType, final ExplainStatement sqlStatement, final List<Object> params,
final String currentDatabaseName) {
super(databaseType, sqlStatement);
tablesContext = new TablesContext(extractTablesFromExplain(sqlStatement));
- sqlStatementContext = SQLStatementContextFactory.newInstance(metaData, databaseType, sqlStatement.getExplainableSQLStatement(), params, currentDatabaseName);
+ explainableSQLStatementContext = SQLStatementContextFactory.newInstance(metaData, databaseType, sqlStatement.getExplainableSQLStatement(), params, currentDatabaseName);
}
private Collection<SimpleTableSegment> extractTablesFromExplain(final ExplainStatement sqlStatement) {
diff --git a/kernel/single/core/src/main/java/org/apache/shardingsphere/single/decider/SingleSQLFederationDecider.java b/kernel/single/core/src/main/java/org/apache/shardingsphere/single/decider/SingleSQLFederationDecider.java
index 6cb658e4e54..914fb9d92c5 100644
--- a/kernel/single/core/src/main/java/org/apache/shardingsphere/single/decider/SingleSQLFederationDecider.java
+++ b/kernel/single/core/src/main/java/org/apache/shardingsphere/single/decider/SingleSQLFederationDecider.java
@@ -50,10 +50,10 @@ public final class SingleSQLFederationDecider implements SQLFederationDecider<Si
return decide0((SelectStatementContext) sqlStatementContext, database, rule, includedDataNodes);
} else if (sqlStatementContext instanceof ExplainStatementContext) {
ExplainStatementContext explainStatementContext = (ExplainStatementContext) sqlStatementContext;
- ShardingSpherePreconditions.checkState(explainStatementContext.getSqlStatementContext() instanceof SelectStatementContext,
+ ShardingSpherePreconditions.checkState(explainStatementContext.getExplainableSQLStatementContext() instanceof SelectStatementContext,
() -> new UnsupportedSQLOperationException(
String.format("unsupported Explain %s statement in sql federation", explainStatementContext.getSqlStatement().getExplainableSQLStatement())));
- return decide0((SelectStatementContext) explainStatementContext.getSqlStatementContext(), database, rule, includedDataNodes);
+ return decide0((SelectStatementContext) explainStatementContext.getExplainableSQLStatementContext(), database, rule, includedDataNodes);
}
throw new UnsupportedSQLOperationException(String.format("unsupported SQL statement %s in sql federation", sqlStatementContext.getSqlStatement()));
}