You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2025/06/27 11:38:05 UTC
(shardingsphere) branch master updated: Rename and move OraclePurgeStatement (#35826)
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 a5ec90a61a8 Rename and move OraclePurgeStatement (#35826)
a5ec90a61a8 is described below
commit a5ec90a61a82f76755b6a899a8916aa95fc1a31e
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Fri Jun 27 19:37:58 2025 +0800
Rename and move OraclePurgeStatement (#35826)
---
.../oracle/visitor/statement/type/OracleDDLStatementVisitor.java | 4 ++--
.../sql/parser/statement/oracle/ddl/OraclePurgeStatement.java} | 7 ++++---
.../parser/internal/asserts/statement/ddl/DDLStatementAssert.java | 5 +++++
.../internal/asserts/statement/ddl/impl/PurgeStatementAssert.java | 8 ++++----
4 files changed, 15 insertions(+), 9 deletions(-)
diff --git a/parser/sql/dialect/oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/type/OracleDDLStatementVisitor.java b/parser/sql/dialect/oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/type/OracleDDLStatementVisitor.java
index 8a8d3a65465..6d49d035201 100644
--- a/parser/sql/dialect/oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/type/OracleDDLStatementVisitor.java
+++ b/parser/sql/dialect/oracle/src/main/java/org/apache/shardingsphere/sql/parser/oracle/visitor/statement/type/OracleDDLStatementVisitor.java
@@ -232,7 +232,6 @@ import org.apache.shardingsphere.sql.parser.statement.core.statement.SQLStatemen
import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.AlterPackageStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.AnalyzeStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.CommentStatement;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.PurgeStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.TruncateStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.database.AlterDatabaseStatement;
import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.database.CreateDatabaseStatement;
@@ -287,6 +286,7 @@ import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleCreateVar
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleDropPackageStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleNoAuditStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OraclePLSQLBlockStatement;
+import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OraclePurgeStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleRenameStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleSwitchStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleSystemActionStatement;
@@ -1016,7 +1016,7 @@ public final class OracleDDLStatementVisitor extends OracleStatementVisitor impl
@Override
public ASTNode visitPurge(final PurgeContext ctx) {
- return new PurgeStatement(null == ctx.tableName() ? null : (SimpleTableSegment) visit(ctx.tableName()), null == ctx.indexName() ? null : (IndexSegment) visit(ctx.indexName()));
+ return new OraclePurgeStatement(null == ctx.tableName() ? null : (SimpleTableSegment) visit(ctx.tableName()), null == ctx.indexName() ? null : (IndexSegment) visit(ctx.indexName()));
}
@Override
diff --git a/parser/sql/statement/core/src/main/java/org/apache/shardingsphere/sql/parser/statement/core/statement/type/ddl/PurgeStatement.java b/parser/sql/statement/type/oracle/src/main/java/org/apache/shardingsphere/sql/parser/statement/oracle/ddl/OraclePurgeStatement.java
similarity index 82%
rename from parser/sql/statement/core/src/main/java/org/apache/shardingsphere/sql/parser/statement/core/statement/type/ddl/PurgeStatement.java
rename to parser/sql/statement/type/oracle/src/main/java/org/apache/shardingsphere/sql/parser/statement/oracle/ddl/OraclePurgeStatement.java
index 8dae15abe24..627cd835473 100644
--- a/parser/sql/statement/core/src/main/java/org/apache/shardingsphere/sql/parser/statement/core/statement/type/ddl/PurgeStatement.java
+++ b/parser/sql/statement/type/oracle/src/main/java/org/apache/shardingsphere/sql/parser/statement/oracle/ddl/OraclePurgeStatement.java
@@ -15,19 +15,20 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl;
+package org.apache.shardingsphere.sql.parser.statement.oracle.ddl;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.sql.parser.statement.core.segment.ddl.index.IndexSegment;
import org.apache.shardingsphere.sql.parser.statement.core.segment.generic.table.SimpleTableSegment;
+import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.DDLStatement;
/**
- * Purge statement.
+ * Purge statement for Oracle.
*/
@RequiredArgsConstructor
@Getter
-public final class PurgeStatement extends DDLStatement {
+public final class OraclePurgeStatement extends DDLStatement {
private final SimpleTableSegment table;
diff --git a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/DDLStatementAssert.java b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/DDLStatementAssert.java
index 1299c348c69..f556acfd76a 100644
--- a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/DDLStatementAssert.java
+++ b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/DDLStatementAssert.java
@@ -48,6 +48,7 @@ import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleAlterSess
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleAlterSystemStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleAuditStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OracleNoAuditStatement;
+import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OraclePurgeStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.flashback.OracleFlashbackTableStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.statistics.OracleAssociateStatisticsStatement;
import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.statistics.OracleDisassociateStatisticsStatement;
@@ -88,6 +89,7 @@ import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.d
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.NoAuditStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.NotifyStmtStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.OpenStatementAssert;
+import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.PurgeStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.RefreshMatViewStmtStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.ReindexStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ddl.impl.RenameTableStatementAssert;
@@ -126,6 +128,7 @@ import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.s
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.NoAuditStatementTestCase;
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.NotifyStmtStatementTestCase;
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.OpenStatementTestCase;
+import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.PurgeStatementTestCase;
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.RefreshMatViewStmtStatementTestCase;
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.ReindexStatementTestCase;
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ddl.RenameTableStatementTestCase;
@@ -222,6 +225,8 @@ public final class DDLStatementAssert {
OpenStatementAssert.assertIs(assertContext, (PostgreSQLOpenStatement) actual, (OpenStatementTestCase) expected);
} else if (actual instanceof OracleFlashbackTableStatement) {
FlashbackTableStatementAssert.assertIs(assertContext, (OracleFlashbackTableStatement) actual, (FlashbackTableStatementTestCase) expected);
+ } else if (actual instanceof OraclePurgeStatement) {
+ PurgeStatementAssert.assertIs(assertContext, (OraclePurgeStatement) actual, (PurgeStatementTestCase) expected);
}
}
}
diff --git a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/impl/PurgeStatementAssert.java b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/impl/PurgeStatementAssert.java
index 2fbf0ce3869..a95c0321d63 100644
--- a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/impl/PurgeStatementAssert.java
+++ b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ddl/impl/PurgeStatementAssert.java
@@ -19,7 +19,7 @@ package org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
-import org.apache.shardingsphere.sql.parser.statement.core.statement.type.ddl.PurgeStatement;
+import org.apache.shardingsphere.sql.parser.statement.oracle.ddl.OraclePurgeStatement;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.SQLCaseAssertContext;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.segment.index.IndexAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.segment.table.TableAssert;
@@ -38,18 +38,18 @@ public final class PurgeStatementAssert {
* @param actual actual purge statement
* @param expected expected purge statement test case
*/
- public static void assertIs(final SQLCaseAssertContext assertContext, final PurgeStatement actual, final PurgeStatementTestCase expected) {
+ public static void assertIs(final SQLCaseAssertContext assertContext, final OraclePurgeStatement actual, final PurgeStatementTestCase expected) {
assertTables(assertContext, actual, expected);
assertIndex(assertContext, actual, expected);
}
- private static void assertTables(final SQLCaseAssertContext assertContext, final PurgeStatement actual, final PurgeStatementTestCase expected) {
+ private static void assertTables(final SQLCaseAssertContext assertContext, final OraclePurgeStatement actual, final PurgeStatementTestCase expected) {
if (null != expected.getTable()) {
TableAssert.assertIs(assertContext, actual.getTable(), expected.getTable());
}
}
- private static void assertIndex(final SQLCaseAssertContext assertContext, final PurgeStatement actual, final PurgeStatementTestCase expected) {
+ private static void assertIndex(final SQLCaseAssertContext assertContext, final OraclePurgeStatement actual, final PurgeStatementTestCase expected) {
if (null != expected.getIndex()) {
IndexAssert.assertIs(assertContext, actual.getIndex(), expected.getIndex());
}