关系型数据库谓词下推

simenliuxing · simenliuxing · commit c7f2f1039d69 · 2019-11-04T11:14:55.000+08:00
diff --git a/rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncSideInfo.java b/rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncSideInfo.java
@@ -93,8 +93,11 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {
             // 如果where条件中第一个符合条件的是维表中的条件
             String firstCondition = whereConditionList.get(0);
             if (!"and".equalsIgnoreCase(firstCondition) && !"or".equalsIgnoreCase(firstCondition)) {
-                sqlCondition += " and ";
+                whereConditionList.add(0, "and (");
+            } else {
+                whereConditionList.add(1, "(");
             }
+            whereConditionList.add(whereConditionList.size(), ")");
             sqlCondition += String.join(" ", whereConditionList);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -93,8 +93,11 @@ public void buildEqualInfo(JoinInfo joinInfo, SideTableInfo sideTableInfo) {`
`93`	`93`	`// 如果where条件中第一个符合条件的是维表中的条件`
`94`	`94`	`String firstCondition = whereConditionList.get(0);`
`95`	`95`	`if (!"and".equalsIgnoreCase(firstCondition) && !"or".equalsIgnoreCase(firstCondition)) {`
`96`		`- sqlCondition += " and ";`
	`96`	`+ whereConditionList.add(0, "and (");`
	`97`	`+ } else {`
	`98`	`+ whereConditionList.add(1, "(");`
`97`	`99`	`}`
	`100`	`+ whereConditionList.add(whereConditionList.size(), ")");`
`98`	`101`	`sqlCondition += String.join(" ", whereConditionList);`
`99`	`102`	`}`
`100`	`103`