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 <[email protected]>
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());