You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2022/06/09 04:07:06 UTC
[shardingsphere] branch master updated: Add getter for RALBackendHandler.sqlStatement (#18255)
This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 c9f7da256d3 Add getter for RALBackendHandler.sqlStatement (#18255)
c9f7da256d3 is described below
commit c9f7da256d3c18e915ea6bf77d8adb02fa50f74e
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Thu Jun 9 12:06:59 2022 +0800
Add getter for RALBackendHandler.sqlStatement (#18255)
* Add getter and setter for RALBackendHandler.sqlStatement
* Refactor RefreshTableMetadataHandler
---
.../proxy/backend/text/distsql/ral/RALBackendHandler.java | 6 +++---
.../proxy/backend/text/distsql/ral/advanced/FormatHandler.java | 2 +-
.../text/distsql/ral/advanced/ParseDistSQLBackendHandler.java | 2 +-
.../backend/text/distsql/ral/advanced/PreviewBackendHandler.java | 4 ++--
.../ral/common/queryable/ExportDatabaseConfigurationHandler.java | 8 ++++----
.../queryable/ShowReadwriteSplittingReadResourcesHandler.java | 2 +-
.../distsql/ral/common/queryable/ShowTableMetadataHandler.java | 4 ++--
.../distsql/ral/common/queryable/ShowTrafficRulesHandler.java | 2 +-
.../text/distsql/ral/common/queryable/ShowVariableHandler.java | 4 ++--
.../distsql/ral/common/updatable/AlterSQLParserRuleHandler.java | 9 +++++----
.../distsql/ral/common/updatable/AlterTrafficRuleHandler.java | 2 +-
.../ral/common/updatable/AlterTransactionRuleHandler.java | 2 +-
.../distsql/ral/common/updatable/CreateTrafficRuleHandler.java | 2 +-
.../ral/common/updatable/RefreshTableMetadataHandler.java | 2 +-
.../text/distsql/ral/common/updatable/SetVariableHandler.java | 4 ++--
15 files changed, 28 insertions(+), 27 deletions(-)
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/RALBackendHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/RALBackendHandler.java
index c6f7bf9bd41..86c962f6539 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/RALBackendHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/RALBackendHandler.java
@@ -34,11 +34,10 @@ import java.sql.SQLException;
/**
* RAL backend handler.
*/
+@Getter
public abstract class RALBackendHandler<E extends RALStatement, R extends RALBackendHandler> implements TextProtocolBackendHandler {
- // CHECKSTYLE:OFF
- protected E sqlStatement;
- // CHECKSTYLE:ON
+ private E sqlStatement;
@Override
public final ResponseHeader execute() throws SQLException {
@@ -62,6 +61,7 @@ public abstract class RALBackendHandler<E extends RALStatement, R extends RALBac
/**
* Initialize statement.
+ *
* @param statement RAL statement
* @return the object itself
*/
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/FormatHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/FormatHandler.java
index 4fc927e7f8d..4f6077d9070 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/FormatHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/FormatHandler.java
@@ -50,7 +50,7 @@ public final class FormatHandler extends QueryableRALBackendHandler<FormatStatem
SQLParserEngine parserEngine = new SQLParserEngine("MySQL", cacheOption);
ParseASTNode parseASTNode;
try {
- parseASTNode = parserEngine.parse(sqlStatement.getSql(), false);
+ parseASTNode = parserEngine.parse(getSqlStatement().getSql(), false);
} catch (SQLParsingException ex) {
throw new SQLParsingException("You have a syntax error in your formatted statement");
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/ParseDistSQLBackendHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/ParseDistSQLBackendHandler.java
index 7d59c1ba161..8023d5cbb78 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/ParseDistSQLBackendHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/ParseDistSQLBackendHandler.java
@@ -67,7 +67,7 @@ public final class ParseDistSQLBackendHandler extends QueryableRALBackendHandler
Preconditions.checkState(sqlParserRule.isPresent());
SQLStatement parsedSqlStatement;
try {
- parsedSqlStatement = sqlParserRule.get().getSQLParserEngine(getStorageType(databaseType, connectionSession).getType()).parse(sqlStatement.getSql(), false);
+ parsedSqlStatement = sqlParserRule.get().getSQLParserEngine(getStorageType(databaseType, connectionSession).getType()).parse(getSqlStatement().getSql(), false);
} catch (SQLParsingException ex) {
throw new SQLParsingException("You have a syntax error in your parsed statement");
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/PreviewBackendHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/PreviewBackendHandler.java
index ec036cd3beb..5d4e4fd12a7 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/PreviewBackendHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/PreviewBackendHandler.java
@@ -104,7 +104,7 @@ public final class PreviewBackendHandler extends QueryableRALBackendHandler<Prev
String databaseType = DatabaseTypeEngine.getTrunkDatabaseTypeName(metaDataContexts.getMetaData().getDatabases().get(databaseName).getProtocolType());
Optional<SQLParserRule> sqlParserRule = metaDataContexts.getMetaData().getGlobalRuleMetaData().findSingleRule(SQLParserRule.class);
Preconditions.checkState(sqlParserRule.isPresent());
- SQLStatement previewedStatement = sqlParserRule.get().getSQLParserEngine(databaseType).parse(sqlStatement.getSql(), false);
+ SQLStatement previewedStatement = sqlParserRule.get().getSQLParserEngine(databaseType).parse(getSqlStatement().getSql(), false);
SQLStatementContext<?> sqlStatementContext = SQLStatementContextFactory.newInstance(metaDataContexts.getMetaData().getDatabases(), previewedStatement, databaseName);
// TODO optimize SQLStatementDatabaseHolder
if (sqlStatementContext instanceof TableAvailable) {
@@ -117,7 +117,7 @@ public final class PreviewBackendHandler extends QueryableRALBackendHandler<Prev
if (!database.isComplete()) {
throw new RuleNotExistedException();
}
- LogicSQL logicSQL = new LogicSQL(sqlStatementContext, sqlStatement.getSql(), Collections.emptyList());
+ LogicSQL logicSQL = new LogicSQL(sqlStatementContext, getSqlStatement().getSql(), Collections.emptyList());
ExecutionContext executionContext = kernelProcessor.generateExecutionContext(logicSQL, database, metaDataContexts.getMetaData().getProps());
Collection<ExecutionUnit> executionUnits = executionContext.getRouteContext().isFederated()
? getFederationExecutionUnits(logicSQL, databaseName, metaDataContexts)
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ExportDatabaseConfigurationHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ExportDatabaseConfigurationHandler.java
index c28ac66e712..fdbf4c727d0 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ExportDatabaseConfigurationHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ExportDatabaseConfigurationHandler.java
@@ -119,10 +119,10 @@ public final class ExportDatabaseConfigurationHandler extends QueryableRALBacken
configItem(ZERO, "databaseName", databaseName, result);
getDataSourcesConfig(database, result);
getRuleConfigurations(database.getRuleMetaData().getConfigurations(), result);
- if (!sqlStatement.getFilePath().isPresent()) {
+ if (!getSqlStatement().getFilePath().isPresent()) {
return Collections.singleton(Collections.singletonList(result.toString()));
}
- File outFile = new File(sqlStatement.getFilePath().get());
+ File outFile = new File(getSqlStatement().getFilePath().get());
if (!outFile.exists()) {
outFile.getParentFile().mkdirs();
}
@@ -132,7 +132,7 @@ public final class ExportDatabaseConfigurationHandler extends QueryableRALBacken
} catch (final IOException ex) {
throw new ShardingSphereException(ex);
}
- return Collections.singleton(Collections.singletonList(String.format("Successfully exported to：'%s'", sqlStatement.getFilePath().get())));
+ return Collections.singleton(Collections.singletonList(String.format("Successfully exported to：'%s'", getSqlStatement().getFilePath().get())));
}
private void getDataSourcesConfig(final ShardingSphereDatabase database, final StringBuilder result) {
@@ -220,7 +220,7 @@ public final class ExportDatabaseConfigurationHandler extends QueryableRALBacken
}
private String getDatabaseName() {
- String result = sqlStatement.getDatabase().isPresent() ? sqlStatement.getDatabase().get().getIdentifier().getValue() : connectionSession.getDatabaseName();
+ String result = getSqlStatement().getDatabase().isPresent() ? getSqlStatement().getDatabase().get().getIdentifier().getValue() : connectionSession.getDatabaseName();
if (Strings.isNullOrEmpty(result)) {
throw new NoDatabaseSelectedException();
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowReadwriteSplittingReadResourcesHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowReadwriteSplittingReadResourcesHandler.java
index c974cdd7f20..6bea258a94a 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowReadwriteSplittingReadResourcesHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowReadwriteSplittingReadResourcesHandler.java
@@ -84,7 +84,7 @@ public final class ShowReadwriteSplittingReadResourcesHandler extends QueryableR
}
private String getDatabaseName() {
- String result = sqlStatement.getDatabase().isPresent() ? sqlStatement.getDatabase().get().getIdentifier().getValue() : connectionSession.getDatabaseName();
+ String result = getSqlStatement().getDatabase().isPresent() ? getSqlStatement().getDatabase().get().getIdentifier().getValue() : connectionSession.getDatabaseName();
if (Strings.isNullOrEmpty(result)) {
throw new NoDatabaseSelectedException();
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTableMetadataHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTableMetadataHandler.java
index e9e5be06e2b..0d205d895d9 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTableMetadataHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTableMetadataHandler.java
@@ -67,12 +67,12 @@ public final class ShowTableMetadataHandler extends QueryableRALBackendHandler<S
String databaseName = getDatabaseName();
String defaultSchema = DatabaseTypeEngine.getDefaultSchemaName(connectionSession.getDatabaseType(), connectionSession.getDatabaseName());
ShardingSphereSchema schema = ProxyContext.getInstance().getDatabase(databaseName).getSchemas().get(defaultSchema);
- return schema.getAllTableNames().stream().filter(each -> sqlStatement.getTableNames().contains(each))
+ return schema.getAllTableNames().stream().filter(each -> getSqlStatement().getTableNames().contains(each))
.map(each -> buildTableRows(databaseName, schema, each)).flatMap(Collection::stream).collect(Collectors.toList());
}
private String getDatabaseName() {
- String result = sqlStatement.getDatabase().isPresent() ? sqlStatement.getDatabase().get().getIdentifier().getValue() : connectionSession.getDatabaseName();
+ String result = getSqlStatement().getDatabase().isPresent() ? getSqlStatement().getDatabase().get().getIdentifier().getValue() : connectionSession.getDatabaseName();
if (Strings.isNullOrEmpty(result)) {
throw new NoDatabaseSelectedException();
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTrafficRulesHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTrafficRulesHandler.java
index ec56e068fd8..60b30cd0c62 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTrafficRulesHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowTrafficRulesHandler.java
@@ -62,7 +62,7 @@ public final class ShowTrafficRulesHandler extends QueryableRALBackendHandler<Sh
Optional<TrafficRuleConfiguration> config = ProxyContext.getInstance().getContextManager().getMetaDataContexts()
.getMetaData().getGlobalRuleMetaData().findRuleConfigurations(TrafficRuleConfiguration.class).stream().findAny();
Collection<List<Object>> result = new LinkedList<>();
- Optional<String> ruleName = Optional.ofNullable(sqlStatement.getRuleName());
+ Optional<String> ruleName = Optional.ofNullable(getSqlStatement().getRuleName());
config.ifPresent(optional -> {
Map<String, ShardingSphereAlgorithmConfiguration> trafficAlgorithms = optional.getTrafficAlgorithms();
Map<String, ShardingSphereAlgorithmConfiguration> loadBalancers = optional.getLoadBalancers();
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowVariableHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowVariableHandler.java
index 32ed830405f..d99fdbdf104 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowVariableHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/queryable/ShowVariableHandler.java
@@ -62,14 +62,14 @@ public final class ShowVariableHandler extends QueryableRALBackendHandler<ShowVa
@Override
protected Collection<List<Object>> getRows(final ContextManager contextManager) {
if (hasSpecifiedKey()) {
- return buildSpecifiedRow(contextManager, sqlStatement.getName());
+ return buildSpecifiedRow(contextManager, getSqlStatement().getName());
} else {
return buildAllVariableRows(contextManager);
}
}
private boolean hasSpecifiedKey() {
- return !Strings.isNullOrEmpty(sqlStatement.getName());
+ return !Strings.isNullOrEmpty(getSqlStatement().getName());
}
private Collection<List<Object>> buildAllVariableRows(final ContextManager contextManager) {
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterSQLParserRuleHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterSQLParserRuleHandler.java
index 4130f5e10e9..c35cf3b6c32 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterSQLParserRuleHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterSQLParserRuleHandler.java
@@ -52,10 +52,11 @@ public final class AlterSQLParserRuleHandler extends UpdatableRALBackendHandler<
private SQLParserRuleConfiguration createSQLParserRuleConfiguration(final SQLParserRuleConfiguration currentConfig) {
SQLParserRuleConfiguration result = new SQLParserRuleConfiguration();
- result.setSqlCommentParseEnabled(null == sqlStatement.getSqlCommentParseEnable() ? currentConfig.isSqlCommentParseEnabled() : sqlStatement.getSqlCommentParseEnable());
- result.setParseTreeCache(null == sqlStatement.getParseTreeCache() ? currentConfig.getParseTreeCache() : createCacheOption(currentConfig.getParseTreeCache(), sqlStatement.getParseTreeCache()));
- result.setSqlStatementCache(null == sqlStatement.getSqlStatementCache() ? currentConfig.getSqlStatementCache()
- : createCacheOption(currentConfig.getSqlStatementCache(), sqlStatement.getSqlStatementCache()));
+ result.setSqlCommentParseEnabled(null == getSqlStatement().getSqlCommentParseEnable() ? currentConfig.isSqlCommentParseEnabled() : getSqlStatement().getSqlCommentParseEnable());
+ result.setParseTreeCache(
+ null == getSqlStatement().getParseTreeCache() ? currentConfig.getParseTreeCache() : createCacheOption(currentConfig.getParseTreeCache(), getSqlStatement().getParseTreeCache()));
+ result.setSqlStatementCache(null == getSqlStatement().getSqlStatementCache() ? currentConfig.getSqlStatementCache()
+ : createCacheOption(currentConfig.getSqlStatementCache(), getSqlStatement().getSqlStatementCache()));
return result;
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTrafficRuleHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTrafficRuleHandler.java
index 1789cddac9f..b2729026f89 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTrafficRuleHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTrafficRuleHandler.java
@@ -67,7 +67,7 @@ public final class AlterTrafficRuleHandler extends UpdatableRALBackendHandler<Al
private Collection<String> getInvalidAlgorithmNames() {
Collection<String> result = new LinkedList<>();
- for (TrafficRuleSegment each : sqlStatement.getSegments()) {
+ for (TrafficRuleSegment each : getSqlStatement().getSegments()) {
if (!TrafficAlgorithmFactory.contains(each.getAlgorithm().getName())) {
result.add(each.getAlgorithm().getName());
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTransactionRuleHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTransactionRuleHandler.java
index 9173f74fcba..3699a266eff 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTransactionRuleHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/AlterTransactionRuleHandler.java
@@ -59,6 +59,6 @@ public final class AlterTransactionRuleHandler extends UpdatableRALBackendHandle
}
private TransactionRuleConfiguration buildTransactionRuleConfiguration() {
- return new TransactionRuleConfiguration(sqlStatement.getDefaultType(), sqlStatement.getProvider().getProviderType(), sqlStatement.getProvider().getProps());
+ return new TransactionRuleConfiguration(getSqlStatement().getDefaultType(), getSqlStatement().getProvider().getProviderType(), getSqlStatement().getProvider().getProps());
}
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/CreateTrafficRuleHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/CreateTrafficRuleHandler.java
index 5bf6909cd7a..3ece9feb9fc 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/CreateTrafficRuleHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/CreateTrafficRuleHandler.java
@@ -64,7 +64,7 @@ public final class CreateTrafficRuleHandler extends UpdatableRALBackendHandler<C
private void checkInvalidAlgorithmNames() throws DistSQLException {
Collection<String> invalidAlgorithmNames = new LinkedList<>();
- for (TrafficRuleSegment each : sqlStatement.getSegments()) {
+ for (TrafficRuleSegment each : getSqlStatement().getSegments()) {
if (!TrafficAlgorithmFactory.contains(each.getAlgorithm().getName())) {
invalidAlgorithmNames.add(each.getAlgorithm().getName());
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/RefreshTableMetadataHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/RefreshTableMetadataHandler.java
index af3731a1c9b..47d44634fd7 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/RefreshTableMetadataHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/RefreshTableMetadataHandler.java
@@ -37,7 +37,7 @@ public final class RefreshTableMetadataHandler extends UpdatableRALBackendHandle
@Override
public RefreshTableMetadataHandler init(final HandlerParameter<RefreshTableMetadataStatement> parameter) {
- sqlStatement = parameter.getStatement();
+ initStatement(parameter.getStatement());
connectionSession = parameter.getConnectionSession();
return this;
}
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetVariableHandler.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetVariableHandler.java
index 3f5f5894269..68d1d2766e6 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetVariableHandler.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetVariableHandler.java
@@ -97,11 +97,11 @@ public final class SetVariableHandler extends UpdatableRALBackendHandler<SetVari
VariableEnum variable = VariableEnum.getValueOf(setVariableStatement.getName());
switch (variable) {
case AGENT_PLUGINS_ENABLED:
- Boolean agentPluginsEnabled = BooleanUtils.toBooleanObject(sqlStatement.getValue());
+ Boolean agentPluginsEnabled = BooleanUtils.toBooleanObject(getSqlStatement().getValue());
SystemPropertyUtil.setSystemProperty(variable.name(), null == agentPluginsEnabled ? Boolean.FALSE.toString() : agentPluginsEnabled.toString());
break;
case TRANSACTION_TYPE:
- connectionSession.getTransactionStatus().setTransactionType(getTransactionType(sqlStatement.getValue()));
+ connectionSession.getTransactionStatus().setTransactionType(getTransactionType(getSqlStatement().getValue()));
break;
default:
throw new UnsupportedVariableException(setVariableStatement.getName());