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 af16f66b41c Reuse standard SQLStatement and remove unnecessary SQL92
SQLStatements (#35568)
af16f66b41c is described below
commit af16f66b41cb734e753daad4dfc3075f58db7ace
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Jun 1 01:51:20 2025 +0800
Reuse standard SQLStatement and remove unnecessary SQL92 SQLStatements
(#35568)
---
.../core/advice/SQLRouteCountAdviceTest.java | 12 +++++-----
.../fixture/EncryptGeneratorFixtureBuilder.java | 8 +++----
...ShardingCreateFunctionSupportedCheckerTest.java | 3 +--
...hardingCreateProcedureSupportedCheckerTest.java | 3 +--
.../ShardingCreateTableSupportedCheckerTest.java | 5 ++--
.../ddl/ShardingDropTableSupportedCheckerTest.java | 3 +--
.../dml/ShardingDeleteSupportedCheckerTest.java | 3 +--
.../dml/ShardingUpdateSupportedCheckerTest.java | 3 +--
.../merge/ShardingResultMergerEngineTest.java | 3 +--
.../ShardingDropTableRouteContextCheckerTest.java | 3 +--
.../dml/ShardingUpdateRouteContextCheckerTest.java | 3 +--
.../type/ShardingRouteEngineFactoryTest.java | 3 +--
.../engine/GeneratedKeyContextEngineTest.java | 7 +++---
.../statement/SQLStatementContextFactoryTest.java | 3 +--
.../statement/dcl/GrantStatementContextTest.java | 3 +--
.../statement/dcl/RevokeStatementContextTest.java | 3 +--
.../ddl/AlterTableStatementContextTest.java | 3 +--
.../ddl/CreateTableStatementContextTest.java | 3 +--
.../ddl/DropTableStatementContextTest.java | 3 +--
.../statement/ddl/PrepareStatementContextTest.java | 9 +++-----
.../statement/dml/DeleteStatementContextTest.java | 3 +--
.../statement/dml/InsertStatementContextTest.java | 11 ++++-----
.../statement/dml/UpdateStatementContextTest.java | 3 +--
.../statement/dml/DeleteStatementBinderTest.java | 3 +--
.../statement/dml/InsertStatementBinderTest.java | 7 +++---
.../statement/dml/UpdateStatementBinderTest.java | 3 +--
.../executor/sql/process/ProcessEngineTest.java | 3 +--
.../single/route/SingleSQLRouterTest.java | 3 +--
.../route/engine/engine/SingleRouteEngineTest.java | 5 ++--
.../transaction/util/AutoCommitUtilsTest.java | 7 +++---
.../statement/type/SQL92DCLStatementVisitor.java | 10 ++++----
.../statement/type/SQL92DDLStatementVisitor.java | 14 +++++------
.../statement/type/SQL92DMLStatementVisitor.java | 14 +++++------
.../statement/type/SQL92TCLStatementVisitor.java | 8 +++----
.../statement/sql92/dcl/SQL92GrantStatement.java | 27 ----------------------
.../statement/sql92/dcl/SQL92RevokeStatement.java | 27 ----------------------
.../sql92/ddl/SQL92AlterTableStatement.java | 27 ----------------------
.../sql92/ddl/SQL92CreateTableStatement.java | 27 ----------------------
.../sql92/ddl/SQL92DropTableStatement.java | 27 ----------------------
.../statement/sql92/dml/SQL92DeleteStatement.java | 27 ----------------------
.../statement/sql92/dml/SQL92InsertStatement.java | 27 ----------------------
.../statement/sql92/dml/SQL92UpdateStatement.java | 27 ----------------------
.../statement/sql92/tcl/SQL92CommitStatement.java | 27 ----------------------
.../sql92/tcl/SQL92SetTransactionStatement.java | 27 ----------------------
44 files changed, 74 insertions(+), 376 deletions(-)
diff --git
a/agent/plugins/metrics/core/src/test/java/org/apache/shardingsphere/agent/plugin/metrics/core/advice/SQLRouteCountAdviceTest.java
b/agent/plugins/metrics/core/src/test/java/org/apache/shardingsphere/agent/plugin/metrics/core/advice/SQLRouteCountAdviceTest.java
index 3b644c66719..c6e480aa602 100644
---
a/agent/plugins/metrics/core/src/test/java/org/apache/shardingsphere/agent/plugin/metrics/core/advice/SQLRouteCountAdviceTest.java
+++
b/agent/plugins/metrics/core/src/test/java/org/apache/shardingsphere/agent/plugin/metrics/core/advice/SQLRouteCountAdviceTest.java
@@ -30,10 +30,10 @@ import
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import org.apache.shardingsphere.infra.session.connection.ConnectionContext;
import org.apache.shardingsphere.infra.session.query.QueryContext;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92DeleteStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Test;
@@ -61,7 +61,7 @@ class SQLRouteCountAdviceTest {
@Test
void assertInsertRoute() {
QueryContext queryContext = new QueryContext(new
UnknownSQLStatementContext(
- databaseType, new SQL92InsertStatement()), "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
+ databaseType, new InsertStatement()), "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
assertRoute(queryContext, "INSERT=1");
}
@@ -74,14 +74,14 @@ class SQLRouteCountAdviceTest {
@Test
void assertUpdateRoute() {
QueryContext queryContext = new QueryContext(new
UnknownSQLStatementContext(
- databaseType, new SQL92UpdateStatement()), "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
+ databaseType, new UpdateStatement()), "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
assertRoute(queryContext, "UPDATE=1");
}
@Test
void assertDeleteRoute() {
QueryContext queryContext = new QueryContext(new
UnknownSQLStatementContext(
- databaseType, new SQL92DeleteStatement()), "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
+ databaseType, new DeleteStatement()), "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
assertRoute(queryContext, "DELETE=1");
}
diff --git
a/features/encrypt/core/src/test/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/fixture/EncryptGeneratorFixtureBuilder.java
b/features/encrypt/core/src/test/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/fixture/EncryptGeneratorFixtureBuilder.java
index 60b71c8ce2b..6512dab6108 100644
---
a/features/encrypt/core/src/test/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/fixture/EncryptGeneratorFixtureBuilder.java
+++
b/features/encrypt/core/src/test/java/org/apache/shardingsphere/encrypt/rewrite/token/generator/fixture/EncryptGeneratorFixtureBuilder.java
@@ -60,9 +60,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertS
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import java.util.ArrayList;
import java.util.Arrays;
@@ -121,7 +119,7 @@ public final class EncryptGeneratorFixtureBuilder {
}
private static InsertStatement createInsertStatement() {
- InsertStatement result = new SQL92InsertStatement();
+ InsertStatement result = new InsertStatement();
result.setTable(new SimpleTableSegment(new TableNameSegment(0, 0, new
IdentifierValue("t_user"))));
InsertColumnsSegment insertColumnsSegment = new
InsertColumnsSegment(0, 0, Arrays.asList(
new ColumnSegment(0, 0, new IdentifierValue("id")), new
ColumnSegment(0, 0, new IdentifierValue("name")),
@@ -132,7 +130,7 @@ public final class EncryptGeneratorFixtureBuilder {
}
private static InsertStatement createInsertSelectStatement(final boolean
containsInsertColumns) {
- InsertStatement result = new SQL92InsertStatement();
+ InsertStatement result = new InsertStatement();
result.setTable(new SimpleTableSegment(new TableNameSegment(0, 0, new
IdentifierValue("t_user"))));
ColumnSegment userIdColumn = new ColumnSegment(0, 0, new
IdentifierValue("user_id"));
userIdColumn.setColumnBoundInfo(new ColumnSegmentBoundInfo(new
TableSegmentBoundInfo(new IdentifierValue("foo_db"), new
IdentifierValue("foo_db")), new IdentifierValue("t_user"),
@@ -166,7 +164,7 @@ public final class EncryptGeneratorFixtureBuilder {
* @return created update statement context
*/
public static UpdateStatementContext createUpdateStatementContext() {
- UpdateStatement updateStatement = new SQL92UpdateStatement();
+ UpdateStatement updateStatement = new UpdateStatement();
updateStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_user"))));
updateStatement.setWhere(createWhereSegment());
updateStatement.setSetAssignment(createSetAssignmentSegment());
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateFunctionSupportedCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateFunctionSupportedCheckerTest.java
index 0ea8d608990..7bcc76c5616 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateFunctionSupportedCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateFunctionSupportedCheckerTest.java
@@ -32,7 +32,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateF
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -108,7 +107,7 @@ class ShardingCreateFunctionSupportedCheckerTest {
@Test
void assertCheckCreateFunctionWithTableExists() {
- CreateTableStatement createTableStatement = new
SQL92CreateTableStatement();
+ CreateTableStatement createTableStatement = new CreateTableStatement();
createTableStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("foo_tbl"))));
ValidStatementSegment validStatementSegment = new
ValidStatementSegment(0, 0);
validStatementSegment.setSqlStatement(createTableStatement);
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateProcedureSupportedCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateProcedureSupportedCheckerTest.java
index 78ccf1cb8e3..d3d5300e1be 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateProcedureSupportedCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateProcedureSupportedCheckerTest.java
@@ -33,7 +33,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateT
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
import
org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateProcedureStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -110,7 +109,7 @@ class ShardingCreateProcedureSupportedCheckerTest {
@Test
void assertCheckWithTableExists() {
- CreateTableStatement createTableStatement = new
SQL92CreateTableStatement();
+ CreateTableStatement createTableStatement = new CreateTableStatement();
createTableStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("foo_tbl"))));
ValidStatementSegment validStatementSegment = new
ValidStatementSegment(0, 0);
validStatementSegment.setSqlStatement(createTableStatement);
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateTableSupportedCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateTableSupportedCheckerTest.java
index 30610dcccd5..853db06de12 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateTableSupportedCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingCreateTableSupportedCheckerTest.java
@@ -26,7 +26,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
@@ -45,7 +44,7 @@ class ShardingCreateTableSupportedCheckerTest {
@Test
void assertCheck() {
- SQL92CreateTableStatement sqlStatement = new
SQL92CreateTableStatement();
+ CreateTableStatement sqlStatement = new CreateTableStatement();
sqlStatement.setTable(new SimpleTableSegment(new TableNameSegment(1,
2, new IdentifierValue("foo_tbl"))));
assertThrows(TableExistsException.class, () ->
assertCheck(sqlStatement));
}
@@ -60,7 +59,7 @@ class ShardingCreateTableSupportedCheckerTest {
@Test
void assertCheckIfNotExists() {
- CreateTableStatement sqlStatement = new SQL92CreateTableStatement();
+ CreateTableStatement sqlStatement = new CreateTableStatement();
sqlStatement.setIfNotExists(true);
sqlStatement.setTable(new SimpleTableSegment(new TableNameSegment(1,
2, new IdentifierValue("foo_tbl"))));
assertCheckIfNotExists(sqlStatement);
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingDropTableSupportedCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingDropTableSupportedCheckerTest.java
index 924a574cd23..58d5a4dfa57 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingDropTableSupportedCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/ddl/ShardingDropTableSupportedCheckerTest.java
@@ -27,7 +27,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92DropTableStatement;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -63,7 +62,7 @@ class ShardingDropTableSupportedCheckerTest {
@Test
void assertCheck() {
- DropTableStatement sqlStatement = new SQL92DropTableStatement();
+ DropTableStatement sqlStatement = new DropTableStatement();
sqlStatement.getTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order_item"))));
DropTableStatementContext sqlStatementContext = new
DropTableStatementContext(mock(), sqlStatement);
ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingDeleteSupportedCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingDeleteSupportedCheckerTest.java
index fe7024a5526..fb50bc05818 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingDeleteSupportedCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingDeleteSupportedCheckerTest.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92DeleteStatement;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -43,7 +42,7 @@ class ShardingDeleteSupportedCheckerTest {
tableSegment.getActualDeleteTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("user"))));
tableSegment.getActualDeleteTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("order"))));
tableSegment.getActualDeleteTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("order_item"))));
- DeleteStatement sqlStatement = new SQL92DeleteStatement();
+ DeleteStatement sqlStatement = new DeleteStatement();
sqlStatement.setTable(tableSegment);
ShardingRule rule = mock(ShardingRule.class);
when(rule.containsShardingTable(new HashSet<>(Arrays.asList("user",
"order", "order_item")))).thenReturn(true);
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingUpdateSupportedCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingUpdateSupportedCheckerTest.java
index e65de28705c..fa958b610ed 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingUpdateSupportedCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/checker/sql/dml/ShardingUpdateSupportedCheckerTest.java
@@ -29,7 +29,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
@@ -76,7 +75,7 @@ class ShardingUpdateSupportedCheckerTest {
}
private UpdateStatement createUpdateStatement() {
- UpdateStatement result = new SQL92UpdateStatement();
+ UpdateStatement result = new UpdateStatement();
result.setTable(new SimpleTableSegment(new TableNameSegment(0, 0, new
IdentifierValue("user"))));
List<ColumnSegment> columns = new LinkedList<>();
columns.add(new ColumnSegment(0, 0, new IdentifierValue("id")));
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/merge/ShardingResultMergerEngineTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/merge/ShardingResultMergerEngineTest.java
index 30edc0ddb3d..ec44f0972bd 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/merge/ShardingResultMergerEngineTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/merge/ShardingResultMergerEngineTest.java
@@ -39,7 +39,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.FetchSt
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
@@ -77,7 +76,7 @@ class ShardingResultMergerEngineTest {
@Test
void assertNewInstanceWithOtherStatement() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
InsertColumnsSegment insertColumnsSegment = new
InsertColumnsSegment(0, 0, Collections.singletonList(new ColumnSegment(0, 0,
new IdentifierValue("col"))));
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("tbl"))));
insertStatement.setInsertColumns(insertColumnsSegment);
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/ddl/ShardingDropTableRouteContextCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/ddl/ShardingDropTableRouteContextCheckerTest.java
index c225b5643a4..73ff8eb7bf8 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/ddl/ShardingDropTableRouteContextCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/ddl/ShardingDropTableRouteContextCheckerTest.java
@@ -34,7 +34,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
import
org.apache.shardingsphere.sql.parser.statement.postgresql.ddl.PostgreSQLDropTableStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92DropTableStatement;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -81,7 +80,7 @@ class ShardingDropTableRouteContextCheckerTest {
@Test
void assertCheckWhenDropTableInUsed() {
- DropTableStatement sqlStatement = new SQL92DropTableStatement();
+ DropTableStatement sqlStatement = new DropTableStatement();
sqlStatement.getTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order_item"))));
ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
when(database.getName()).thenReturn("db_schema");
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/dml/ShardingUpdateRouteContextCheckerTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/dml/ShardingUpdateRouteContextCheckerTest.java
index 7df040e1c9b..6a5ae649d02 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/dml/ShardingUpdateRouteContextCheckerTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/checker/dml/ShardingUpdateRouteContextCheckerTest.java
@@ -38,7 +38,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.apache.shardingsphere.test.util.PropertiesBuilder;
import org.apache.shardingsphere.test.util.PropertiesBuilder.Property;
import org.junit.jupiter.api.Test;
@@ -123,7 +122,7 @@ class ShardingUpdateRouteContextCheckerTest {
}
private UpdateStatement createUpdateStatement() {
- UpdateStatement result = new SQL92UpdateStatement();
+ UpdateStatement result = new UpdateStatement();
result.setTable(new SimpleTableSegment(new TableNameSegment(0, 0, new
IdentifierValue("user"))));
List<ColumnSegment> columns = new LinkedList<>();
columns.add(new ColumnSegment(0, 0, new IdentifierValue("id")));
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/ShardingRouteEngineFactoryTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/ShardingRouteEngineFactoryTest.java
index 48a93c61f11..ae27cce26ba 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/ShardingRouteEngineFactoryTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/route/engine/type/ShardingRouteEngineFactoryTest.java
@@ -50,7 +50,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CursorS
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DDLStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dcl.SQL92GrantStatement;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -131,7 +130,7 @@ class ShardingRouteEngineFactoryTest {
@Test
void assertNewInstanceForDCLForSingleTable() {
- GrantStatement grantStatement = new SQL92GrantStatement();
+ GrantStatement grantStatement = new GrantStatement();
grantStatement.getTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("tbl"))));
GrantStatementContext sqlStatementContext = new
GrantStatementContext(mock(), grantStatement);
QueryContext queryContext = new QueryContext(sqlStatementContext, "",
Collections.emptyList(), new HintValueContext(), mockConnectionContext(),
mock(ShardingSphereMetaData.class));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/segment/insert/keygen/engine/GeneratedKeyContextEngineTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/segment/insert/keygen/engine/GeneratedKeyContextEngineTest.java
index befb6e3ab08..032cb006bbb 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/segment/insert/keygen/engine/GeneratedKeyContextEngineTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/segment/insert/keygen/engine/GeneratedKeyContextEngineTest.java
@@ -34,7 +34,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -66,7 +65,7 @@ class GeneratedKeyContextEngineTest {
@Test
void assertCreateGenerateKeyContextWithoutGenerateKeyColumnConfiguration()
{
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("tbl1"))));
insertStatement.setInsertColumns(new InsertColumnsSegment(0, 0,
Collections.singletonList(new ColumnSegment(0, 0, new IdentifierValue("id")))));
assertFalse(new GeneratedKeyContextEngine(insertStatement,
schema).createGenerateKeyContext(Collections.emptyMap(),
@@ -75,7 +74,7 @@ class GeneratedKeyContextEngineTest {
@Test
void
assertCreateGenerateKeyContextWhenCreateWithGenerateKeyColumnConfiguration() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("foo_tbl"))));
insertStatement.setInsertColumns(new InsertColumnsSegment(0, 0,
Collections.singletonList(new ColumnSegment(0, 0, new IdentifierValue("id")))));
List<ExpressionSegment> expressionSegments =
Collections.singletonList(new LiteralExpressionSegment(0, 0, 1));
@@ -89,7 +88,7 @@ class GeneratedKeyContextEngineTest {
@Test
void assertCreateGenerateKeyContextWhenFind() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("foo_tbl"))));
insertStatement.setInsertColumns(new InsertColumnsSegment(0, 0,
Collections.singletonList(new ColumnSegment(0, 0, new IdentifierValue("id")))));
insertStatement.getValues().add(new InsertValuesSegment(0, 0,
Collections.singletonList(new ParameterMarkerExpressionSegment(1, 2, 0))));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/SQLStatementContextFactoryTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/SQLStatementContextFactoryTest.java
index 8200c901ab4..ef2c411bdd6 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/SQLStatementContextFactoryTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/SQLStatementContextFactoryTest.java
@@ -44,7 +44,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.MoveSta
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
@@ -72,7 +71,7 @@ class SQLStatementContextFactoryTest {
@Test
void assertSQLStatementContextCreatedWhenSQLStatementInstance() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("tbl"))));
SQLStatementContext sqlStatementContext = new
SQLBindEngine(mockMetaData(), "foo_db", new
HintValueContext()).bind(databaseType, insertStatement,
Collections.emptyList());
assertThat(sqlStatementContext,
instanceOf(InsertStatementContext.class));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/GrantStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/GrantStatementContextTest.java
index 2fcdd416811..4c5f3ff2792 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/GrantStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/GrantStatementContextTest.java
@@ -22,7 +22,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dcl.GrantStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dcl.SQL92GrantStatement;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -36,7 +35,7 @@ class GrantStatementContextTest {
@Test
void assertNewInstance() {
- GrantStatement sqlStatement = new SQL92GrantStatement();
+ GrantStatement sqlStatement = new GrantStatement();
sqlStatement.getTables().addAll(Arrays.asList(new
SimpleTableSegment(createTableNameSegment("foo_tbl")), new
SimpleTableSegment(createTableNameSegment("bar_tbl"))));
GrantStatementContext actual = new GrantStatementContext(mock(),
sqlStatement);
assertThat(actual.getSqlStatement(), is(sqlStatement));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/RevokeStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/RevokeStatementContextTest.java
index 2222d8cca84..8db99c4812f 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/RevokeStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dcl/RevokeStatementContextTest.java
@@ -22,7 +22,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dcl.RevokeStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dcl.SQL92RevokeStatement;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -36,7 +35,7 @@ class RevokeStatementContextTest {
@Test
void assertNewInstance() {
- RevokeStatement revokeStatement = new SQL92RevokeStatement();
+ RevokeStatement revokeStatement = new RevokeStatement();
revokeStatement.getTables().addAll(Arrays.asList(new
SimpleTableSegment(createTableNameSegment("foo_tbl")), new
SimpleTableSegment(createTableNameSegment("bar_tbl"))));
RevokeStatementContext actual = new RevokeStatementContext(mock(),
revokeStatement);
assertThat(actual.getSqlStatement(), is(revokeStatement));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/AlterTableStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/AlterTableStatementContextTest.java
index 350aa92e66b..f5b68855da6 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/AlterTableStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/AlterTableStatementContextTest.java
@@ -33,7 +33,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92AlterTableStatement;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -51,7 +50,7 @@ class AlterTableStatementContextTest {
@Test
void assertNewInstance() {
- AlterTableStatement alterTableStatement = new
SQL92AlterTableStatement();
+ AlterTableStatement alterTableStatement = new AlterTableStatement();
SimpleTableSegment table = new
SimpleTableSegment(createTableNameSegment("foo_tbl"));
alterTableStatement.setTable(table);
alterTableStatement.setRenameTable(new
SimpleTableSegment(createTableNameSegment("rename_foo_tbl")));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/CreateTableStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/CreateTableStatementContextTest.java
index fd0e101a9b8..c8e3b515146 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/CreateTableStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/CreateTableStatementContextTest.java
@@ -27,7 +27,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
import org.junit.jupiter.api.Test;
import java.util.Collections;
@@ -44,7 +43,7 @@ class CreateTableStatementContextTest {
@Test
void assertNewInstance() {
- CreateTableStatement sqlStatement = new SQL92CreateTableStatement();
+ CreateTableStatement sqlStatement = new CreateTableStatement();
CreateTableStatementContext actual = new
CreateTableStatementContext(mock(), sqlStatement);
SimpleTableSegment table = new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("foo_tbl")));
sqlStatement.setTable(table);
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/DropTableStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/DropTableStatementContextTest.java
index fac0c01b5bd..f5477be1564 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/DropTableStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/DropTableStatementContextTest.java
@@ -21,7 +21,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92DropTableStatement;
import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.is;
@@ -32,7 +31,7 @@ class DropTableStatementContextTest {
@Test
void assertNewInstance() {
- DropTableStatement dropTableStatement = new SQL92DropTableStatement();
+ DropTableStatement dropTableStatement = new DropTableStatement();
DropTableStatementContext actual = new
DropTableStatementContext(mock(), dropTableStatement);
dropTableStatement.getTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("foo_tbl"))));
dropTableStatement.getTables().add(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("bar_tbl"))));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/PrepareStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/PrepareStatementContextTest.java
index 14dfb2ba590..9548d64d73c 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/PrepareStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/ddl/PrepareStatementContextTest.java
@@ -29,10 +29,7 @@ import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertS
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92DeleteStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -74,13 +71,13 @@ class PrepareStatementContextTest {
}
private InsertStatement getInsert(final SimpleTableSegment table) {
- InsertStatement result = new SQL92InsertStatement();
+ InsertStatement result = new InsertStatement();
result.setTable(table);
return result;
}
private UpdateStatement getUpdate(final SimpleTableSegment table) {
- UpdateStatement result = new SQL92UpdateStatement();
+ UpdateStatement result = new UpdateStatement();
result.setTable(table);
ColumnSegment column = new ColumnSegment(0, 0, new
IdentifierValue("foo_col"));
SetAssignmentSegment setAssignmentSegment = new
SetAssignmentSegment(0, 0, Collections.singletonList(new
ColumnAssignmentSegment(0, 0, Collections.singletonList(column), column)));
@@ -89,7 +86,7 @@ class PrepareStatementContextTest {
}
private DeleteStatement getDelete(final SimpleTableSegment table) {
- DeleteStatement result = new SQL92DeleteStatement();
+ DeleteStatement result = new DeleteStatement();
result.setTable(table);
return result;
}
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContextTest.java
index c19af36d830..d9e63276160 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContextTest.java
@@ -25,7 +25,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92DeleteStatement;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -42,7 +41,7 @@ class DeleteStatementContextTest {
@Test
void assertNewInstance() {
- DeleteStatement deleteStatement = new SQL92DeleteStatement();
+ DeleteStatement deleteStatement = new DeleteStatement();
WhereSegment whereSegment = mock(WhereSegment.class);
when(whereSegment.getExpr()).thenReturn(mock(ExpressionSegment.class));
deleteStatement.setWhere(whereSegment);
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/InsertStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/InsertStatementContextTest.java
index 56259916347..739239fff2f 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/InsertStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/InsertStatementContextTest.java
@@ -40,7 +40,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
@@ -132,7 +131,7 @@ class InsertStatementContextTest {
@Test
void assertInsertSelect() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
SelectStatement selectStatement = new SQL92SelectStatement();
selectStatement.addParameterMarkerSegments(Collections.singleton(new
ParameterMarkerExpressionSegment(0, 0, 0, ParameterMarkerType.QUESTION)));
selectStatement.setProjections(new ProjectionsSegment(0, 0));
@@ -198,7 +197,7 @@ class InsertStatementContextTest {
@Test
void assertContainsInsertColumns() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
InsertColumnsSegment insertColumnsSegment = new
InsertColumnsSegment(0, 0, Collections.singletonList(new ColumnSegment(0, 0,
new IdentifierValue("col"))));
insertStatement.setInsertColumns(insertColumnsSegment);
TableNameSegment tableNameSegment = new TableNameSegment(0, 0, new
IdentifierValue(""));
@@ -210,7 +209,7 @@ class InsertStatementContextTest {
@Test
void assertNotContainsInsertColumns() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
TableNameSegment tableNameSegment = new TableNameSegment(0, 0, new
IdentifierValue(""));
tableNameSegment.setTableBoundInfo(new TableSegmentBoundInfo(new
IdentifierValue("foo_db"), new IdentifierValue("foo_schema")));
insertStatement.setTable(new SimpleTableSegment(tableNameSegment));
@@ -231,7 +230,7 @@ class InsertStatementContextTest {
@Test
void assertGetValueListCountWithValues() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.getValues().add(new InsertValuesSegment(0, 0,
Collections.singletonList(new LiteralExpressionSegment(0, 0, 1))));
insertStatement.getValues().add(new InsertValuesSegment(0, 0,
Collections.singletonList(new LiteralExpressionSegment(0, 0, 2))));
TableNameSegment tableNameSegment = new TableNameSegment(0, 0, new
IdentifierValue(""));
@@ -257,7 +256,7 @@ class InsertStatementContextTest {
@Test
void assertGetInsertColumnNamesForInsertColumns() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
InsertColumnsSegment insertColumnsSegment = new
InsertColumnsSegment(0, 0, Collections.singletonList(new ColumnSegment(0, 0,
new IdentifierValue("col"))));
insertStatement.setInsertColumns(insertColumnsSegment);
TableNameSegment tableNameSegment = new TableNameSegment(0, 0, new
IdentifierValue(""));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/UpdateStatementContextTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/UpdateStatementContextTest.java
index 466a36b7798..2e514e7a49a 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/UpdateStatementContextTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/context/statement/dml/UpdateStatementContextTest.java
@@ -28,7 +28,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
@@ -70,7 +69,7 @@ class UpdateStatementContextTest {
JoinTableSegment joinTableSegment = new JoinTableSegment();
joinTableSegment.setLeft(table1);
joinTableSegment.setRight(table2);
- UpdateStatement updateStatement = new SQL92UpdateStatement();
+ UpdateStatement updateStatement = new UpdateStatement();
updateStatement.setWhere(whereSegment);
updateStatement.setTable(joinTableSegment);
updateStatement.setSetAssignment(new SetAssignmentSegment(0, 0,
Collections.emptyList()));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/DeleteStatementBinderTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/DeleteStatementBinderTest.java
index 4c0860a7394..2f5ca19e92b 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/DeleteStatementBinderTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/DeleteStatementBinderTest.java
@@ -32,7 +32,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92DeleteStatement;
import org.junit.jupiter.api.Test;
import java.sql.Types;
@@ -53,7 +52,7 @@ class DeleteStatementBinderTest {
@Test
void assertBind() {
- DeleteStatement deleteStatement = new SQL92DeleteStatement();
+ DeleteStatement deleteStatement = new DeleteStatement();
SimpleTableSegment simpleTableSegment = new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order")));
deleteStatement.setTable(simpleTableSegment);
deleteStatement.setWhere(new WhereSegment(0, 0, new
BinaryOperationExpression(0, 0, new ColumnSegment(0, 0, new
IdentifierValue("status")),
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/InsertStatementBinderTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/InsertStatementBinderTest.java
index 84cf5863ef0..e0c131a5015 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/InsertStatementBinderTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/InsertStatementBinderTest.java
@@ -37,7 +37,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
@@ -61,7 +60,7 @@ class InsertStatementBinderTest {
@Test
void assertBindInsertValues() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order"))));
insertStatement.setInsertColumns(new InsertColumnsSegment(0, 0,
Arrays.asList(new ColumnSegment(0, 0, new IdentifierValue("order_id")),
new ColumnSegment(0, 0, new IdentifierValue("user_id")), new
ColumnSegment(0, 0, new IdentifierValue("status")))));
@@ -98,7 +97,7 @@ class InsertStatementBinderTest {
@Test
void assertBindInsertSelectWithColumns() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order"))));
insertStatement.setInsertColumns(new InsertColumnsSegment(0, 0,
Arrays.asList(new ColumnSegment(0, 0, new IdentifierValue("order_id")),
new ColumnSegment(0, 0, new IdentifierValue("user_id")), new
ColumnSegment(0, 0, new IdentifierValue("status")))));
@@ -124,7 +123,7 @@ class InsertStatementBinderTest {
@Test
void assertBindInsertSelectWithoutColumns() {
- InsertStatement insertStatement = new SQL92InsertStatement();
+ InsertStatement insertStatement = new InsertStatement();
insertStatement.setTable(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order"))));
SelectStatement subSelectStatement = new SQL92SelectStatement();
subSelectStatement.setFrom(new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order"))));
diff --git
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/UpdateStatementBinderTest.java
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/UpdateStatementBinderTest.java
index f1d03f0fe6f..a5361ae0dd2 100644
---
a/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/UpdateStatementBinderTest.java
+++
b/infra/binder/core/src/test/java/org/apache/shardingsphere/infra/binder/engine/statement/dml/UpdateStatementBinderTest.java
@@ -32,7 +32,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.junit.jupiter.api.Test;
import java.sql.Types;
@@ -53,7 +52,7 @@ class UpdateStatementBinderTest {
@Test
void assertBind() {
- UpdateStatement updateStatement = new SQL92UpdateStatement();
+ UpdateStatement updateStatement = new UpdateStatement();
SimpleTableSegment simpleTableSegment = new SimpleTableSegment(new
TableNameSegment(0, 0, new IdentifierValue("t_order")));
updateStatement.setTable(simpleTableSegment);
updateStatement.setWhere(new WhereSegment(0, 0, new
BinaryOperationExpression(0, 0, new ColumnSegment(0, 0, new
IdentifierValue("status")),
diff --git
a/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/ProcessEngineTest.java
b/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/ProcessEngineTest.java
index 23e88627e15..504b7a250a3 100644
---
a/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/ProcessEngineTest.java
+++
b/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/ProcessEngineTest.java
@@ -31,7 +31,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import org.apache.shardingsphere.test.mock.AutoMockExtension;
import org.apache.shardingsphere.test.mock.StaticMockSettings;
import org.junit.jupiter.api.BeforeEach;
@@ -79,7 +78,7 @@ class ProcessEngineTest {
}
private UpdateStatement getSQLStatement() {
- UpdateStatement result = new SQL92UpdateStatement();
+ UpdateStatement result = new UpdateStatement();
TableNameSegment tableNameSegment = new TableNameSegment(0, 0, new
IdentifierValue("foo_tbl"));
tableNameSegment.setTableBoundInfo(new TableSegmentBoundInfo(new
IdentifierValue("foo_db"), new IdentifierValue("foo_schema")));
result.setTable(new SimpleTableSegment(tableNameSegment));
diff --git
a/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
b/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
index e1c6caec46f..55aec56fa6b 100644
---
a/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
+++
b/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
@@ -47,7 +47,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableNameSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
import org.apache.shardingsphere.test.fixture.jdbc.MockedDataSource;
import org.junit.jupiter.api.Test;
@@ -216,7 +215,7 @@ class SingleSQLRouterTest {
}
private QueryContext createQueryContext() {
- CreateTableStatement createTableStatement = new
SQL92CreateTableStatement();
+ CreateTableStatement createTableStatement = new CreateTableStatement();
TableNameSegment tableNameSegment = new TableNameSegment(1, 2, new
IdentifierValue("t_order"));
tableNameSegment.setTableBoundInfo(new TableSegmentBoundInfo(new
IdentifierValue("foo_db"), new IdentifierValue("foo_schema")));
createTableStatement.setTable(new
SimpleTableSegment(tableNameSegment));
diff --git
a/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/engine/engine/SingleRouteEngineTest.java
b/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/engine/engine/SingleRouteEngineTest.java
index 1f6fda165e9..4b0e81118c8 100644
---
a/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/engine/engine/SingleRouteEngineTest.java
+++
b/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/engine/engine/SingleRouteEngineTest.java
@@ -35,7 +35,6 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.statement.SQLStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
import org.apache.shardingsphere.test.fixture.jdbc.MockedDataSource;
import org.junit.jupiter.api.Test;
@@ -95,7 +94,7 @@ class SingleRouteEngineTest {
@Test
void assertRouteWithoutSingleRule() throws SQLException {
- CreateTableStatement sqlStatement = new SQL92CreateTableStatement();
+ CreateTableStatement sqlStatement = new CreateTableStatement();
SingleRouteEngine engine = new
SingleRouteEngine(mockQualifiedTables(), sqlStatement, mock());
SingleRule singleRule = new SingleRule(new SingleRuleConfiguration(),
"foo_db", mock(), createDataSourceMap(), Collections.emptyList());
RouteContext routeContext = new RouteContext();
@@ -111,7 +110,7 @@ class SingleRouteEngineTest {
@Test
void assertRouteWithDefaultSingleRule() throws SQLException {
- CreateTableStatement sqlStatement = new SQL92CreateTableStatement();
+ CreateTableStatement sqlStatement = new CreateTableStatement();
SingleRouteEngine engine = new
SingleRouteEngine(mockQualifiedTables(), sqlStatement, mock());
SingleRule singleRule = new SingleRule(new
SingleRuleConfiguration(Collections.emptyList(), "ds_0"), "foo_db", mock(),
createDataSourceMap(), Collections.emptyList());
RouteContext routeContext = new RouteContext();
diff --git
a/kernel/transaction/core/src/test/java/org/apache/shardingsphere/transaction/util/AutoCommitUtilsTest.java
b/kernel/transaction/core/src/test/java/org/apache/shardingsphere/transaction/util/AutoCommitUtilsTest.java
index 87b0b51e5f4..9cb1c736718 100644
---
a/kernel/transaction/core/src/test/java/org/apache/shardingsphere/transaction/util/AutoCommitUtilsTest.java
+++
b/kernel/transaction/core/src/test/java/org/apache/shardingsphere/transaction/util/AutoCommitUtilsTest.java
@@ -20,9 +20,8 @@ package org.apache.shardingsphere.transaction.util;
import
org.apache.shardingsphere.distsql.statement.rdl.resource.unit.type.RegisterStorageUnitStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
import org.junit.jupiter.api.Test;
@@ -42,10 +41,10 @@ class AutoCommitUtilsTest {
@Test
void assertNeedOpenTransactionForDDLOrDMLStatement() {
- CreateTableStatement sqlStatement = new SQL92CreateTableStatement();
+ CreateTableStatement sqlStatement = new CreateTableStatement();
sqlStatement.setIfNotExists(true);
assertTrue(AutoCommitUtils.needOpenTransaction(sqlStatement));
- assertTrue(AutoCommitUtils.needOpenTransaction(new
SQL92InsertStatement()));
+ assertTrue(AutoCommitUtils.needOpenTransaction(new InsertStatement()));
}
@Test
diff --git
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DCLStatementVisitor.java
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DCLStatementVisitor.java
index 77bef13abab..3b8c25fc6b2 100644
---
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DCLStatementVisitor.java
+++
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DCLStatementVisitor.java
@@ -21,10 +21,10 @@ import org.apache.shardingsphere.sql.parser.api.ASTNode;
import
org.apache.shardingsphere.sql.parser.api.visitor.statement.type.DCLStatementVisitor;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.GrantContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.RevokeContext;
-import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dcl.SQL92GrantStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dcl.SQL92RevokeStatement;
import
org.apache.shardingsphere.sql.parser.sql92.visitor.statement.SQL92StatementVisitor;
+import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dcl.GrantStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dcl.RevokeStatement;
/**
* DCL statement visitor for SQL92.
@@ -33,7 +33,7 @@ public final class SQL92DCLStatementVisitor extends
SQL92StatementVisitor implem
@Override
public ASTNode visitGrant(final GrantContext ctx) {
- SQL92GrantStatement result = new SQL92GrantStatement();
+ GrantStatement result = new GrantStatement();
if (null != ctx.privilegeClause()) {
result.getTables().add((SimpleTableSegment)
visit(ctx.privilegeClause().onObjectClause().privilegeLevel().tableName()));
}
@@ -42,7 +42,7 @@ public final class SQL92DCLStatementVisitor extends
SQL92StatementVisitor implem
@Override
public ASTNode visitRevoke(final RevokeContext ctx) {
- SQL92RevokeStatement result = new SQL92RevokeStatement();
+ RevokeStatement result = new RevokeStatement();
if (null != ctx.privilegeClause()) {
result.getTables().add((SimpleTableSegment)
visit(ctx.privilegeClause().onObjectClause().privilegeLevel().tableName()));
}
diff --git
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DDLStatementVisitor.java
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DDLStatementVisitor.java
index d3a9f2eff21..c2cf41bc72d 100644
---
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DDLStatementVisitor.java
+++
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DDLStatementVisitor.java
@@ -37,6 +37,7 @@ import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.DropCol
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.DropConstraintSpecificationContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.DropTableContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.ModifyColumnSpecificationContext;
+import
org.apache.shardingsphere.sql.parser.sql92.visitor.statement.SQL92StatementVisitor;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.AlterDefinitionSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.CreateDefinitionSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.column.ColumnDefinitionSegment;
@@ -50,12 +51,11 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.constrain
import
org.apache.shardingsphere.sql.parser.statement.core.segment.dml.column.ColumnSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.DataTypeSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterTableStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.collection.CollectionValue;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92AlterTableStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92CreateTableStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.ddl.SQL92DropTableStatement;
-import
org.apache.shardingsphere.sql.parser.sql92.visitor.statement.SQL92StatementVisitor;
import java.util.Collections;
@@ -67,7 +67,7 @@ public final class SQL92DDLStatementVisitor extends
SQL92StatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitCreateTable(final CreateTableContext ctx) {
- SQL92CreateTableStatement result = new SQL92CreateTableStatement();
+ CreateTableStatement result = new CreateTableStatement();
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
if (null != ctx.createDefinitionClause()) {
CollectionValue<CreateDefinitionSegment> createDefinitions =
(CollectionValue<CreateDefinitionSegment>) visit(ctx.createDefinitionClause());
@@ -157,7 +157,7 @@ public final class SQL92DDLStatementVisitor extends
SQL92StatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitAlterTable(final AlterTableContext ctx) {
- SQL92AlterTableStatement result = new SQL92AlterTableStatement();
+ AlterTableStatement result = new AlterTableStatement();
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
if (null != ctx.alterDefinitionClause()) {
for (AlterDefinitionSegment each :
((CollectionValue<AlterDefinitionSegment>)
visit(ctx.alterDefinitionClause())).getValue()) {
@@ -217,7 +217,7 @@ public final class SQL92DDLStatementVisitor extends
SQL92StatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitDropTable(final DropTableContext ctx) {
- SQL92DropTableStatement result = new SQL92DropTableStatement();
+ DropTableStatement result = new DropTableStatement();
result.getTables().addAll(((CollectionValue<SimpleTableSegment>)
visit(ctx.tableNames())).getValue());
return result;
}
diff --git
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DMLStatementVisitor.java
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DMLStatementVisitor.java
index c31ac519f30..16645619d72 100644
---
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DMLStatementVisitor.java
+++
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92DMLStatementVisitor.java
@@ -84,13 +84,13 @@ import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SubqueryTableSegment;
import
org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.TableSegment;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.value.collection.CollectionValue;
import
org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
import
org.apache.shardingsphere.sql.parser.statement.core.value.literal.impl.BooleanLiteralValue;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92DeleteStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92InsertStatement;
import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92SelectStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.dml.SQL92UpdateStatement;
import java.util.Collection;
import java.util.Collections;
@@ -105,7 +105,7 @@ public final class SQL92DMLStatementVisitor extends
SQL92StatementVisitor implem
@Override
public ASTNode visitInsert(final InsertContext ctx) {
- SQL92InsertStatement result = (SQL92InsertStatement)
visit(ctx.insertValuesClause());
+ InsertStatement result = (InsertStatement)
visit(ctx.insertValuesClause());
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
result.addParameterMarkerSegments(getParameterMarkerSegments());
return result;
@@ -114,7 +114,7 @@ public final class SQL92DMLStatementVisitor extends
SQL92StatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitInsertValuesClause(final InsertValuesClauseContext
ctx) {
- SQL92InsertStatement result = new SQL92InsertStatement();
+ InsertStatement result = new InsertStatement();
if (null != ctx.columnNames()) {
ColumnNamesContext columnNames = ctx.columnNames();
CollectionValue<ColumnSegment> columnSegments =
(CollectionValue<ColumnSegment>) visit(columnNames);
@@ -136,7 +136,7 @@ public final class SQL92DMLStatementVisitor extends
SQL92StatementVisitor implem
@Override
public ASTNode visitUpdate(final UpdateContext ctx) {
- SQL92UpdateStatement result = new SQL92UpdateStatement();
+ UpdateStatement result = new UpdateStatement();
result.setTable((TableSegment) visit(ctx.tableReferences()));
result.setSetAssignment((SetAssignmentSegment)
visit(ctx.setAssignmentsClause()));
if (null != ctx.whereClause()) {
@@ -186,7 +186,7 @@ public final class SQL92DMLStatementVisitor extends
SQL92StatementVisitor implem
@Override
public ASTNode visitDelete(final DeleteContext ctx) {
- SQL92DeleteStatement result = new SQL92DeleteStatement();
+ DeleteStatement result = new DeleteStatement();
result.setTable((TableSegment) visit(ctx.singleTableClause()));
if (null != ctx.whereClause()) {
result.setWhere((WhereSegment) visit(ctx.whereClause()));
diff --git
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92TCLStatementVisitor.java
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92TCLStatementVisitor.java
index 4f7aaf427ee..568f97ed064 100644
---
a/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92TCLStatementVisitor.java
+++
b/parser/sql/dialect/sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/type/SQL92TCLStatementVisitor.java
@@ -23,9 +23,9 @@ import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.CommitC
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.RollbackContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.SetTransactionContext;
import
org.apache.shardingsphere.sql.parser.sql92.visitor.statement.SQL92StatementVisitor;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.tcl.CommitStatement;
import
org.apache.shardingsphere.sql.parser.statement.core.statement.tcl.RollbackStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.tcl.SQL92CommitStatement;
-import
org.apache.shardingsphere.sql.parser.statement.sql92.tcl.SQL92SetTransactionStatement;
+import
org.apache.shardingsphere.sql.parser.statement.core.statement.tcl.SetTransactionStatement;
/**
* TCL statement visitor for SQL92.
@@ -34,12 +34,12 @@ public final class SQL92TCLStatementVisitor extends
SQL92StatementVisitor implem
@Override
public ASTNode visitSetTransaction(final SetTransactionContext ctx) {
- return new SQL92SetTransactionStatement();
+ return new SetTransactionStatement();
}
@Override
public ASTNode visitCommit(final CommitContext ctx) {
- return new SQL92CommitStatement();
+ return new CommitStatement();
}
@Override
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dcl/SQL92GrantStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dcl/SQL92GrantStatement.java
deleted file mode 100644
index dedefb00672..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dcl/SQL92GrantStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.dcl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.dcl.GrantStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 grant statement.
- */
-public final class SQL92GrantStatement extends GrantStatement implements
SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dcl/SQL92RevokeStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dcl/SQL92RevokeStatement.java
deleted file mode 100644
index 73c967a6c26..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dcl/SQL92RevokeStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.dcl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.dcl.RevokeStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 revoke statement.
- */
-public final class SQL92RevokeStatement extends RevokeStatement implements
SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92AlterTableStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92AlterTableStatement.java
deleted file mode 100644
index 196c08be1cc..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92AlterTableStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.ddl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 alter table statement.
- */
-public final class SQL92AlterTableStatement extends AlterTableStatement
implements SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92CreateTableStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92CreateTableStatement.java
deleted file mode 100644
index f56ce08ce62..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92CreateTableStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.ddl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 create table statement.
- */
-public final class SQL92CreateTableStatement extends CreateTableStatement
implements SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92DropTableStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92DropTableStatement.java
deleted file mode 100644
index 52209f0bd1f..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/ddl/SQL92DropTableStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.ddl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 drop table statement.
- */
-public final class SQL92DropTableStatement extends DropTableStatement
implements SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92DeleteStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92DeleteStatement.java
deleted file mode 100644
index c06b7a21460..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92DeleteStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.dml;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 delete statement.
- */
-public final class SQL92DeleteStatement extends DeleteStatement implements
SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92InsertStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92InsertStatement.java
deleted file mode 100644
index f7c3c85e0ef..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92InsertStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.dml;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 insert statement.
- */
-public final class SQL92InsertStatement extends InsertStatement implements
SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92UpdateStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92UpdateStatement.java
deleted file mode 100644
index d9f9dc6737a..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/dml/SQL92UpdateStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.dml;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 update statement.
- */
-public final class SQL92UpdateStatement extends UpdateStatement implements
SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/tcl/SQL92CommitStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/tcl/SQL92CommitStatement.java
deleted file mode 100644
index 1a4699554f7..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/tcl/SQL92CommitStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.tcl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.tcl.CommitStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 commit statement.
- */
-public final class SQL92CommitStatement extends CommitStatement implements
SQL92Statement {
-}
diff --git
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/tcl/SQL92SetTransactionStatement.java
b/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/tcl/SQL92SetTransactionStatement.java
deleted file mode 100644
index 4e877f8f429..00000000000
---
a/parser/sql/statement/type/sql92/src/main/java/org/apache/shardingsphere/sql/parser/statement/sql92/tcl/SQL92SetTransactionStatement.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.sql.parser.statement.sql92.tcl;
-
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.tcl.SetTransactionStatement;
-import org.apache.shardingsphere.sql.parser.statement.sql92.SQL92Statement;
-
-/**
- * SQL92 set transaction statement.
- */
-public final class SQL92SetTransactionStatement extends
SetTransactionStatement implements SQL92Statement {
-}
