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 <zhangli...@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()));
}
