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 97105dfef1d Add shardingsphere-data-pipeline-cdc-distsql module
(#36051)
97105dfef1d is described below
commit 97105dfef1d1d534db2c81f86c8cd0f482329229
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Jul 22 09:05:26 2025 +0800
Add shardingsphere-data-pipeline-cdc-distsql module (#36051)
* Add shardingsphere-data-pipeline-cdc-distsql module
* Add shardingsphere-data-pipeline-cdc-distsql module
* Add shardingsphere-data-pipeline-cdc-distsql module
---
...stsql.handler.engine.query.DistSQLQueryExecutor | 3 -
...sql.handler.engine.update.DistSQLUpdateExecutor | 1 -
...e.distsql.parser.engine.spi.DistSQLParserFacade | 1 -
.../scenario/cdc/{ => distsql/handler}/pom.xml | 27 +++++--
.../cdc/query/ShowStreamingJobStatusExecutor.java | 0
.../cdc/query/ShowStreamingListExecutor.java | 0
.../cdc/query/ShowStreamingRuleExecutor.java | 0
.../handler/cdc/update/DropStreamingExecutor.java | 0
...tsql.handler.engine.query.DistSQLQueryExecutor} | 5 +-
...ql.handler.engine.update.DistSQLUpdateExecutor} | 3 +-
.../scenario/cdc/distsql/parser/pom.xml | 91 ++++++++++++++++++++++
.../distsql/parser/autogen/CDCDistSQLStatement.g4 | 0
.../src/main/antlr4/imports/cdc/Alphabet.g4} | 39 +++++++---
.../src/main/antlr4/imports/cdc/BaseRule.g4} | 45 ++++++++---
.../parser/src/main/antlr4/imports/cdc/Keyword.g4} | 81 ++++++++++++++++---
.../src/main/antlr4/imports/cdc/Literals.g4} | 23 +++---
.../src/main/antlr4/imports/cdc/RALStatement.g4 | 76 ++++++++++++++++++
.../parser/src/main/antlr4/imports/cdc/Symbol.g4 | 62 +++++++++++++++
.../cdc/distsql/parser/core/CDCDistSQLLexer.java | 0
.../cdc/distsql/parser/core/CDCDistSQLParser.java | 2 +-
.../parser/core/CDCDistSQLStatementVisitor.java | 0
.../parser/facade/CDCDistSQLParserFacade.java | 0
...e.distsql.parser.engine.spi.DistSQLParserFacade | 1 -
.../scenario/cdc/{ => distsql}/pom.xml | 10 +--
.../scenario/cdc/{ => distsql/statement}/pom.xml | 17 ++--
.../cdc/distsql/statement/CDCRALStatement.java | 0
.../queryable/QueryableCDCRALStatement.java | 0
.../queryable/ShowStreamingListStatement.java | 0
.../queryable/ShowStreamingRuleStatement.java | 0
.../queryable/ShowStreamingStatusStatement.java | 0
.../updatable/DropStreamingStatement.java | 0
.../updatable/UpdatableCDCRALStatement.java | 0
kernel/data-pipeline/scenario/cdc/pom.xml | 1 +
proxy/backend/core/pom.xml | 2 +-
test/it/parser/pom.xml | 7 +-
35 files changed, 421 insertions(+), 76 deletions(-)
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
index d20d3fa9ed8..a6035b1a9b9 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
+++
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
@@ -20,6 +20,3 @@
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.query.ShowMigr
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.query.ShowMigrationJobStatusExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.query.ShowMigrationCheckStatusExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.query.ShowMigrationSourceStorageUnitsExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.query.ShowStreamingListExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.query.ShowStreamingJobStatusExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.query.ShowStreamingRuleExecutor
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
index f7415152fde..3ccd33ff3f8 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
+++
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
@@ -27,4 +27,3 @@
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.CheckMi
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StartMigrationCheckExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StopMigrationCheckExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.DropMigrationCheckExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.update.DropStreamingExecutor
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
b/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
index 3a7c6af2d33..387a141ecb7 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
+++
b/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
@@ -16,4 +16,3 @@
#
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.facade.MigrationDistSQLParserFacade
-org.apache.shardingsphere.data.pipeline.cdc.distsql.parser.facade.CDCDistSQLParserFacade
diff --git a/kernel/data-pipeline/scenario/cdc/pom.xml
b/kernel/data-pipeline/scenario/cdc/distsql/handler/pom.xml
similarity index 59%
copy from kernel/data-pipeline/scenario/cdc/pom.xml
copy to kernel/data-pipeline/scenario/cdc/distsql/handler/pom.xml
index 8895bf872d9..a3ab9e8b934 100644
--- a/kernel/data-pipeline/scenario/cdc/pom.xml
+++ b/kernel/data-pipeline/scenario/cdc/distsql/handler/pom.xml
@@ -20,16 +20,27 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-scenario</artifactId>
+ <artifactId>shardingsphere-data-pipeline-cdc-distsql</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-cdc</artifactId>
- <packaging>pom</packaging>
+ <artifactId>shardingsphere-data-pipeline-cdc-distsql-handler</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>protocol</module>
- <module>core</module>
- <module>client</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+
<artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+
<artifactId>shardingsphere-data-pipeline-cdc-distsql-parser</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-data-pipeline-cdc-core</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingJobStatusExecutor.java
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingJobStatusExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingJobStatusExecutor.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingJobStatusExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingListExecutor.java
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingListExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingListExecutor.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingListExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingRuleExecutor.java
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingRuleExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingRuleExecutor.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/query/ShowStreamingRuleExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/update/DropStreamingExecutor.java
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/update/DropStreamingExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/update/DropStreamingExecutor.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/cdc/update/DropStreamingExecutor.java
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
similarity index 73%
copy from
kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
copy to
kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
index 3a7c6af2d33..5b2986fa6ec 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
+++
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
@@ -15,5 +15,6 @@
# limitations under the License.
#
-org.apache.shardingsphere.data.pipeline.migration.distsql.parser.facade.MigrationDistSQLParserFacade
-org.apache.shardingsphere.data.pipeline.cdc.distsql.parser.facade.CDCDistSQLParserFacade
+org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.query.ShowStreamingListExecutor
+org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.query.ShowStreamingJobStatusExecutor
+org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.query.ShowStreamingRuleExecutor
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
similarity index 80%
copy from
kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
copy to
kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
index 3a7c6af2d33..6b7eea7d919 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
+++
b/kernel/data-pipeline/scenario/cdc/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
@@ -15,5 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.data.pipeline.migration.distsql.parser.facade.MigrationDistSQLParserFacade
-org.apache.shardingsphere.data.pipeline.cdc.distsql.parser.facade.CDCDistSQLParserFacade
+org.apache.shardingsphere.data.pipeline.distsql.handler.cdc.update.DropStreamingExecutor
diff --git a/kernel/data-pipeline/scenario/cdc/distsql/parser/pom.xml
b/kernel/data-pipeline/scenario/cdc/distsql/parser/pom.xml
new file mode 100644
index 00000000000..d398a9510bb
--- /dev/null
+++ b/kernel/data-pipeline/scenario/cdc/distsql/parser/pom.xml
@@ -0,0 +1,91 @@
+<?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-data-pipeline-cdc-distsql</artifactId>
+ <version>5.5.3-SNAPSHOT</version>
+ </parent>
+ <artifactId>shardingsphere-data-pipeline-cdc-distsql-parser</artifactId>
+ <name>${project.artifactId}</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-parser-sql-spi</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-parser-distsql-engine</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+
<artifactId>shardingsphere-data-pipeline-cdc-distsql-statement</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+
+ <profiles>
+ <profile>
+ <id>jdk8</id>
+ <activation>
+ <jdk>1.8</jdk>
+ </activation>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.codehaus.mojo</groupId>
+ <artifactId>build-helper-maven-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ <profile>
+ <id>jdk11+</id>
+ <activation>
+ <jdk>[11,)</jdk>
+ </activation>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.antlr</groupId>
+ <artifactId>antlr4-maven-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>antlr</id>
+ <goals>
+ <goal>antlr4</goal>
+ </goals>
+ <configuration>
+
<sourceDirectory>src/main/antlr4/cdc/</sourceDirectory>
+
<libDirectory>src/main/antlr4/imports/cdc/</libDirectory>
+ <listener>false</listener>
+ <visitor>true</visitor>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
similarity index 100%
copy from
kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
copy to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Alphabet.g4
similarity index 56%
copy from
kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
copy to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Alphabet.g4
index aabf400687f..f7603cc7e63 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Alphabet.g4
@@ -15,15 +15,34 @@
* limitations under the License.
*/
-grammar CDCDistSQLStatement;
+lexer grammar Alphabet;
-import Symbol, RALStatement;
+FOR_GENERATOR: 'DO NOT MATCH ANY THING, JUST FOR GENERATOR';
-execute
- : (showStreamingList
- | showStreamingStatus
- | dropStreaming
- | showStreamingRule
- | alterStreamingRule
- ) SEMI_? EOF
- ;
+fragment A: [Aa];
+fragment B: [Bb];
+fragment C: [Cc];
+fragment D: [Dd];
+fragment E: [Ee];
+fragment F: [Ff];
+fragment G: [Gg];
+fragment H: [Hh];
+fragment I: [Ii];
+fragment J: [Jj];
+fragment K: [Kk];
+fragment L: [Ll];
+fragment M: [Mm];
+fragment N: [Nn];
+fragment O: [Oo];
+fragment P: [Pp];
+fragment Q: [Qq];
+fragment R: [Rr];
+fragment S: [Ss];
+fragment T: [Tt];
+fragment U: [Uu];
+fragment V: [Vv];
+fragment W: [Ww];
+fragment X: [Xx];
+fragment Y: [Yy];
+fragment Z: [Zz];
+fragment UL_: '_';
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/BaseRule.g4
similarity index 61%
copy from
kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
copy to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/BaseRule.g4
index aabf400687f..b7285f768da 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/BaseRule.g4
@@ -15,15 +15,42 @@
* limitations under the License.
*/
-grammar CDCDistSQLStatement;
+grammar BaseRule;
-import Symbol, RALStatement;
+import Symbol, Keyword, Literals;
-execute
- : (showStreamingList
- | showStreamingStatus
- | dropStreaming
- | showStreamingRule
- | alterStreamingRule
- ) SEMI_? EOF
+algorithmDefinition
+ : TYPE LP_ NAME EQ_ algorithmTypeName (COMMA_ propertiesDefinition)? RP_
+ ;
+
+algorithmTypeName
+ : STRING_
+ ;
+
+propertiesDefinition
+ : PROPERTIES LP_ properties? RP_
+ ;
+
+properties
+ : property (COMMA_ property)*
+ ;
+
+property
+ : key=STRING_ EQ_ value=literal
+ ;
+
+literal
+ : STRING_ | (MINUS_)? INT_ | TRUE | FALSE
+ ;
+
+TRUE
+ : T R U E
+ ;
+
+FALSE
+ : F A L S E
+ ;
+
+intValue
+ : INT_
;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Keyword.g4
similarity index 53%
copy from
kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
copy to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Keyword.g4
index aabf400687f..68bd46e9b4a 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Keyword.g4
@@ -15,15 +15,78 @@
* limitations under the License.
*/
-grammar CDCDistSQLStatement;
+lexer grammar Keyword;
-import Symbol, RALStatement;
+import Alphabet;
-execute
- : (showStreamingList
- | showStreamingStatus
- | dropStreaming
- | showStreamingRule
- | alterStreamingRule
- ) SEMI_? EOF
+WS
+ : [ \t\r\n] + ->skip
+ ;
+
+SHOW
+ : S H O W
+ ;
+
+STREAMING
+ : S T R E A M I N G
+ ;
+
+LIST
+ : L I S T
+ ;
+
+STATUS
+ : S T A T U S
+ ;
+
+DROP
+ : D R O P
+ ;
+
+TYPE
+ : T Y P E
+ ;
+
+NAME
+ : N A M E
+ ;
+
+PROPERTIES
+ : P R O P E R T I E S
+ ;
+
+ALTER
+ : A L T E R
+ ;
+
+RULE
+ : R U L E
+ ;
+
+READ
+ : R E A D
+ ;
+
+WORKER_THREAD
+ : W O R K E R UL_ T H R E A D
+ ;
+
+BATCH_SIZE
+ : B A T C H UL_ S I Z E
+ ;
+
+SHARDING_SIZE
+ : S H A R D I N G UL_ S I Z E
+ ;
+
+RATE_LIMITER
+ : R A T E UL_ L I M I T E R
+ ;
+
+STREAM_CHANNEL
+ : S T R E A M UL_ C H A N N E L
+ ;
+
+WRITE
+ : W R I T E
;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Literals.g4
similarity index 75%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
rename to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Literals.g4
index aabf400687f..68f6a1b07ed 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/cdc/org/apache/shardingsphere/distsql/parser/autogen/CDCDistSQLStatement.g4
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Literals.g4
@@ -15,15 +15,20 @@
* limitations under the License.
*/
-grammar CDCDistSQLStatement;
+lexer grammar Literals;
-import Symbol, RALStatement;
+import Alphabet, Symbol;
-execute
- : (showStreamingList
- | showStreamingStatus
- | dropStreaming
- | showStreamingRule
- | alterStreamingRule
- ) SEMI_? EOF
+IDENTIFIER_
+ : [A-Za-z_$0-9]*?[A-Za-z_$]+?[A-Za-z_$0-9]*
+ | BQ_ ~'`'+ BQ_
+ ;
+
+STRING_
+ : (DQ_ ('\\'. | '""' | ~('"' | '\\'))* DQ_)
+ | (SQ_ ('\\'. | '\'\'' | ~('\'' | '\\'))* SQ_)
+ ;
+
+INT_
+ : [0-9]+
;
diff --git
a/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/RALStatement.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/RALStatement.g4
new file mode 100644
index 00000000000..213747d09d7
--- /dev/null
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/RALStatement.g4
@@ -0,0 +1,76 @@
+/*
+ * 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.
+ */
+
+grammar RALStatement;
+
+import BaseRule;
+
+showStreamingRule
+ : SHOW STREAMING RULE
+ ;
+
+alterStreamingRule
+ : ALTER STREAMING RULE transmissionRule
+ ;
+
+transmissionRule
+ : LP_ readDefinition? (COMMA_? writeDefinition)? (COMMA_? streamChannel)?
RP_
+ ;
+
+readDefinition
+ : READ LP_ workerThread? (COMMA_? batchSize)? (COMMA_? shardingSize)?
(COMMA_? rateLimiter)? RP_
+ ;
+
+writeDefinition
+ : WRITE LP_ workerThread? (COMMA_? batchSize)? (COMMA_? rateLimiter)? RP_
+ ;
+
+workerThread
+ : WORKER_THREAD EQ_ intValue
+ ;
+
+batchSize
+ : BATCH_SIZE EQ_ intValue
+ ;
+
+shardingSize
+ : SHARDING_SIZE EQ_ intValue
+ ;
+
+rateLimiter
+ : RATE_LIMITER LP_ algorithmDefinition RP_
+ ;
+
+streamChannel
+ : STREAM_CHANNEL LP_ algorithmDefinition RP_
+ ;
+
+showStreamingList
+ : SHOW STREAMING LIST
+ ;
+
+showStreamingStatus
+ : SHOW STREAMING STATUS jobId
+ ;
+
+dropStreaming
+ : DROP STREAMING jobId
+ ;
+
+jobId
+ : INT_ | IDENTIFIER_ | STRING_
+ ;
diff --git
a/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Symbol.g4
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Symbol.g4
new file mode 100644
index 00000000000..1da7901ec98
--- /dev/null
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/antlr4/imports/cdc/Symbol.g4
@@ -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.
+ */
+
+lexer grammar Symbol;
+
+AND_: '&&';
+OR_: '||';
+NOT_: '!';
+TILDE_: '~';
+VERTICALBAR_: '|';
+AMPERSAND_: '&';
+SIGNEDLEFTSHIFT_: '<<';
+SIGNEDRIGHTSHIFT_: '>>';
+CARET_: '^';
+MOD_: '%';
+COLON_: ':';
+PLUS_: '+';
+MINUS_: '-';
+ASTERISK_: '*';
+SLASH_: '/';
+BACKSLASH_: '\\';
+DOT_: '.';
+DOTASTERISK_: '.*';
+SAFEEQ_: '<=>';
+DEQ_: '==';
+EQ_: '=';
+NEQ_: '<>' | '!=';
+GT_: '>';
+GTE_: '>=';
+LT_: '<';
+LTE_: '<=';
+POUND_: '#';
+LP_: '(';
+RP_: ')';
+LBE_: '{';
+RBE_: '}';
+LBT_: '[';
+RBT_: ']';
+COMMA_: ',';
+DQ_: '"';
+SQ_: '\'';
+BQ_: '`';
+QUESTION_: '?';
+AT_: '@';
+SEMI_: ';';
+JSONSEPARATOR_: '->>';
+UL_: '_';
+DL_: '$';
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLLexer.java
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLLexer.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLLexer.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLLexer.java
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLParser.java
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLParser.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLParser.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLParser.java
index 24f2dfe17c5..4deb564a2ab 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLParser.java
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLParser.java
@@ -20,8 +20,8 @@ package
org.apache.shardingsphere.data.pipeline.cdc.distsql.parser.core;
import org.antlr.v4.runtime.CommonTokenStream;
import org.antlr.v4.runtime.TokenStream;
import
org.apache.shardingsphere.distsql.parser.autogen.CDCDistSQLStatementParser;
-import org.apache.shardingsphere.sql.parser.api.parser.SQLParser;
import org.apache.shardingsphere.sql.parser.api.ASTNode;
+import org.apache.shardingsphere.sql.parser.api.parser.SQLParser;
import org.apache.shardingsphere.sql.parser.core.ParseASTNode;
/**
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/facade/CDCDistSQLParserFacade.java
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/facade/CDCDistSQLParserFacade.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/facade/CDCDistSQLParserFacade.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/facade/CDCDistSQLParserFacade.java
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
similarity index 89%
copy from
kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
copy to
kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
index 3a7c6af2d33..f94a31ac6a6 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
+++
b/kernel/data-pipeline/scenario/cdc/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
@@ -15,5 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.data.pipeline.migration.distsql.parser.facade.MigrationDistSQLParserFacade
org.apache.shardingsphere.data.pipeline.cdc.distsql.parser.facade.CDCDistSQLParserFacade
diff --git a/kernel/data-pipeline/scenario/cdc/pom.xml
b/kernel/data-pipeline/scenario/cdc/distsql/pom.xml
similarity index 85%
copy from kernel/data-pipeline/scenario/cdc/pom.xml
copy to kernel/data-pipeline/scenario/cdc/distsql/pom.xml
index 8895bf872d9..5b0f8ae4ba6 100644
--- a/kernel/data-pipeline/scenario/cdc/pom.xml
+++ b/kernel/data-pipeline/scenario/cdc/distsql/pom.xml
@@ -20,16 +20,16 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-scenario</artifactId>
+ <artifactId>shardingsphere-data-pipeline-cdc</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-cdc</artifactId>
+ <artifactId>shardingsphere-data-pipeline-cdc-distsql</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<modules>
- <module>protocol</module>
- <module>core</module>
- <module>client</module>
+ <module>statement</module>
+ <module>parser</module>
+ <module>handler</module>
</modules>
</project>
diff --git a/kernel/data-pipeline/scenario/cdc/pom.xml
b/kernel/data-pipeline/scenario/cdc/distsql/statement/pom.xml
similarity index 75%
copy from kernel/data-pipeline/scenario/cdc/pom.xml
copy to kernel/data-pipeline/scenario/cdc/distsql/statement/pom.xml
index 8895bf872d9..f1c1e41bc16 100644
--- a/kernel/data-pipeline/scenario/cdc/pom.xml
+++ b/kernel/data-pipeline/scenario/cdc/distsql/statement/pom.xml
@@ -20,16 +20,17 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-scenario</artifactId>
+ <artifactId>shardingsphere-data-pipeline-cdc-distsql</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-cdc</artifactId>
- <packaging>pom</packaging>
+ <artifactId>shardingsphere-data-pipeline-cdc-distsql-statement</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>protocol</module>
- <module>core</module>
- <module>client</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/CDCRALStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/CDCRALStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/CDCRALStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/CDCRALStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/QueryableCDCRALStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/QueryableCDCRALStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/QueryableCDCRALStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/QueryableCDCRALStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingListStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingListStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingListStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingListStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingRuleStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingRuleStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingRuleStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingRuleStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingStatusStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingStatusStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingStatusStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/queryable/ShowStreamingStatusStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/DropStreamingStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/DropStreamingStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/DropStreamingStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/DropStreamingStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/UpdatableCDCRALStatement.java
b/kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/UpdatableCDCRALStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/UpdatableCDCRALStatement.java
rename to
kernel/data-pipeline/scenario/cdc/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/statement/updatable/UpdatableCDCRALStatement.java
diff --git a/kernel/data-pipeline/scenario/cdc/pom.xml
b/kernel/data-pipeline/scenario/cdc/pom.xml
index 8895bf872d9..41f25c750f2 100644
--- a/kernel/data-pipeline/scenario/cdc/pom.xml
+++ b/kernel/data-pipeline/scenario/cdc/pom.xml
@@ -31,5 +31,6 @@
<module>protocol</module>
<module>core</module>
<module>client</module>
+ <module>distsql</module>
</modules>
</project>
diff --git a/proxy/backend/core/pom.xml b/proxy/backend/core/pom.xml
index 166b6d6f39c..2e8004bff12 100644
--- a/proxy/backend/core/pom.xml
+++ b/proxy/backend/core/pom.xml
@@ -119,7 +119,7 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-cdc-core</artifactId>
+
<artifactId>shardingsphere-data-pipeline-cdc-distsql-handler</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
diff --git a/test/it/parser/pom.xml b/test/it/parser/pom.xml
index 2b46ac060a9..cb69fbfcc08 100644
--- a/test/it/parser/pom.xml
+++ b/test/it/parser/pom.xml
@@ -36,11 +36,6 @@
<artifactId>shardingsphere-parser-sql-engine</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
@@ -48,7 +43,7 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-parser-distsql-engine</artifactId>
+
<artifactId>shardingsphere-data-pipeline-cdc-distsql-parser</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
