1.10同步修改

dapeng · dapeng · commit 2c787cb4710b · 2020-09-08T17:56:20.000+08:00
diff --git a/oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle/OracleDialect.java b/oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle/OracleDialect.java
@@ -104,7 +104,7 @@ private String buildConnectionByAllReplace(boolean allReplace, String col) {
 
 
     private String buildConnectionConditions(String[] uniqueKeyFields) {
-        return Arrays.stream(uniqueKeyFields).map(col -> "T1." + quoteIdentifier(col) + "=T2." + quoteIdentifier(col)).collect(Collectors.joining(","));
+        return Arrays.stream(uniqueKeyFields).map(col -> "T1." + quoteIdentifier(col) + "=T2." + quoteIdentifier(col)).collect(Collectors.joining(" AND "));
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ private String buildConnectionByAllReplace(boolean allReplace, String col) {`
`104`	`104`
`105`	`105`
`106`	`106`	`private String buildConnectionConditions(String[] uniqueKeyFields) {`
`107`		`- return Arrays.stream(uniqueKeyFields).map(col -> "T1." + quoteIdentifier(col) + "=T2." + quoteIdentifier(col)).collect(Collectors.joining(","));`
	`107`	`+ return Arrays.stream(uniqueKeyFields).map(col -> "T1." + quoteIdentifier(col) + "=T2." + quoteIdentifier(col)).collect(Collectors.joining(" AND "));`
`108`	`108`	`}`
`109`	`109`
`110`	`110`	`/**`