This is an automated email from the ASF dual-hosted git repository.
panjuan 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 974f72b1182 Rename unionClause to combineClause in G4 file (#18211)
974f72b1182 is described below
commit 974f72b1182f1a554df2aa56b89e12d49182cb2f
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Jun 7 12:04:37 2022 +0800
Rename unionClause to combineClause in G4 file (#18211)
* Rename CombiningType.XXX_DISTINCT to XXX
* Fix test cases
* Refactor SelectStatementAssert
* Refactor UnionSegment
* Rename CombiningSegment
* Rename SelectStatement.combines
* Rename CombineSegment
* Rename CombineType
* Rename ExpectedUnion
* Rename ExpectedCombine
* Rename Combining to Combine
* Rename SelectStatementTestCase.combine
* Rename unionClause to combineClause in G4 file
---
.../optimizer/converter/SQLNodeConverterEngine.java | 6 +++---
.../src/main/antlr4/imports/mysql/BaseRule.g4 | 2 +-
.../src/main/antlr4/imports/mysql/DMLStatement.g4 | 8 ++++----
.../mysql/visitor/format/impl/MySQLFormatSQLVisitor.java | 14 +++++++-------
.../visitor/statement/impl/MySQLStatementSQLVisitor.java | 14 +++++++-------
.../statement/impl/OpenGaussStatementSQLVisitor.java | 2 +-
.../src/main/antlr4/imports/oracle/DMLStatement.g4 | 4 ++--
.../statement/impl/OracleDMLStatementSQLVisitor.java | 8 ++++----
.../statement/impl/PostgreSQLStatementSQLVisitor.java | 2 +-
.../src/main/antlr4/imports/sql92/DMLStatement.g4 | 6 +++---
.../statement/impl/SQL92DMLStatementSQLVisitor.java | 8 ++++----
.../segment/dml/{union => combine}/CombineSegment.java | 2 +-
.../parser/sql/common/statement/dml/SelectStatement.java | 2 +-
.../asserts/statement/dml/impl/SelectStatementAssert.java | 4 ++--
14 files changed, 41 insertions(+), 41 deletions(-)
diff --git
a/shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-optimizer/src/main/java/org/apache/shardingsphere/infra/federation/optimizer/converter/SQLNodeConverterEngine.java
b/shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-optimizer/src/main/java/org/apache/shardingsphere/infra/federation/optimizer/converter/SQLNodeConverterEngine.java
index 138147eb518..7e6c888ecdc 100644
---
a/shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-optimizer/src/main/java/org/apache/shardingsphere/infra/federation/optimizer/converter/SQLNodeConverterEngine.java
+++
b/shardingsphere-infra/shardingsphere-infra-federation/shardingsphere-infra-federation-optimizer/src/main/java/org/apache/shardingsphere/infra/federation/optimizer/converter/SQLNodeConverterEngine.java
@@ -30,7 +30,7 @@ import org.apache.calcite.sql.fun.SqlStdOperatorTable;
import org.apache.calcite.sql.parser.SqlParserPos;
import
org.apache.shardingsphere.infra.federation.optimizer.converter.statement.SelectStatementConverter;
import org.apache.shardingsphere.sql.parser.sql.common.constant.CombineType;
-import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union.CombineSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine.CombineSegment;
import org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.dml.SelectStatement;
@@ -64,8 +64,8 @@ public final class SQLNodeConverterEngine {
if (statement instanceof SelectStatement) {
SqlNode sqlNode = new
SelectStatementConverter().convertToSQLNode((SelectStatement) statement);
for (CombineSegment each : ((SelectStatement)
statement).getCombines()) {
- SqlNode unionSqlNode =
convertToSQLNode(each.getSelectStatement());
- return new
SqlBasicCall(convertCombineOperator(each.getCombineType()), new
SqlNode[]{sqlNode, unionSqlNode}, SqlParserPos.ZERO);
+ SqlNode combineSqlNode =
convertToSQLNode(each.getSelectStatement());
+ return new
SqlBasicCall(convertCombineOperator(each.getCombineType()), new
SqlNode[]{sqlNode, combineSqlNode}, SqlParserPos.ZERO);
}
return sqlNode;
}
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/BaseRule.g4
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/BaseRule.g4
index a62ffd14e64..cbd6b27b8ec 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/BaseRule.g4
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/BaseRule.g4
@@ -1285,7 +1285,7 @@ conditionName
: identifier
;
-unionOption
+combineOption
: ALL | DISTINCT
;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
index 375bd12eb3e..2230f42e23c 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/antlr4/imports/mysql/DMLStatement.g4
@@ -138,12 +138,12 @@ queryExpression
queryExpressionBody
: queryPrimary
- | queryExpressionParens unionClause
- | queryExpressionBody unionClause
+ | queryExpressionParens combineClause
+ | queryExpressionBody combineClause
;
-unionClause
- : UNION unionOption? (queryPrimary | queryExpressionParens)
+combineClause
+ : UNION combineOption? (queryPrimary | queryExpressionParens)
;
queryExpressionParens
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/format/impl/MySQLFormatSQLVisitor.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/format/impl/MySQLFormatSQLVisitor.java
index 94f0fe40264..9d4cae8ec13 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/format/impl/MySQLFormatSQLVisitor.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/format/impl/MySQLFormatSQLVisitor.java
@@ -31,12 +31,12 @@ import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.AlterTa
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.AlterTableContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.AssignmentValuesContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ColumnNamesContext;
+import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.CombineClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.CreateDefinitionClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.CreateTableOptionsSpaceSeparatedContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.CteClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.DataTypeContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.DerivedColumnsContext;
-import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableStatementContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ExprContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.FieldLengthContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.IdentifierContext;
@@ -64,10 +64,10 @@ import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.String_
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.SystemVariableContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableElementListContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableNameContext;
+import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableStatementContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableValueConstructorContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TemporalLiteralsContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TypeDatetimePrecisionContext;
-import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.UnionClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.UserVariableContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.WhereClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.WithClauseContext;
@@ -174,19 +174,19 @@ public abstract class MySQLFormatSQLVisitor extends
MySQLStatementBaseVisitor<St
visit(ctx.queryPrimary());
} else if (null != ctx.queryExpressionParens()) {
visit(ctx.queryExpressionParens());
- visit(ctx.unionClause());
+ visit(ctx.combineClause());
} else {
visit(ctx.queryExpressionBody());
- visit(ctx.unionClause());
+ visit(ctx.combineClause());
}
return result.toString();
}
@Override
- public String visitUnionClause(final UnionClauseContext ctx) {
+ public String visitCombineClause(final CombineClauseContext ctx) {
result.append("\nUNION\n");
- if (null != ctx.unionOption()) {
- visit(ctx.unionOption());
+ if (null != ctx.combineOption()) {
+ visit(ctx.combineOption());
result.append(" ");
}
if (null != ctx.queryPrimary()) {
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/statement/impl/MySQLStatementSQLVisitor.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/statement/impl/MySQLStatementSQLVisitor.java
index 3df4c546e44..30d8c4e874d 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/statement/impl/MySQLStatementSQLVisitor.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-mysql/src/main/java/org/apache/shardingsphere/sql/parser/mysql/visitor/statement/impl/MySQLStatementSQLVisitor.java
@@ -42,6 +42,7 @@ import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.Collate
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ColumnNameContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ColumnNamesContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ColumnRefContext;
+import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.CombineClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.CompleteRegularFunctionContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ConstraintNameContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ConvertFunctionContext;
@@ -123,7 +124,6 @@ import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableRe
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TableStatementContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TemporalLiteralsContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.TrimFunctionContext;
-import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.UnionClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.UpdateContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ValuesFunctionContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.ViewNameContext;
@@ -133,10 +133,10 @@ import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.WhereCl
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.WindowClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.MySQLStatementParser.WindowFunctionContext;
import
org.apache.shardingsphere.sql.parser.sql.common.constant.AggregationType;
+import org.apache.shardingsphere.sql.parser.sql.common.constant.CombineType;
import org.apache.shardingsphere.sql.parser.sql.common.constant.JoinType;
import org.apache.shardingsphere.sql.parser.sql.common.constant.OrderDirection;
import
org.apache.shardingsphere.sql.parser.sql.common.constant.ParameterMarkerType;
-import org.apache.shardingsphere.sql.parser.sql.common.constant.CombineType;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.ddl.constraint.ConstraintSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.ddl.index.IndexNameSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.ddl.index.IndexSegment;
@@ -183,7 +183,7 @@ import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.pagination.li
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.HavingSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.LockSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.WhereSegment;
-import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union.CombineSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine.CombineSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.AliasSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.DataTypeLengthSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.DataTypeSegment;
@@ -683,17 +683,17 @@ public abstract class MySQLStatementSQLVisitor extends
MySQLStatementBaseVisitor
}
if (null != ctx.queryExpressionBody()) {
MySQLSelectStatement result = (MySQLSelectStatement)
visit(ctx.queryExpressionBody());
- result.getCombines().add((CombineSegment)
visitUnionClause(ctx.unionClause()));
+ result.getCombines().add((CombineSegment)
visitCombineClause(ctx.combineClause()));
return result;
}
MySQLSelectStatement result = (MySQLSelectStatement)
visit(ctx.queryExpressionParens());
- result.getCombines().add((CombineSegment)
visitUnionClause(ctx.unionClause()));
+ result.getCombines().add((CombineSegment)
visitCombineClause(ctx.combineClause()));
return result;
}
@Override
- public ASTNode visitUnionClause(final UnionClauseContext ctx) {
- CombineType combineType = (null != ctx.unionOption() && null !=
ctx.unionOption().ALL()) ? CombineType.UNION_ALL : CombineType.UNION;
+ public ASTNode visitCombineClause(final CombineClauseContext ctx) {
+ CombineType combineType = (null != ctx.combineOption() && null !=
ctx.combineOption().ALL()) ? CombineType.UNION_ALL : CombineType.UNION;
MySQLSelectStatement statement = null != ctx.queryPrimary() ?
(MySQLSelectStatement) visit(ctx.queryPrimary()) : (MySQLSelectStatement)
visit(ctx.queryExpressionParens());
return new CombineSegment(ctx.getStart().getStartIndex(),
ctx.getStop().getStopIndex(), combineType, statement);
}
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-opengauss/src/main/java/org/apache/shardingsphere/sql/parser/opengauss/visitor/statement/impl/OpenGaussStatementSQLVisitor.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-opengauss/src/main/java/org/apache/shardingsphere/sql/parser/opengauss/visitor/statement/impl/OpenGaussStatementSQLVisitor.java
index 2caa6c98601..f7d8c43c3be 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-opengauss/src/main/java/org/apache/shardingsphere/sql/parser/opengauss/visitor/statement/impl/OpenGaussStatementSQLVisitor.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-opengauss/src/main/java/org/apache/shardingsphere/sql/parser/opengauss/visitor/statement/impl/OpenGaussStatementSQLVisitor.java
@@ -149,7 +149,7 @@ import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.pagination.li
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.HavingSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.LockSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.WhereSegment;
-import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union.CombineSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine.CombineSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.AliasAvailable;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.AliasSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.DataTypeLengthSegment;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/antlr4/imports/oracle/DMLStatement.g4
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/antlr4/imports/oracle/DMLStatement.g4
index 5f19b8c1b0f..8c0ad4c523a 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/antlr4/imports/oracle/DMLStatement.g4
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/antlr4/imports/oracle/DMLStatement.g4
@@ -136,10 +136,10 @@ select
;
selectSubquery
- : (queryBlock | selectUnionClause | parenthesisSelectSubquery)
orderByClause? rowLimitingClause
+ : (queryBlock | selectCombineClause | parenthesisSelectSubquery)
orderByClause? rowLimitingClause
;
-selectUnionClause
+selectCombineClause
: ((queryBlock | parenthesisSelectSubquery) orderByClause?
rowLimitingClause) ((UNION ALL? | INTERSECT | MINUS) selectSubquery)+
;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/impl/OracleDMLStatementSQLVisitor.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/impl/OracleDMLStatementSQLVisitor.java
index 8ae7f19001b..d496bc76f79 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/impl/OracleDMLStatementSQLVisitor.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/impl/OracleDMLStatementSQLVisitor.java
@@ -76,6 +76,7 @@ import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.QueryT
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.QueryTableExprContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.ReferenceModelContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.RollupCubeClauseContext;
+import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectCombineClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectFromClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectJoinOptionContext;
@@ -85,7 +86,6 @@ import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.Select
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectProjectionExprClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectSubqueryContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectTableReferenceContext;
-import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SelectUnionClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.ShardsClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SingleColumnForLoopContext;
import
org.apache.shardingsphere.sql.parser.autogen.OracleStatementParser.SubqueryContext;
@@ -463,8 +463,8 @@ public final class OracleDMLStatementSQLVisitor extends
OracleStatementSQLVisito
OracleSelectStatement result;
if (null != ctx.queryBlock()) {
result = (OracleSelectStatement) visit(ctx.queryBlock());
- } else if (null != ctx.selectUnionClause()) {
- result = (OracleSelectStatement) visit(ctx.selectUnionClause());
+ } else if (null != ctx.selectCombineClause()) {
+ result = (OracleSelectStatement) visit(ctx.selectCombineClause());
} else {
result = (OracleSelectStatement)
visit(ctx.parenthesisSelectSubquery());
}
@@ -576,7 +576,7 @@ public final class OracleDMLStatementSQLVisitor extends
OracleStatementSQLVisito
}
@Override
- public ASTNode visitSelectUnionClause(final SelectUnionClauseContext ctx) {
+ public ASTNode visitSelectCombineClause(final SelectCombineClauseContext
ctx) {
OracleSelectStatement result;
if (null != ctx.queryBlock()) {
result = (OracleSelectStatement) visit(ctx.queryBlock());
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/java/org/apache/shardingsphere/sql/parser/postgresql/visitor/statement/impl/PostgreSQLStatementSQLVisitor.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/java/org/apache/shardingsphere/sql/parser/postgresql/visitor/statement/impl/PostgreSQLStatementSQLVisitor.java
index 7469ccef81b..1f230bc984e 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/java/org/apache/shardingsphere/sql/parser/postgresql/visitor/statement/impl/PostgreSQLStatementSQLVisitor.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/java/org/apache/shardingsphere/sql/parser/postgresql/visitor/statement/impl/PostgreSQLStatementSQLVisitor.java
@@ -146,7 +146,7 @@ import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.pagination.li
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.HavingSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.LockSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.WhereSegment;
-import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union.CombineSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine.CombineSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.AliasAvailable;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.AliasSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.DataTypeLengthSegment;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/antlr4/imports/sql92/DMLStatement.g4
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/antlr4/imports/sql92/DMLStatement.g4
index 3333509e95d..97707d9110a 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/antlr4/imports/sql92/DMLStatement.g4
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/antlr4/imports/sql92/DMLStatement.g4
@@ -65,10 +65,10 @@ singleTableClause
;
select
- : unionClause
+ : combineClause
;
-unionClause
+combineClause
: selectClause (UNION (ALL)? selectClause)*
;
@@ -159,5 +159,5 @@ limitOffset
;
subquery
- : LP_ unionClause RP_
+ : LP_ combineClause RP_
;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/impl/SQL92DMLStatementSQLVisitor.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/impl/SQL92DMLStatementSQLVisitor.java
index fc62ba35838..70059388a15 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/impl/SQL92DMLStatementSQLVisitor.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-sql92/src/main/java/org/apache/shardingsphere/sql/parser/sql92/visitor/statement/impl/SQL92DMLStatementSQLVisitor.java
@@ -27,6 +27,7 @@ import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.Assignm
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.AssignmentValueContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.AssignmentValuesContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.ColumnNamesContext;
+import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.CombineClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.DeleteContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.DuplicateSpecificationContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.EscapedTableReferenceContext;
@@ -51,7 +52,6 @@ import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.Subquer
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.TableFactorContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.TableReferenceContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.TableReferencesContext;
-import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.UnionClauseContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.UpdateContext;
import
org.apache.shardingsphere.sql.parser.autogen.SQL92StatementParser.WhereClauseContext;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.assignment.AssignmentSegment;
@@ -218,14 +218,14 @@ public final class SQL92DMLStatementSQLVisitor extends
SQL92StatementSQLVisitor
@Override
public ASTNode visitSelect(final SelectContext ctx) {
// TODO :Unsupported for withClause.
- SQL92SelectStatement result = (SQL92SelectStatement)
visit(ctx.unionClause());
+ SQL92SelectStatement result = (SQL92SelectStatement)
visit(ctx.combineClause());
result.setParameterCount(getCurrentParameterIndex());
result.getParameterMarkerSegments().addAll(getParameterMarkerSegments());
return result;
}
@Override
- public ASTNode visitUnionClause(final UnionClauseContext ctx) {
+ public ASTNode visitCombineClause(final CombineClauseContext ctx) {
// TODO :Unsupported for union SQL.
return visit(ctx.selectClause(0));
}
@@ -473,6 +473,6 @@ public final class SQL92DMLStatementSQLVisitor extends
SQL92StatementSQLVisitor
@Override
public ASTNode visitSubquery(final SubqueryContext ctx) {
- return visit(ctx.unionClause());
+ return visit(ctx.combineClause());
}
}
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/union/CombineSegment.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/combine/CombineSegment.java
similarity index 99%
rename from
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/union/CombineSegment.java
rename to
shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/combine/CombineSegment.java
index f631dfb3f44..9bccce53cc4 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/union/CombineSegment.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/segment/dml/combine/CombineSegment.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union;
+package org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/dml/SelectStatement.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/dml/SelectStatement.java
index 00b11e61d53..4f53b42378a 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/dml/SelectStatement.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/dml/SelectStatement.java
@@ -25,7 +25,7 @@ import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.order.GroupBy
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.order.OrderBySegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.HavingSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.WhereSegment;
-import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union.CombineSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine.CombineSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.table.TableSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.AbstractSQLStatement;
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/dml/impl/SelectStatementAssert.java
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/dml/impl/SelectStatementAssert.java
index f627e5bff52..92286bb98ba 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/dml/impl/SelectStatementAssert.java
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/dml/impl/SelectStatementAssert.java
@@ -21,7 +21,7 @@ import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.pagination.limit.LimitSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.predicate.LockSegment;
-import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.union.CombineSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.dml.combine.CombineSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.ModelSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.WindowSegment;
import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.WithSegment;
@@ -186,7 +186,7 @@ public final class SelectStatementAssert {
return;
}
Collection<CombineSegment> combineSegments = actual.getCombines();
- assertFalse(assertContext.getText("Actual union segment should
exist."), combineSegments.isEmpty());
+ assertFalse(assertContext.getText("Actual combine segment should
exist."), combineSegments.isEmpty());
assertThat(assertContext.getText("Combine size assertion error: "),
combineSegments.size(), is(expected.getCombine().size()));
int count = 0;
for (CombineSegment each : combineSegments) {
