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());