This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new f83e7ef1931 Add PostgreSQL Cluster Statement (#18142)
f83e7ef1931 is described below
commit f83e7ef1931917f40efc90d28b456dff0627b833
Author: Thanoshan MV <[email protected]>
AuthorDate: Thu Jun 2 05:34:00 2022 +0530
Add PostgreSQL Cluster Statement (#18142)
---
.../main/antlr4/imports/postgresql/DDLStatement.g4 | 20 +++++-
.../parser/autogen/PostgreSQLStatementParser.g4 | 1 +
.../impl/PostgreSQLDDLStatementSQLVisitor.java | 14 +++++
.../core/database/visitor/SQLVisitorRule.java | 4 +-
.../sql/common/statement/ddl/ClusterStatement.java | 28 +++++++++
.../handler/ddl/ClusterStatementHandler.java | 62 ++++++++++++++++++
.../postgresql/ddl/PostgreSQLClusterStatement.java | 59 +++++++++++++++++
.../asserts/statement/ddl/DDLStatementAssert.java | 11 +++-
.../statement/ddl/impl/ClusterStatementAssert.java | 73 ++++++++++++++++++++++
.../jaxb/cases/domain/SQLParserTestCases.java | 5 ++
.../statement/ddl/ClusterStatementTestCase.java | 40 ++++++++++++
.../src/main/resources/case/ddl/cluster.xml | 30 +++++++++
.../main/resources/sql/supported/ddl/cluster.xml | 23 +++++++
.../main/resources/sql/unsupported/unsupported.xml | 20 ------
14 files changed, 364 insertions(+), 26 deletions(-)
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/imports/postgresql/DDLStatement.g4
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/imports/postgresql/DDLStatement.g4
index 77d5825a284..b2da6ab0ad1 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/imports/postgresql/DDLStatement.g4
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/imports/postgresql/DDLStatement.g4
@@ -1194,11 +1194,27 @@ close
;
cluster
- : CLUSTER VERBOSE? (qualifiedName clusterIndexSpecification? | name ON
qualifiedName)?
+ : CLUSTER clusterVerboseSpecification? tableName?
clusterIndexSpecification?
+ ;
+
+clusterVerboseSpecification
+ : VERBOSE | clusterVerboseOptionList
;
clusterIndexSpecification
- : USING name
+ : USING indexName
+ ;
+
+clusterVerboseOptionList
+ : LP_ clusterVerboseOption (COMMA_ clusterVerboseOption)* RP_
+ ;
+
+clusterVerboseOption
+ : VERBOSE booleanValue?
+ ;
+
+booleanValue
+ : TRUE | ON | FALSE | OFF | NUMBER_
;
comment
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/org/apache/shardingsphere/sql/parser/autogen/PostgreSQLStatementParser.g4
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/org/apache/shardingsphere/sql/parser/autogen/PostgreSQLStatementParser.g4
index 94a03cf2e21..de392746b50 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/org/apache/shardingsphere/sql/parser/autogen/PostgreSQLStatementParser.g4
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-dialect/shardingsphere-sql-parser-postgresql/src/main/antlr4/org/apache/shardingsphere/sql/parser/autogen/PostgreSQLStatementParser.g4
@@ -146,5 +146,6 @@ execute
| dropServer
| checkpoint
| close
+ | cluster
) SEMI_? EOF
;
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/PostgreSQLDDLStatementSQLVisitor.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/PostgreSQLDDLStatementSQLVisitor.java
index 0cb2e70299e..6fe678199e6 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/PostgreSQLDDLStatementSQLVisitor.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/PostgreSQLDDLStatementSQLVisitor.java
@@ -49,6 +49,7 @@ import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.Al
import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.AlterTextSearchTemplateContext;
import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.AlterViewContext;
import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.CloseContext;
+import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.ClusterContext;
import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.ColumnConstraintContext;
import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.ColumnDefinitionContext;
import
org.apache.shardingsphere.sql.parser.autogen.PostgreSQLStatementParser.CommentContext;
@@ -179,6 +180,7 @@ import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLAlterTextSearchStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLAlterViewStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLCloseStatement;
+import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLClusterStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLCommentStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLCreateConversionStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLCreateDatabaseStatement;
@@ -1042,4 +1044,16 @@ public final class PostgreSQLDDLStatementSQLVisitor
extends PostgreSQLStatementS
public ASTNode visitCursorName(final CursorNameContext ctx) {
return new CursorNameSegment(ctx.start.getStartIndex(),
ctx.stop.getStopIndex(), (IdentifierValue) visit(ctx.name()));
}
+
+ @Override
+ public ASTNode visitCluster(final ClusterContext ctx) {
+ PostgreSQLClusterStatement result = new PostgreSQLClusterStatement();
+ if (null != ctx.tableName()) {
+ result.setTable((SimpleTableSegment) visit(ctx.tableName()));
+ }
+ if (null != ctx.clusterIndexSpecification()) {
+ result.setIndex((IndexSegment)
visit(ctx.clusterIndexSpecification().indexName()));
+ }
+ return result;
+ }
}
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/main/java/org/apache/shardingsphere/sql/parser/core/database/visitor/SQLVisitorRule.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/main/java/org/apache/shardingsphere/sql/parser/core/database/visitor/SQLVisitorRule.java
index 0a4789fcf21..5dd05014730 100644
---
a/shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/main/java/org/apache/shardingsphere/sql/parser/core/database/visitor/SQLVisitorRule.java
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-engine/src/main/java/org/apache/shardingsphere/sql/parser/core/database/visitor/SQLVisitorRule.java
@@ -544,7 +544,9 @@ public enum SQLVisitorRule {
FETCH("Fetch", SQLStatementType.DDL),
- CHECKPOINT("Checkpoint", SQLStatementType.DML);
+ CHECKPOINT("Checkpoint", SQLStatementType.DML),
+
+ CLUSTER("Cluster", SQLStatementType.DDL);
private final String name;
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/ClusterStatement.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/ClusterStatement.java
new file mode 100644
index 00000000000..24830b19573
--- /dev/null
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/common/statement/ddl/ClusterStatement.java
@@ -0,0 +1,28 @@
+/*
+ * 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.sql.common.statement.ddl;
+
+import lombok.ToString;
+import
org.apache.shardingsphere.sql.parser.sql.common.statement.AbstractSQLStatement;
+
+/**
+ * Cluster statement.
+ */
+@ToString
+public abstract class ClusterStatement extends AbstractSQLStatement implements
DDLStatement {
+}
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/handler/ddl/ClusterStatementHandler.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/handler/ddl/ClusterStatementHandler.java
new file mode 100644
index 00000000000..368f47b6bc6
--- /dev/null
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/handler/ddl/ClusterStatementHandler.java
@@ -0,0 +1,62 @@
+/*
+ * 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.sql.dialect.handler.ddl;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.ddl.index.IndexSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.table.SimpleTableSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.ClusterStatement;
+import
org.apache.shardingsphere.sql.parser.sql.dialect.handler.SQLStatementHandler;
+import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.PostgreSQLStatement;
+import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.ddl.PostgreSQLClusterStatement;
+
+import java.util.Optional;
+
+/**
+ * Cluster statement handler for different dialect SQLStatements.
+ */
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public final class ClusterStatementHandler implements SQLStatementHandler {
+
+ /**
+ * Get simple table segment.
+ *
+ * @param clusterStatement cluster statement
+ * @return simple table segment
+ */
+ public static Optional<SimpleTableSegment> getSimpleTableSegment(final
ClusterStatement clusterStatement) {
+ if (clusterStatement instanceof PostgreSQLStatement) {
+ return ((PostgreSQLClusterStatement) clusterStatement).getTable();
+ }
+ return Optional.empty();
+ }
+
+ /**
+ * Get index segment.
+ *
+ * @param clusterStatement cluster statement
+ * @return index segment
+ */
+ public static Optional<IndexSegment> getIndexSegment(final
ClusterStatement clusterStatement) {
+ if (clusterStatement instanceof PostgreSQLStatement) {
+ return ((PostgreSQLClusterStatement) clusterStatement).getIndex();
+ }
+ return Optional.empty();
+ }
+}
diff --git
a/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/ddl/PostgreSQLClusterStatement.java
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/ddl/PostgreSQLClusterStatement.java
new file mode 100644
index 00000000000..682290d3606
--- /dev/null
+++
b/shardingsphere-sql-parser/shardingsphere-sql-parser-statement/src/main/java/org/apache/shardingsphere/sql/parser/sql/dialect/statement/postgresql/ddl/PostgreSQLClusterStatement.java
@@ -0,0 +1,59 @@
+/*
+ * 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.sql.dialect.statement.postgresql.ddl;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.ddl.index.IndexSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.table.SimpleTableSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.ClusterStatement;
+import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.postgresql.PostgreSQLStatement;
+
+import java.util.Optional;
+
+/**
+ * PostgreSQL cluster statement.
+ */
+@ToString
+@Getter
+@Setter
+public final class PostgreSQLClusterStatement extends ClusterStatement
implements PostgreSQLStatement {
+
+ private SimpleTableSegment table;
+
+ private IndexSegment index;
+
+ /**
+ * Get simple table segment.
+ *
+ * @return simple table segment
+ */
+ public Optional<SimpleTableSegment> getTable() {
+ return Optional.ofNullable(table);
+ }
+
+ /**
+ * Get index segment.
+ *
+ * @return index segment
+ */
+ public Optional<IndexSegment> getIndex() {
+ return Optional.ofNullable(index);
+ }
+}
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/DDLStatementAssert.java
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/DDLStatementAssert.java
index d5217b696d9..b3f1b660971 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/DDLStatementAssert.java
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/DDLStatementAssert.java
@@ -22,6 +22,8 @@ import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterIndexStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterSystemStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.AlterTableStatement;
+import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CloseStatement;
+import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.ClusterStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateIndexStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.CreateTableStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DDLStatement;
@@ -29,7 +31,6 @@ import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DropIndexSt
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.DropTableStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.RenameTableStatement;
import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.TruncateStatement;
-import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.opengauss.ddl.OpenGaussCloseStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.opengauss.ddl.OpenGaussCursorStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.opengauss.ddl.OpenGaussFetchStatement;
import
org.apache.shardingsphere.sql.parser.sql.dialect.statement.opengauss.ddl.OpenGaussMoveStatement;
@@ -50,6 +51,7 @@ import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement
import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.AssociateStatisticsStatementAssert;
import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.AuditStatementAssert;
import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.CloseStatementAssert;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.ClusterStatementAssert;
import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.CreateIndexStatementAssert;
import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.CreateTableStatementAssert;
import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.statement.ddl.impl.CursorStatementAssert;
@@ -71,6 +73,7 @@ import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.AssociateStatisticsStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.AuditStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CloseStatementTestCase;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.ClusterStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CreateIndexStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CreateTableStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CursorStatementTestCase;
@@ -131,12 +134,14 @@ public final class DDLStatementAssert {
NoAuditStatementAssert.assertIs(assertContext,
(OracleNoAuditStatement) actual, (NoAuditStatementTestCase) expected);
} else if (actual instanceof OpenGaussCursorStatement) {
CursorStatementAssert.assertIs(assertContext,
(OpenGaussCursorStatement) actual, (CursorStatementTestCase) expected);
- } else if (actual instanceof OpenGaussCloseStatement) {
- CloseStatementAssert.assertIs(assertContext,
(OpenGaussCloseStatement) actual, (CloseStatementTestCase) expected);
+ } else if (actual instanceof CloseStatement) {
+ CloseStatementAssert.assertIs(assertContext, (CloseStatement)
actual, (CloseStatementTestCase) expected);
} else if (actual instanceof OpenGaussMoveStatement) {
MoveStatementAssert.assertIs(assertContext,
(OpenGaussMoveStatement) actual, (MoveStatementTestCase) expected);
} else if (actual instanceof OpenGaussFetchStatement) {
FetchStatementAssert.assertIs(assertContext,
(OpenGaussFetchStatement) actual, (FetchStatementTestCase) expected);
+ } else if (actual instanceof ClusterStatement) {
+ ClusterStatementAssert.assertIs(assertContext, (ClusterStatement)
actual, (ClusterStatementTestCase) expected);
}
}
}
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/impl/ClusterStatementAssert.java
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/impl/ClusterStatementAssert.java
new file mode 100644
index 00000000000..a1cc3ce8d9a
--- /dev/null
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/asserts/statement/ddl/impl/ClusterStatementAssert.java
@@ -0,0 +1,73 @@
+/*
+ * 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.test.sql.parser.parameterized.asserts.statement.ddl.impl;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.ddl.index.IndexSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.segment.generic.table.SimpleTableSegment;
+import
org.apache.shardingsphere.sql.parser.sql.common.statement.ddl.ClusterStatement;
+import
org.apache.shardingsphere.sql.parser.sql.dialect.handler.ddl.ClusterStatementHandler;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.SQLCaseAssertContext;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.segment.index.IndexAssert;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.asserts.segment.table.TableAssert;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.ClusterStatementTestCase;
+
+import java.util.Optional;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+/**
+ * Cluster statement assert.
+ */
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public final class ClusterStatementAssert {
+
+ /**
+ * Assert cluster statement is correct with expected parser result.
+ *
+ * @param assertContext assert context
+ * @param actual actual cluster statement
+ * @param expected expected cluster statement test case
+ */
+ public static void assertIs(final SQLCaseAssertContext assertContext,
final ClusterStatement actual, final ClusterStatementTestCase expected) {
+ assertTable(assertContext, actual, expected);
+ assertIndex(assertContext, actual, expected);
+ }
+
+ private static void assertTable(final SQLCaseAssertContext assertContext,
final ClusterStatement actual, final ClusterStatementTestCase expected) {
+ Optional<SimpleTableSegment> tableSegment =
ClusterStatementHandler.getSimpleTableSegment(actual);
+ if (null != expected.getTable()) {
+ assertTrue(assertContext.getText("Actual table segment should
exist."), tableSegment.isPresent());
+ TableAssert.assertIs(assertContext, tableSegment.get(),
expected.getTable());
+ } else {
+ assertFalse(assertContext.getText("Actual table segment should not
exist."), tableSegment.isPresent());
+ }
+ }
+
+ private static void assertIndex(final SQLCaseAssertContext assertContext,
final ClusterStatement actual, final ClusterStatementTestCase expected) {
+ Optional<IndexSegment> indexSegment =
ClusterStatementHandler.getIndexSegment(actual);
+ if (null != expected.getIndex()) {
+ assertTrue(assertContext.getText("Actual index segment should
exist."), indexSegment.isPresent());
+ IndexAssert.assertIs(assertContext, indexSegment.get(),
expected.getIndex());
+ } else {
+ assertFalse(assertContext.getText("Actual index segment should not
exist."), indexSegment.isPresent());
+ }
+ }
+}
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/SQLParserTestCases.java
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/SQLParserTestCases.java
index 12ac77e5e43..5509f99b706 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/SQLParserTestCases.java
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/SQLParserTestCases.java
@@ -130,6 +130,7 @@ import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.AssociateStatisticsStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.AuditStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CloseStatementTestCase;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.ClusterStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CommentStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CreateContextStatementTestCase;
import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl.CreateConversionStatementTestCase;
@@ -1408,6 +1409,9 @@ public final class SQLParserTestCases {
@XmlElement(name = "checkpoint")
private final List<CheckpointStatementTestCase> checkpointTestCases = new
LinkedList<>();
+ @XmlElement(name = "cluster")
+ private final List<ClusterStatementTestCase> clusterStatementTestCases =
new LinkedList<>();
+
/**
* Get all SQL parser test cases.
*
@@ -1759,6 +1763,7 @@ public final class SQLParserTestCases {
putAll(moveTestCases, result);
putAll(fetchTestCases, result);
putAll(checkpointTestCases, result);
+ putAll(clusterStatementTestCases, result);
return result;
}
// CHECKSTYLE:ON
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/ddl/ClusterStatementTestCase.java
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/ddl/ClusterStatementTestCase.java
new file mode 100644
index 00000000000..a74805248d6
--- /dev/null
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/java/org/apache/shardingsphere/test/sql/parser/parameterized/jaxb/cases/domain/statement/ddl/ClusterStatementTestCase.java
@@ -0,0 +1,40 @@
+/*
+ * 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.test.sql.parser.parameterized.jaxb.cases.domain.statement.ddl;
+
+import lombok.Getter;
+import lombok.Setter;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.segment.impl.index.ExpectedIndex;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.segment.impl.table.ExpectedSimpleTable;
+import
org.apache.shardingsphere.test.sql.parser.parameterized.jaxb.cases.domain.statement.SQLParserTestCase;
+
+import javax.xml.bind.annotation.XmlElement;
+
+/**
+ * Cluster statement test case.
+ */
+@Getter
+@Setter
+public final class ClusterStatementTestCase extends SQLParserTestCase {
+
+ @XmlElement(name = "table")
+ private ExpectedSimpleTable table;
+
+ @XmlElement(name = "index")
+ private ExpectedIndex index;
+}
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/ddl/cluster.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/ddl/cluster.xml
new file mode 100644
index 00000000000..62f3f9de990
--- /dev/null
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/ddl/cluster.xml
@@ -0,0 +1,30 @@
+<?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.
+ -->
+
+<sql-parser-test-cases>
+ <cluster sql-case-id="cluster_table_using_index">
+ <table name="abbrev_abort_uuids" start-index="8" stop-index="25" />
+ <index name="abbrev_abort_uuids__abort_decreasing_idx"
start-index="33" stop-index="72" />
+ </cluster>
+
+ <cluster sql-case-id="cluster_table">
+ <table name="clstr_1" start-index="8" stop-index="14" />
+ </cluster>
+
+ <cluster sql-case-id="cluster"/>
+</sql-parser-test-cases>
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/ddl/cluster.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/ddl/cluster.xml
new file mode 100644
index 00000000000..6bd5b0b36e8
--- /dev/null
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/ddl/cluster.xml
@@ -0,0 +1,23 @@
+<?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.
+ -->
+
+<sql-cases>
+ <sql-case id="cluster_table_using_index" value="CLUSTER abbrev_abort_uuids
USING abbrev_abort_uuids__abort_decreasing_idx;" db-types="PostgreSQL" />
+ <sql-case id="cluster_table" value="CLUSTER clstr_1;"
db-types="PostgreSQL" />
+ <sql-case id="cluster" value="CLUSTER;" db-types="PostgreSQL" />
+</sql-cases>
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/unsupported/unsupported.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/unsupported/unsupported.xml
index 4910b946583..1bff962f345 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/unsupported/unsupported.xml
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/unsupported/unsupported.xml
@@ -4202,24 +4202,6 @@
<sql-case id="alter_by_postgresql_source_test_case459" value="ALTER TYPE
test_typex DROP ATTRIBUTE a;" db-types="PostgreSQL" />
<sql-case id="alter_by_postgresql_source_test_case460" value="ALTER TYPE
tt_t0 DROP ATTRIBUTE z;" db-types="PostgreSQL" />
<sql-case id="analyze_by_postgresql_source_test_case1" value="ANALYZE
(nonexistent-arg) does_not_exist;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case1" value="CLUSTER
abbrev_abort_uuids USING abbrev_abort_uuids__abort_decreasing_idx;"
db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case2" value="CLUSTER
abbrev_abort_uuids USING abbrev_abort_uuids__abort_increasing_idx;"
db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case3" value="CLUSTER
abbrev_abort_uuids USING abbrev_abort_uuids__noabort_decreasing_idx;"
db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case4" value="CLUSTER
abbrev_abort_uuids USING abbrev_abort_uuids__noabort_increasing_idx;"
db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case5" value="CLUSTER
clstr_1;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case6" value="CLUSTER
clstr_1_pkey ON clstr_1;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case7" value="CLUSTER
clstr_2 USING clstr_2_pkey;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case8" value="CLUSTER
clstr_2;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case9" value="CLUSTER
clstr_expression USING clstr_expression_minus_a;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case10" value="CLUSTER
clstr_expression USING clstr_expression_upper_b;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case11" value="CLUSTER
clstr_tst_c ON clstr_tst;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case12" value="CLUSTER
clstrpart USING clstrpart_idx;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case13" value="CLUSTER
clustertest USING clustertest_pkey;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case14" value="CLUSTER
clustertest;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case15" value="CLUSTER
clustertest_pkey ON clustertest;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case16" value="CLUSTER hs2
using hs1_pkey;" db-types="PostgreSQL" />
- <sql-case id="cluster_by_postgresql_source_test_case17" value="CLUSTER
vaccluster;" db-types="PostgreSQL" />
- <sql-case id="cluster;_by_postgresql_source_test_case1" value="CLUSTER;"
db-types="PostgreSQL" />
<sql-case id="copy_by_postgresql_source_test_case1" value="COPY testnull
FROM stdin WITH NULL AS E'\\0';" db-types="PostgreSQL" />
<sql-case id="copy_by_postgresql_source_test_case2" value="COPY testnull
TO stdout WITH NULL AS E'\\0';" db-types="PostgreSQL" />
<sql-case id="copy_by_postgresql_source_test_case3" value="COPY x from
stdin WITH DELIMITER AS ':' NULL AS E'\\X' ENCODING
'sql_ascii';" db-types="PostgreSQL" />
@@ -7145,8 +7127,6 @@
<sql-case id="low_alter_by_postgresql_source_test_case105" value="alter
type rewritetype alter attribute a type varchar cascade;" db-types="PostgreSQL"
/>
<sql-case id="low_alter_by_postgresql_source_test_case106" value="alter
type testdomain2 rename to testdomain3;" db-types="PostgreSQL" />
<sql-case id="low_alter_by_postgresql_source_test_case107" value="alter
type two_ints add attribute c two_ints_range;" db-types="PostgreSQL" />
- <sql-case id="low_cluster_by_postgresql_source_test_case1" value="cluster
clstr_4 using cluster_sort;" db-types="PostgreSQL" />
- <sql-case id="low_cluster_by_postgresql_source_test_case2" value="cluster
clstr_temp using clstr_temp_pkey;" db-types="PostgreSQL" />
<sql-case id="low_copy_by_postgresql_source_test_case1" value="copy
(select * from test1) (t,id) to stdout;" db-types="PostgreSQL" />
<sql-case id="low_copy_by_postgresql_source_test_case2" value="copy
(select * from test1) from stdin;" db-types="PostgreSQL" />
<sql-case id="low_copy_by_postgresql_source_test_case3" value="copy
(select 1) to stdout\; copy (select 2) to stdout\; select 0\; select 3;"
db-types="PostgreSQL" />
