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 0055818bf74 Refactor extract delete where segments (#34988)
0055818bf74 is described below

commit 0055818bf74c908635f816047a33c7c5cd9b31e6
Author: ZhangCheng <chengzh...@apache.org>
AuthorDate: Fri Mar 14 11:08:53 2025 +0800

    Refactor extract delete where segments (#34988)
---
 .../infra/binder/context/statement/dml/DeleteStatementContext.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContext.java
 
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContext.java
index a7bdfb95a38..067ff411425 100644
--- 
a/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContext.java
+++ 
b/infra/binder/src/main/java/org/apache/shardingsphere/infra/binder/context/statement/dml/DeleteStatementContext.java
@@ -56,11 +56,15 @@ public final class DeleteStatementContext extends 
CommonSQLStatementContext impl
     public DeleteStatementContext(final DeleteStatement sqlStatement) {
         super(sqlStatement);
         tablesContext = new TablesContext(getAllSimpleTableSegments());
-        getSqlStatement().getWhere().ifPresent(whereSegments::add);
+        extractWhereSegments(whereSegments, sqlStatement);
         ColumnExtractor.extractColumnSegments(columnSegments, whereSegments);
         ExpressionExtractor.extractJoinConditions(joinConditions, 
whereSegments);
     }
     
+    private void extractWhereSegments(final Collection<WhereSegment> 
whereSegments, final DeleteStatement deleteStatement) {
+        deleteStatement.getWhere().ifPresent(whereSegments::add);
+    }
+    
     private Collection<SimpleTableSegment> getAllSimpleTableSegments() {
         TableExtractor tableExtractor = new TableExtractor();
         tableExtractor.extractTablesFromDelete(getSqlStatement());

Reply via email to