You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2025/06/05 04:45:55 UTC
(shardingsphere) branch master updated: Remove useless parser-sql-statement-doris (#35589)
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 1e11bac1364 Remove useless parser-sql-statement-doris (#35589)
1e11bac1364 is described below
commit 1e11bac1364c15565b0401cb7d11e1973b99f13a
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Thu Jun 5 12:45:48 2025 +0800
Remove useless parser-sql-statement-doris (#35589)
---
parser/sql/dialect/doris/pom.xml | 5 --
.../visitor/statement/DorisStatementVisitor.java | 72 +++++++++----------
.../statement/type/DorisDALStatementVisitor.java | 4 +-
.../statement/type/DorisDDLStatementVisitor.java | 80 +++++++++++-----------
parser/sql/statement/type/doris/pom.xml | 36 ----------
.../sql/parser/statement/doris/DorisStatement.java | 26 -------
.../statement/doris/dal/DorisExplainStatement.java | 47 -------------
.../doris/ddl/DorisAlterTableStatement.java | 55 ---------------
.../doris/ddl/DorisAlterViewStatement.java | 46 -------------
.../doris/ddl/DorisCreateFunctionStatement.java | 39 -----------
.../doris/ddl/DorisCreateIndexStatement.java | 47 -------------
.../doris/ddl/DorisCreateProcedureStatement.java | 39 -----------
.../doris/ddl/DorisCreateTableStatement.java | 53 --------------
.../doris/ddl/DorisDropIndexStatement.java | 55 ---------------
.../doris/ddl/DorisDropTableStatement.java | 35 ----------
.../doris/ddl/DorisDropViewStatement.java | 33 ---------
.../statement/doris/dml/DorisDeleteStatement.java | 47 -------------
.../statement/doris/dml/DorisInsertStatement.java | 47 -------------
.../statement/doris/dml/DorisSelectStatement.java | 55 ---------------
.../statement/doris/dml/DorisUpdateStatement.java | 47 -------------
.../statement/mysql/dml/MySQLUpdateStatement.java | 12 ++--
parser/sql/statement/type/pom.xml | 1 -
test/it/parser/pom.xml | 5 --
23 files changed, 84 insertions(+), 802 deletions(-)
diff --git a/parser/sql/dialect/doris/pom.xml b/parser/sql/dialect/doris/pom.xml
index 3f640162811..797ad90e15b 100644
--- a/parser/sql/dialect/doris/pom.xml
+++ b/parser/sql/dialect/doris/pom.xml
@@ -36,11 +36,6 @@
<artifactId>shardingsphere-infra-database-doris</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-parser-sql-statement-doris</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-parser-sql-statement-mysql</artifactId>
diff --git a/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/DorisStatementVisitor.java b/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/DorisStatementVisitor.java
index dcbf09bcf37..7806ced8759 100644
--- a/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/DorisStatementVisitor.java
+++ b/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/DorisStatementVisitor.java
@@ -237,10 +237,10 @@ import org.apache.shardingsphere.sql.parser.statement.core.value.literal.impl.Nu
import org.apache.shardingsphere.sql.parser.statement.core.value.literal.impl.OtherLiteralValue;
import org.apache.shardingsphere.sql.parser.statement.core.value.literal.impl.StringLiteralValue;
import org.apache.shardingsphere.sql.parser.statement.core.value.parametermarker.ParameterMarkerValue;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisDeleteStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisInsertStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisSelectStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisUpdateStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLDeleteStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLInsertStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLSelectStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLUpdateStatement;
import java.math.BigDecimal;
import java.util.ArrayList;
@@ -689,7 +689,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
if (null != ctx.queryExpressionParens()) {
return visit(ctx.queryExpressionParens());
}
- DorisSelectStatement result = (DorisSelectStatement) visit(ctx.queryExpression());
+ MySQLSelectStatement result = (MySQLSelectStatement) visit(ctx.queryExpression());
if (null != ctx.lockClauseList()) {
result.setLock((LockSegment) visit(ctx.lockClauseList()));
}
@@ -710,11 +710,11 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitQueryExpression(final QueryExpressionContext ctx) {
- DorisSelectStatement result;
+ MySQLSelectStatement result;
if (null != ctx.queryExpressionBody()) {
- result = (DorisSelectStatement) visit(ctx.queryExpressionBody());
+ result = (MySQLSelectStatement) visit(ctx.queryExpressionBody());
} else {
- result = (DorisSelectStatement) visit(ctx.queryExpressionParens());
+ result = (MySQLSelectStatement) visit(ctx.queryExpressionParens());
}
if (null != ctx.orderByClause()) {
result.setOrderBy((OrderBySegment) visit(ctx.orderByClause()));
@@ -733,7 +733,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
if (null != ctx.selectWithInto()) {
return visit(ctx.selectWithInto());
}
- DorisSelectStatement result = (DorisSelectStatement) visit(ctx.queryExpression());
+ MySQLSelectStatement result = (MySQLSelectStatement) visit(ctx.queryExpression());
if (null != ctx.lockClauseList()) {
result.setLock((LockSegment) visit(ctx.lockClauseList()));
}
@@ -767,9 +767,9 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
return visit(ctx.queryPrimary());
}
if (null != ctx.queryExpressionBody() && ctx.queryExpressionBody().size() > 1) {
- DorisSelectStatement result = new DorisSelectStatement();
+ MySQLSelectStatement result = new MySQLSelectStatement();
SubquerySegment left = new SubquerySegment(ctx.queryExpressionBody(0).start.getStartIndex(), ctx.queryExpressionBody(0).stop.getStopIndex(),
- (DorisSelectStatement) visit(ctx.queryExpressionBody(0)), getOriginalText(ctx.queryExpressionBody(0)));
+ (MySQLSelectStatement) visit(ctx.queryExpressionBody(0)), getOriginalText(ctx.queryExpressionBody(0)));
result.setProjections(left.getSelect().getProjections());
left.getSelect().getFrom().ifPresent(result::setFrom);
result.setCombine(createCombineSegment(ctx, left));
@@ -788,13 +788,13 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
combineType = null == ctx.combineOption() || null == ctx.combineOption().ALL() ? CombineType.UNION : CombineType.UNION_ALL;
}
ParserRuleContext ruleContext = ctx.queryExpressionBody(1);
- SubquerySegment right = new SubquerySegment(ruleContext.start.getStartIndex(), ruleContext.stop.getStopIndex(), (DorisSelectStatement) visit(ruleContext), getOriginalText(ruleContext));
+ SubquerySegment right = new SubquerySegment(ruleContext.start.getStartIndex(), ruleContext.stop.getStopIndex(), (MySQLSelectStatement) visit(ruleContext), getOriginalText(ruleContext));
return new CombineSegment(ctx.getStart().getStartIndex(), ctx.getStop().getStopIndex(), left, combineType, right);
}
@Override
public ASTNode visitQuerySpecification(final QuerySpecificationContext ctx) {
- DorisSelectStatement result = new DorisSelectStatement();
+ MySQLSelectStatement result = new MySQLSelectStatement();
result.setProjections((ProjectionsSegment) visit(ctx.projections()));
if (null != ctx.selectSpecification()) {
result.getProjections().setDistinctRow(isDistinct(ctx));
@@ -827,7 +827,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitTableValueConstructor(final TableValueConstructorContext ctx) {
- DorisSelectStatement result = new DorisSelectStatement();
+ MySQLSelectStatement result = new MySQLSelectStatement();
int startIndex = ctx.getStart().getStartIndex();
int stopIndex = ctx.getStop().getStopIndex();
ValuesExpression valuesExpression = new ValuesExpression(startIndex, stopIndex);
@@ -847,7 +847,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitTableStatement(final TableStatementContext ctx) {
- DorisSelectStatement result = new DorisSelectStatement();
+ MySQLSelectStatement result = new MySQLSelectStatement();
result.setProjections(new ProjectionsSegment(ctx.start.getStartIndex(), ctx.start.getStartIndex()));
result.getProjections().getProjections().add(new ShorthandProjectionSegment(ctx.start.getStartIndex(), ctx.start.getStartIndex()));
result.setFrom(new SimpleTableSegment(new TableNameSegment(ctx.start.getStartIndex(), ctx.stop.getStopIndex(), new IdentifierValue(ctx.tableName().getText()))));
@@ -1430,13 +1430,13 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitInsert(final InsertContext ctx) {
// TODO :FIXME, since there is no segment for insertValuesClause, InsertStatement is created by sub rule.
- DorisInsertStatement result;
+ MySQLInsertStatement result;
if (null != ctx.insertValuesClause()) {
- result = (DorisInsertStatement) visit(ctx.insertValuesClause());
+ result = (MySQLInsertStatement) visit(ctx.insertValuesClause());
} else if (null != ctx.insertSelectClause()) {
- result = (DorisInsertStatement) visit(ctx.insertSelectClause());
+ result = (MySQLInsertStatement) visit(ctx.insertSelectClause());
} else {
- result = new DorisInsertStatement();
+ result = new MySQLInsertStatement();
result.setSetAssignment((SetAssignmentSegment) visit(ctx.setAssignmentsClause()));
}
if (null != ctx.onDuplicateKeyClause()) {
@@ -1449,7 +1449,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitInsertSelectClause(final InsertSelectClauseContext ctx) {
- DorisInsertStatement result = new DorisInsertStatement();
+ MySQLInsertStatement result = new MySQLInsertStatement();
result.setInsertSelect(createInsertSelectSegment(ctx));
if (null != ctx.LP_()) {
if (null != ctx.fields()) {
@@ -1464,14 +1464,14 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
}
private SubquerySegment createInsertSelectSegment(final InsertSelectClauseContext ctx) {
- DorisSelectStatement selectStatement = (DorisSelectStatement) visit(ctx.select());
+ MySQLSelectStatement selectStatement = (MySQLSelectStatement) visit(ctx.select());
selectStatement.getParameterMarkerSegments().addAll(getParameterMarkerSegments());
return new SubquerySegment(ctx.select().start.getStartIndex(), ctx.select().stop.getStopIndex(), selectStatement, getOriginalText(ctx.select()));
}
@Override
public ASTNode visitInsertValuesClause(final InsertValuesClauseContext ctx) {
- DorisInsertStatement result = new DorisInsertStatement();
+ MySQLInsertStatement result = new MySQLInsertStatement();
if (null != ctx.LP_()) {
if (null != ctx.fields()) {
result.setInsertColumns(new InsertColumnsSegment(ctx.LP_().getSymbol().getStartIndex(), ctx.RP_().getSymbol().getStopIndex(), createInsertColumns(ctx.fields())));
@@ -1505,13 +1505,13 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitReplace(final ReplaceContext ctx) {
// TODO :FIXME, since there is no segment for replaceValuesClause, ReplaceStatement is created by sub rule.
- DorisInsertStatement result;
+ MySQLInsertStatement result;
if (null != ctx.replaceValuesClause()) {
- result = (DorisInsertStatement) visit(ctx.replaceValuesClause());
+ result = (MySQLInsertStatement) visit(ctx.replaceValuesClause());
} else if (null != ctx.replaceSelectClause()) {
- result = (DorisInsertStatement) visit(ctx.replaceSelectClause());
+ result = (MySQLInsertStatement) visit(ctx.replaceSelectClause());
} else {
- result = new DorisInsertStatement();
+ result = new MySQLInsertStatement();
result.setSetAssignment((SetAssignmentSegment) visit(ctx.setAssignmentsClause()));
}
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
@@ -1521,7 +1521,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitReplaceSelectClause(final ReplaceSelectClauseContext ctx) {
- DorisInsertStatement result = new DorisInsertStatement();
+ MySQLInsertStatement result = new MySQLInsertStatement();
if (null != ctx.LP_()) {
if (null != ctx.fields()) {
result.setInsertColumns(new InsertColumnsSegment(ctx.LP_().getSymbol().getStartIndex(), ctx.RP_().getSymbol().getStopIndex(), createInsertColumns(ctx.fields())));
@@ -1536,13 +1536,13 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
}
private SubquerySegment createReplaceSelectSegment(final ReplaceSelectClauseContext ctx) {
- DorisSelectStatement selectStatement = (DorisSelectStatement) visit(ctx.select());
+ MySQLSelectStatement selectStatement = (MySQLSelectStatement) visit(ctx.select());
return new SubquerySegment(ctx.select().start.getStartIndex(), ctx.select().stop.getStopIndex(), selectStatement, getOriginalText(ctx.select()));
}
@Override
public ASTNode visitReplaceValuesClause(final ReplaceValuesClauseContext ctx) {
- DorisInsertStatement result = new DorisInsertStatement();
+ MySQLInsertStatement result = new MySQLInsertStatement();
if (null != ctx.LP_()) {
if (null != ctx.fields()) {
result.setInsertColumns(new InsertColumnsSegment(ctx.LP_().getSymbol().getStartIndex(), ctx.RP_().getSymbol().getStopIndex(), createInsertColumns(ctx.fields())));
@@ -1566,7 +1566,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitUpdate(final UpdateContext ctx) {
- DorisUpdateStatement result = new DorisUpdateStatement();
+ MySQLUpdateStatement result = new MySQLUpdateStatement();
TableSegment tableSegment = (TableSegment) visit(ctx.tableReferences());
result.setTable(tableSegment);
result.setSetAssignment((SetAssignmentSegment) visit(ctx.setAssignmentsClause()));
@@ -1631,7 +1631,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitDelete(final DeleteContext ctx) {
- DorisDeleteStatement result = new DorisDeleteStatement();
+ MySQLDeleteStatement result = new MySQLDeleteStatement();
if (null != ctx.multipleTablesClause()) {
result.setTable((TableSegment) visit(ctx.multipleTablesClause()));
} else {
@@ -1678,16 +1678,16 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitSelect(final SelectContext ctx) {
- DorisSelectStatement result;
+ MySQLSelectStatement result;
if (null != ctx.queryExpression()) {
- result = (DorisSelectStatement) visit(ctx.queryExpression());
+ result = (MySQLSelectStatement) visit(ctx.queryExpression());
if (null != ctx.lockClauseList()) {
result.setLock((LockSegment) visit(ctx.lockClauseList()));
}
} else if (null != ctx.selectWithInto()) {
- result = (DorisSelectStatement) visit(ctx.selectWithInto());
+ result = (MySQLSelectStatement) visit(ctx.selectWithInto());
} else {
- result = (DorisSelectStatement) visit(ctx.getChild(0));
+ result = (MySQLSelectStatement) visit(ctx.getChild(0));
}
result.addParameterMarkerSegments(getParameterMarkerSegments());
return result;
@@ -1903,7 +1903,7 @@ public abstract class DorisStatementVisitor extends DorisStatementBaseVisitor<AS
@Override
public ASTNode visitTableFactor(final TableFactorContext ctx) {
if (null != ctx.subquery()) {
- DorisSelectStatement subquery = (DorisSelectStatement) visit(ctx.subquery());
+ MySQLSelectStatement subquery = (MySQLSelectStatement) visit(ctx.subquery());
SubquerySegment subquerySegment = new SubquerySegment(ctx.subquery().start.getStartIndex(), ctx.subquery().stop.getStopIndex(), subquery, getOriginalText(ctx.subquery()));
SubqueryTableSegment result = new SubqueryTableSegment(ctx.start.getStartIndex(), ctx.stop.getStopIndex(), subquerySegment);
if (null != ctx.alias()) {
diff --git a/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDALStatementVisitor.java b/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDALStatementVisitor.java
index 8f81a0ba779..b3be01af042 100644
--- a/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDALStatementVisitor.java
+++ b/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDALStatementVisitor.java
@@ -212,7 +212,7 @@ import org.apache.shardingsphere.sql.parser.statement.core.value.collection.Coll
import org.apache.shardingsphere.sql.parser.statement.core.value.identifier.IdentifierValue;
import org.apache.shardingsphere.sql.parser.statement.core.value.literal.impl.NumberLiteralValue;
import org.apache.shardingsphere.sql.parser.statement.core.value.literal.impl.StringLiteralValue;
-import org.apache.shardingsphere.sql.parser.statement.doris.dal.DorisExplainStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dal.MySQLExplainStatement;
import java.util.Collections;
import java.util.LinkedList;
@@ -488,7 +488,7 @@ public final class DorisDALStatementVisitor extends DorisStatementVisitor implem
@Override
public ASTNode visitExplain(final ExplainContext ctx) {
- DorisExplainStatement result = new DorisExplainStatement();
+ MySQLExplainStatement result = new MySQLExplainStatement();
if (null != ctx.tableName()) {
result.setSimpleTable((SimpleTableSegment) visit(ctx.tableName()));
if (null != ctx.columnRef()) {
diff --git a/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDDLStatementVisitor.java b/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDDLStatementVisitor.java
index 38d54df9592..474f2c4c1c9 100644
--- a/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDDLStatementVisitor.java
+++ b/parser/sql/dialect/doris/src/main/java/org/apache/shardingsphere/sql/parser/doris/visitor/statement/type/DorisDDLStatementVisitor.java
@@ -151,24 +151,17 @@ import org.apache.shardingsphere.sql.parser.statement.core.statement.SQLStatemen
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterDatabaseStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterEventStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterFunctionStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLAlterInstanceStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLAlterLogfileGroupStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterProcedureStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterServerStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterTablespaceStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateDatabaseStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateEventStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateLogfileGroupStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateMaterializedViewStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateServerStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTablespaceStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateTriggerStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateViewStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DeallocateStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropDatabaseStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropEventStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropFunctionStatement;
-import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropLogfileGroupStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropProcedureStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropServerStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTablespaceStatement;
@@ -180,19 +173,26 @@ import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.Truncat
import org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
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.doris.ddl.DorisAlterTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisAlterViewStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisCreateFunctionStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisCreateIndexStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisCreateProcedureStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisCreateTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisDropIndexStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisDropTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.ddl.DorisDropViewStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisDeleteStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisInsertStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisSelectStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.dml.DorisUpdateStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLAlterInstanceStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLAlterLogfileGroupStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLAlterTableStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLAlterViewStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateEventStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateFunctionStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateIndexStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateLogfileGroupStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateProcedureStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateServerStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLCreateTableStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropEventStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropIndexStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropLogfileGroupStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropTableStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.ddl.MySQLDropViewStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLDeleteStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLInsertStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLSelectStatement;
+import org.apache.shardingsphere.sql.parser.statement.mysql.dml.MySQLUpdateStatement;
import java.util.Collection;
import java.util.Collections;
@@ -211,23 +211,23 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
result.setReplaceView(null != ctx.REPLACE());
result.setView((SimpleTableSegment) visit(ctx.viewName()));
result.setViewDefinition(getOriginalText(ctx.select()));
- result.setSelect((DorisSelectStatement) visit(ctx.select()));
+ result.setSelect((MySQLSelectStatement) visit(ctx.select()));
return result;
}
@Override
public ASTNode visitAlterView(final AlterViewContext ctx) {
- DorisAlterViewStatement result = new DorisAlterViewStatement();
+ MySQLAlterViewStatement result = new MySQLAlterViewStatement();
result.setView((SimpleTableSegment) visit(ctx.viewName()));
result.setViewDefinition(getOriginalText(ctx.select()));
- result.setSelect((DorisSelectStatement) visit(ctx.select()));
+ result.setSelect((MySQLSelectStatement) visit(ctx.select()));
return result;
}
@SuppressWarnings("unchecked")
@Override
public ASTNode visitDropView(final DropViewContext ctx) {
- DorisDropViewStatement result = new DorisDropViewStatement();
+ MySQLDropViewStatement result = new MySQLDropViewStatement();
result.setIfExists(null != ctx.ifExists());
result.getViews().addAll(((CollectionValue<SimpleTableSegment>) visit(ctx.viewNames())).getValue());
return result;
@@ -251,7 +251,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitCreateTable(final CreateTableContext ctx) {
- DorisCreateTableStatement result = new DorisCreateTableStatement();
+ MySQLCreateTableStatement result = new MySQLCreateTableStatement();
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
result.setIfNotExists(null != ctx.ifNotExists());
if (null != ctx.createDefinitionClause()) {
@@ -313,7 +313,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitAlterTable(final AlterTableContext ctx) {
- DorisAlterTableStatement result = new DorisAlterTableStatement();
+ MySQLAlterTableStatement result = new MySQLAlterTableStatement();
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
if (null == ctx.alterTableActions() || null == ctx.alterTableActions().alterCommandList() || null == ctx.alterTableActions().alterCommandList().alterList()) {
return result;
@@ -324,7 +324,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
return result;
}
- private void setAlterDefinition(final DorisAlterTableStatement alterTableStatement, final AlterDefinitionSegment alterDefinitionSegment) {
+ private void setAlterDefinition(final MySQLAlterTableStatement alterTableStatement, final AlterDefinitionSegment alterDefinitionSegment) {
if (alterDefinitionSegment instanceof AddColumnDefinitionSegment) {
alterTableStatement.getAddColumnDefinitions().add((AddColumnDefinitionSegment) alterDefinitionSegment);
} else if (alterDefinitionSegment instanceof ModifyColumnDefinitionSegment) {
@@ -662,7 +662,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@SuppressWarnings("unchecked")
@Override
public ASTNode visitDropTable(final DropTableContext ctx) {
- DorisDropTableStatement result = new DorisDropTableStatement();
+ MySQLDropTableStatement result = new MySQLDropTableStatement();
result.setIfExists(null != ctx.ifExists());
result.getTables().addAll(((CollectionValue<SimpleTableSegment>) visit(ctx.tableList())).getValue());
return result;
@@ -678,7 +678,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@SuppressWarnings({"unchecked", "rawtypes"})
@Override
public ASTNode visitCreateIndex(final CreateIndexContext ctx) {
- DorisCreateIndexStatement result = new DorisCreateIndexStatement();
+ MySQLCreateIndexStatement result = new MySQLCreateIndexStatement();
result.setTable((SimpleTableSegment) visit(ctx.tableName()));
IndexNameSegment indexName = new IndexNameSegment(ctx.indexName().start.getStartIndex(), ctx.indexName().stop.getStopIndex(), new IdentifierValue(ctx.indexName().getText()));
result.setIndex(new IndexSegment(ctx.indexName().start.getStartIndex(), ctx.indexName().stop.getStopIndex(), indexName));
@@ -696,7 +696,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@Override
public ASTNode visitDropIndex(final DropIndexContext ctx) {
- DorisDropIndexStatement result = new DorisDropIndexStatement();
+ MySQLDropIndexStatement result = new MySQLDropIndexStatement();
result.setSimpleTable((SimpleTableSegment) visit(ctx.tableName()));
IndexNameSegment indexName = new IndexNameSegment(ctx.indexName().start.getStartIndex(), ctx.indexName().stop.getStopIndex(), new IdentifierValue(ctx.indexName().getText()));
result.getIndexes().add(new IndexSegment(ctx.indexName().start.getStartIndex(), ctx.indexName().stop.getStopIndex(), indexName));
@@ -732,7 +732,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@Override
public ASTNode visitCreateProcedure(final CreateProcedureContext ctx) {
- DorisCreateProcedureStatement result = new DorisCreateProcedureStatement();
+ MySQLCreateProcedureStatement result = new MySQLCreateProcedureStatement();
result.setProcedureName((FunctionNameSegment) visit(ctx.functionName()));
result.setRoutineBody((RoutineBodySegment) visit(ctx.routineBody()));
return result;
@@ -759,7 +759,7 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
@Override
public ASTNode visitCreateFunction(final CreateFunctionContext ctx) {
- DorisCreateFunctionStatement result = new DorisCreateFunctionStatement();
+ MySQLCreateFunctionStatement result = new MySQLCreateFunctionStatement();
result.setFunctionName((FunctionNameSegment) visit(ctx.functionName()));
result.setRoutineBody((RoutineBodySegment) visit(ctx.routineBody()));
return result;
@@ -817,23 +817,23 @@ public final class DorisDDLStatementVisitor extends DorisStatementVisitor implem
ValidStatementSegment result = new ValidStatementSegment(ctx.start.getStartIndex(), ctx.stop.getStopIndex());
SQLStatement sqlStatement = null;
if (null != ctx.createTable()) {
- sqlStatement = (DorisCreateTableStatement) visit(ctx.createTable());
+ sqlStatement = (MySQLCreateTableStatement) visit(ctx.createTable());
} else if (null != ctx.alterTable()) {
- sqlStatement = (DorisAlterTableStatement) visit(ctx.alterTable());
+ sqlStatement = (MySQLAlterTableStatement) visit(ctx.alterTable());
} else if (null != ctx.dropTable()) {
- sqlStatement = (DorisDropTableStatement) visit(ctx.dropTable());
+ sqlStatement = (MySQLDropTableStatement) visit(ctx.dropTable());
} else if (null != ctx.truncateTable()) {
sqlStatement = (TruncateStatement) visit(ctx.truncateTable());
} else if (null != ctx.insert()) {
- sqlStatement = (DorisInsertStatement) visit(ctx.insert());
+ sqlStatement = (MySQLInsertStatement) visit(ctx.insert());
} else if (null != ctx.replace()) {
- sqlStatement = (DorisInsertStatement) visit(ctx.replace());
+ sqlStatement = (MySQLInsertStatement) visit(ctx.replace());
} else if (null != ctx.update()) {
- sqlStatement = (DorisUpdateStatement) visit(ctx.update());
+ sqlStatement = (MySQLUpdateStatement) visit(ctx.update());
} else if (null != ctx.delete()) {
- sqlStatement = (DorisDeleteStatement) visit(ctx.delete());
+ sqlStatement = (MySQLDeleteStatement) visit(ctx.delete());
} else if (null != ctx.select()) {
- sqlStatement = (DorisSelectStatement) visit(ctx.select());
+ sqlStatement = (MySQLSelectStatement) visit(ctx.select());
}
result.setSqlStatement(sqlStatement);
return result;
diff --git a/parser/sql/statement/type/doris/pom.xml b/parser/sql/statement/type/doris/pom.xml
deleted file mode 100644
index a6f6e7201da..00000000000
--- a/parser/sql/statement/type/doris/pom.xml
+++ /dev/null
@@ -1,36 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ~ 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.
- -->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-parser-sql-statement-type</artifactId>
- <version>5.5.3-SNAPSHOT</version>
- </parent>
- <artifactId>shardingsphere-parser-sql-statement-doris</artifactId>
- <name>${project.artifactId}</name>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-parser-sql-statement-core</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-</project>
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/DorisStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/DorisStatement.java
deleted file mode 100644
index 96e361e5cd5..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/DorisStatement.java
+++ /dev/null
@@ -1,26 +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.doris;
-
-import org.apache.shardingsphere.sql.parser.statement.core.statement.SQLStatement;
-
-/**
- * Doris statement.
- */
-public interface DorisStatement extends SQLStatement {
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dal/DorisExplainStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dal/DorisExplainStatement.java
deleted file mode 100644
index 492706650b0..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dal/DorisExplainStatement.java
+++ /dev/null
@@ -1,47 +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.doris.dal;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.column.ColumnSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.dal.ExplainStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris explain statement.
- */
-@Setter
-public final class DorisExplainStatement extends ExplainStatement implements DorisStatement {
-
- private SimpleTableSegment simpleTable;
-
- private ColumnSegment columnWild;
-
- @Override
- public Optional<SimpleTableSegment> getSimpleTable() {
- return Optional.ofNullable(simpleTable);
- }
-
- @Override
- public Optional<ColumnSegment> getColumnWild() {
- return Optional.ofNullable(columnWild);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisAlterTableStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisAlterTableStatement.java
deleted file mode 100644
index ada69e32d88..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisAlterTableStatement.java
+++ /dev/null
@@ -1,55 +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.doris.ddl;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.AlgorithmTypeSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.LockTableSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris alter table statement.
- */
-@Setter
-public final class DorisAlterTableStatement extends AlterTableStatement implements DorisStatement {
-
- private AlgorithmTypeSegment algorithmSegment;
-
- private LockTableSegment lockTableSegment;
-
- /**
- * Get algorithm segment.
- *
- * @return algorithm segment
- */
- public Optional<AlgorithmTypeSegment> getGetAlgorithmSegment() {
- return Optional.ofNullable(algorithmSegment);
- }
-
- /**
- * Get lock table Segment.
- *
- * @return lock table segment
- */
- public Optional<LockTableSegment> getLockTableSegment() {
- return Optional.ofNullable(lockTableSegment);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisAlterViewStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisAlterViewStatement.java
deleted file mode 100644
index 9922da33dc4..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisAlterViewStatement.java
+++ /dev/null
@@ -1,46 +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.doris.ddl;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.AlterViewStatement;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris alter view statement.
- */
-@Setter
-public final class DorisAlterViewStatement extends AlterViewStatement implements DorisStatement {
-
- private SelectStatement select;
-
- private String viewDefinition;
-
- @Override
- public Optional<SelectStatement> getSelect() {
- return Optional.ofNullable(select);
- }
-
- @Override
- public Optional<String> getViewDefinition() {
- return Optional.ofNullable(viewDefinition);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateFunctionStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateFunctionStatement.java
deleted file mode 100644
index d406b747acc..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateFunctionStatement.java
+++ /dev/null
@@ -1,39 +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.doris.ddl;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.routine.RoutineBodySegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateFunctionStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris create function statement.
- */
-@Setter
-public final class DorisCreateFunctionStatement extends CreateFunctionStatement implements DorisStatement {
-
- private RoutineBodySegment routineBody;
-
- @Override
- public Optional<RoutineBodySegment> getRoutineBody() {
- return Optional.ofNullable(routineBody);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateIndexStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateIndexStatement.java
deleted file mode 100644
index f913c2b1e3e..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateIndexStatement.java
+++ /dev/null
@@ -1,47 +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.doris.ddl;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.AlgorithmTypeSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.LockTableSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateIndexStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris create index statement.
- */
-@Setter
-public final class DorisCreateIndexStatement extends CreateIndexStatement implements DorisStatement {
-
- private AlgorithmTypeSegment algorithmType;
-
- private LockTableSegment lockTable;
-
- @Override
- public Optional<AlgorithmTypeSegment> getAlgorithmType() {
- return Optional.ofNullable(algorithmType);
- }
-
- @Override
- public Optional<LockTableSegment> getLockTable() {
- return Optional.ofNullable(lockTable);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateProcedureStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateProcedureStatement.java
deleted file mode 100644
index 298135981d9..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateProcedureStatement.java
+++ /dev/null
@@ -1,39 +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.doris.ddl;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.routine.RoutineBodySegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.CreateProcedureStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris create procedure statement.
- */
-@Setter
-public final class DorisCreateProcedureStatement extends CreateProcedureStatement implements DorisStatement {
-
- private RoutineBodySegment routineBody;
-
- @Override
- public Optional<RoutineBodySegment> getRoutineBody() {
- return Optional.ofNullable(routineBody);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateTableStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateTableStatement.java
deleted file mode 100644
index ec4a2500ec7..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisCreateTableStatement.java
+++ /dev/null
@@ -1,53 +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.doris.ddl;
-
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.CreateTableOptionSegment;
-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.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris create table statement.
- */
-@RequiredArgsConstructor
-@Getter
-@Setter
-public final class DorisCreateTableStatement extends CreateTableStatement implements DorisStatement {
-
- private boolean ifNotExists;
-
- private SimpleTableSegment likeTable;
-
- private CreateTableOptionSegment createTableOption;
-
- @Override
- public Optional<SimpleTableSegment> getLikeTable() {
- return Optional.ofNullable(likeTable);
- }
-
- @Override
- public Optional<CreateTableOptionSegment> getCreateTableOption() {
- return Optional.ofNullable(createTableOption);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropIndexStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropIndexStatement.java
deleted file mode 100644
index 32f10148c57..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropIndexStatement.java
+++ /dev/null
@@ -1,55 +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.doris.ddl;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.AlgorithmTypeSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.table.LockTableSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropIndexStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris drop index statement.
- */
-@Setter
-public final class DorisDropIndexStatement extends DropIndexStatement implements DorisStatement {
-
- private SimpleTableSegment simpleTable;
-
- private AlgorithmTypeSegment algorithmType;
-
- private LockTableSegment lockTable;
-
- @Override
- public Optional<SimpleTableSegment> getSimpleTable() {
- return Optional.ofNullable(simpleTable);
- }
-
- @Override
- public Optional<AlgorithmTypeSegment> getAlgorithmType() {
- return Optional.ofNullable(algorithmType);
- }
-
- @Override
- public Optional<LockTableSegment> getLockTable() {
- return Optional.ofNullable(lockTable);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropTableStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropTableStatement.java
deleted file mode 100644
index 7c9ba41ddcf..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropTableStatement.java
+++ /dev/null
@@ -1,35 +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.doris.ddl;
-
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropTableStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-/**
- * Doris drop table statement.
- */
-@RequiredArgsConstructor
-@Getter
-@Setter
-public final class DorisDropTableStatement extends DropTableStatement implements DorisStatement {
-
- private boolean ifExists;
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropViewStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropViewStatement.java
deleted file mode 100644
index eb02918ff4e..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/ddl/DorisDropViewStatement.java
+++ /dev/null
@@ -1,33 +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.doris.ddl;
-
-import lombok.Getter;
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.ddl.DropViewStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-/**
- * Doris drop view statement.
- */
-@Getter
-@Setter
-public final class DorisDropViewStatement extends DropViewStatement implements DorisStatement {
-
- private boolean ifExists;
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisDeleteStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisDeleteStatement.java
deleted file mode 100644
index 4125aae6fee..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisDeleteStatement.java
+++ /dev/null
@@ -1,47 +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.doris.dml;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.order.OrderBySegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.pagination.limit.LimitSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.dml.DeleteStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris delete statement.
- */
-@Setter
-public final class DorisDeleteStatement extends DeleteStatement implements DorisStatement {
-
- private OrderBySegment orderBy;
-
- private LimitSegment limit;
-
- @Override
- public Optional<OrderBySegment> getOrderBy() {
- return Optional.ofNullable(orderBy);
- }
-
- @Override
- public Optional<LimitSegment> getLimit() {
- return Optional.ofNullable(limit);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisInsertStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisInsertStatement.java
deleted file mode 100644
index 25bb951f12e..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisInsertStatement.java
+++ /dev/null
@@ -1,47 +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.doris.dml;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.assignment.SetAssignmentSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.column.OnDuplicateKeyColumnsSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.dml.InsertStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris insert statement.
- */
-@Setter
-public final class DorisInsertStatement extends InsertStatement implements DorisStatement {
-
- private SetAssignmentSegment setAssignment;
-
- private OnDuplicateKeyColumnsSegment onDuplicateKeyColumns;
-
- @Override
- public Optional<SetAssignmentSegment> getSetAssignment() {
- return Optional.ofNullable(setAssignment);
- }
-
- @Override
- public Optional<OnDuplicateKeyColumnsSegment> getOnDuplicateKeyColumns() {
- return Optional.ofNullable(onDuplicateKeyColumns);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisSelectStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisSelectStatement.java
deleted file mode 100644
index 04e73650d08..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisSelectStatement.java
+++ /dev/null
@@ -1,55 +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.doris.dml;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.pagination.limit.LimitSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.predicate.LockSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.generic.WindowSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.dml.SelectStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris select statement.
- */
-@Setter
-public final class DorisSelectStatement extends SelectStatement implements DorisStatement {
-
- private LimitSegment limit;
-
- private LockSegment lock;
-
- private WindowSegment window;
-
- @Override
- public Optional<LimitSegment> getLimit() {
- return Optional.ofNullable(limit);
- }
-
- @Override
- public Optional<LockSegment> getLock() {
- return Optional.ofNullable(lock);
- }
-
- @Override
- public Optional<WindowSegment> getWindow() {
- return Optional.ofNullable(window);
- }
-}
diff --git a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisUpdateStatement.java b/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisUpdateStatement.java
deleted file mode 100644
index a08b5c75732..00000000000
--- a/parser/sql/statement/type/doris/src/main/java/org/apache/shardingsphere/sql/parser/statement/doris/dml/DorisUpdateStatement.java
+++ /dev/null
@@ -1,47 +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.doris.dml;
-
-import lombok.Setter;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.order.OrderBySegment;
-import org.apache.shardingsphere.sql.parser.statement.core.segment.dml.pagination.limit.LimitSegment;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.dml.UpdateStatement;
-import org.apache.shardingsphere.sql.parser.statement.doris.DorisStatement;
-
-import java.util.Optional;
-
-/**
- * Doris update statement.
- */
-@Setter
-public final class DorisUpdateStatement extends UpdateStatement implements DorisStatement {
-
- private OrderBySegment orderBy;
-
- private LimitSegment limit;
-
- @Override
- public Optional<OrderBySegment> getOrderBy() {
- return Optional.ofNullable(orderBy);
- }
-
- @Override
- public Optional<LimitSegment> getLimit() {
- return Optional.ofNullable(limit);
- }
-}
diff --git a/parser/sql/statement/type/mysql/src/main/java/org/apache/shardingsphere/sql/parser/statement/mysql/dml/MySQLUpdateStatement.java b/parser/sql/statement/type/mysql/src/main/java/org/apache/shardingsphere/sql/parser/statement/mysql/dml/MySQLUpdateStatement.java
index 8677efa3dfa..b8cdd634a7c 100644
--- a/parser/sql/statement/type/mysql/src/main/java/org/apache/shardingsphere/sql/parser/statement/mysql/dml/MySQLUpdateStatement.java
+++ b/parser/sql/statement/type/mysql/src/main/java/org/apache/shardingsphere/sql/parser/statement/mysql/dml/MySQLUpdateStatement.java
@@ -32,16 +32,11 @@ import java.util.Optional;
@Setter
public final class MySQLUpdateStatement extends UpdateStatement implements MySQLStatement {
- private WithSegment withSegment;
-
private OrderBySegment orderBy;
private LimitSegment limit;
- @Override
- public Optional<WithSegment> getWithSegment() {
- return Optional.ofNullable(withSegment);
- }
+ private WithSegment withSegment;
@Override
public Optional<OrderBySegment> getOrderBy() {
@@ -52,4 +47,9 @@ public final class MySQLUpdateStatement extends UpdateStatement implements MySQL
public Optional<LimitSegment> getLimit() {
return Optional.ofNullable(limit);
}
+
+ @Override
+ public Optional<WithSegment> getWithSegment() {
+ return Optional.ofNullable(withSegment);
+ }
}
diff --git a/parser/sql/statement/type/pom.xml b/parser/sql/statement/type/pom.xml
index 0609179aae5..d5ab47baf5d 100644
--- a/parser/sql/statement/type/pom.xml
+++ b/parser/sql/statement/type/pom.xml
@@ -28,7 +28,6 @@
<name>${project.artifactId}</name>
<modules>
- <module>doris</module>
<module>firebird</module>
<module>hive</module>
<module>mysql</module>
diff --git a/test/it/parser/pom.xml b/test/it/parser/pom.xml
index 88c5b6d062f..751f6d4067e 100644
--- a/test/it/parser/pom.xml
+++ b/test/it/parser/pom.xml
@@ -152,11 +152,6 @@
<artifactId>shardingsphere-parser-sql-statement-presto</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-parser-sql-statement-doris</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>