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 ea9d138040e Add more test cases on CDCDistSQLStatementVisitor (#37417)
ea9d138040e is described below
commit ea9d138040e3eee3b2684aa62142e91b06b35b1c
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Dec 17 23:53:40 2025 +0800
Add more test cases on CDCDistSQLStatementVisitor (#37417)
---
test/it/parser/src/main/resources/case/ral/cdc.xml | 18 ++++++++++++++++++
.../src/main/resources/sql/supported/ral/cdc.xml | 2 ++
2 files changed, 20 insertions(+)
diff --git a/test/it/parser/src/main/resources/case/ral/cdc.xml
b/test/it/parser/src/main/resources/case/ral/cdc.xml
index 35df1528745..2e15c116567 100644
--- a/test/it/parser/src/main/resources/case/ral/cdc.xml
+++ b/test/it/parser/src/main/resources/case/ral/cdc.xml
@@ -45,6 +45,24 @@
</rule>
</alter-streaming-rule>
+ <alter-streaming-rule sql-case-id="alter-streaming-rule-read-lite">
+ <job-type-name>STREAMING</job-type-name>
+ <rule>
+ <read>
+ <rate-limiter algorithm-name="QPS" />
+ </read>
+ </rule>
+ </alter-streaming-rule>
+
+ <alter-streaming-rule sql-case-id="alter-streaming-rule-write-lite">
+ <job-type-name>STREAMING</job-type-name>
+ <rule>
+ <write>
+ <rate-limiter algorithm-name="TPS" />
+ </write>
+ </rule>
+ </alter-streaming-rule>
+
<show-streaming-list sql-case-id="show-streaming-list" />
<show-streaming-status sql-case-id="show-streaming-status">
diff --git a/test/it/parser/src/main/resources/sql/supported/ral/cdc.xml
b/test/it/parser/src/main/resources/sql/supported/ral/cdc.xml
index 91a7680418e..b055bbf9be6 100644
--- a/test/it/parser/src/main/resources/sql/supported/ral/cdc.xml
+++ b/test/it/parser/src/main/resources/sql/supported/ral/cdc.xml
@@ -19,6 +19,8 @@
<sql-cases>
<sql-case id="show-streaming-rule" value="SHOW STREAMING RULE;"
db-types="ShardingSphere"/>
<sql-case id="alter-streaming-rule" value="ALTER STREAMING RULE
(READ(WORKER_THREAD=20,BATCH_SIZE=1000,SHARDING_SIZE=10000000,RATE_LIMITER
(TYPE(NAME='QPS',PROPERTIES('qps'='500')))),WRITE(WORKER_THREAD=20,BATCH_SIZE=2000,RATE_LIMITER
(TYPE(NAME='TPS',PROPERTIES('tps'='2000')))),STREAM_CHANNEL
(TYPE(NAME='MEMORY',PROPERTIES('block-queue-size'='100'))));"
db-types="ShardingSphere" />
+ <sql-case id="alter-streaming-rule-read-lite" value="ALTER STREAMING RULE
(READ(RATE_LIMITER (TYPE(NAME='QPS'))));" db-types="ShardingSphere" />
+ <sql-case id="alter-streaming-rule-write-lite" value="ALTER STREAMING RULE
(WRITE(RATE_LIMITER (TYPE(NAME='TPS'))));" db-types="ShardingSphere" />
<sql-case id="show-streaming-list" value="SHOW STREAMING LIST;"
db-types="ShardingSphere"/>
<sql-case id="show-streaming-status" value="SHOW STREAMING STATUS 123;"
db-types="ShardingSphere"/>
<sql-case id="drop-streaming" value="DROP STREAMING 123;"
db-types="ShardingSphere"/>
