mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-20 14:49:14 -05:00
Code Issues Packages Projects Releases Wiki Activity

inner 1504 - fix or condition in on join filter

Browse Source
This commit is contained in:
baofengqi
2021-12-08 18:23:15 +08:00
committed by Huqing Yan
parent 0af53cc33e
commit a49f5e4ae2
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/builder/sqlvisitor/GlobalVisitor.java
+4 -1
View File
@@ -224,9 +224,12 @@ public class GlobalVisitor extends MysqlVisitor {
if (first) {
sqlBuilder.append(" on ");
} else {
joinOnFilterStr.append(" and ");
joinOnFilterStr.append(" and (");
}
joinOnFilterStr.append(join.getOtherJoinOnFilter());
if (!first) {
joinOnFilterStr.append(")");
}
}
sqlBuilder.append(joinOnFilterStr.toString());
if (join.isWithSubQuery() || isTopQuery) {
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/builder/sqlvisitor/PushDownVisitor.java
+4 -1
View File
@@ -208,9 +208,12 @@ public class PushDownVisitor extends MysqlVisitor {
if (first) {
sqlBuilder.append(" on ");
} else {
joinOnFilterStr.append(" and ");
joinOnFilterStr.append(" and (");
}
joinOnFilterStr.append(join.getOtherJoinOnFilter());
if (!first) {
joinOnFilterStr.append(")");
}
}
return joinOnFilterStr;
}