[hotfix-53286][jdbc] Fix the DynamicPreparedStmt cache invalidation of the same table caused by different RowKind.

shitou · tiezhu · commit 780e2ca64eb8 · 2022-03-30T18:56:06.000+08:00
diff --git a/flinkx-connectors/flinkx-connector-jdbc-base/src/main/java/com/dtstack/flinkx/connector/jdbc/sink/PreparedStmtProxy.java b/flinkx-connectors/flinkx-connector-jdbc-base/src/main/java/com/dtstack/flinkx/connector/jdbc/sink/PreparedStmtProxy.java
@@ -164,7 +164,7 @@ public void getOrCreateFieldNamedPstmt(RowData row) throws ExecutionException {
             }
         } else {
             String key =
-                    getPstmtCacheKey(jdbcConf.getSchema(), jdbcConf.getTable(), row.getRowKind());
+                    getPstmtCacheKey(jdbcConf.getSchema(), jdbcConf.getTable(), RowKind.INSERT);
             DynamicPreparedStmt fieldNamedPreparedStatement =
                     pstmtCache.get(
                             key,

Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ public void getOrCreateFieldNamedPstmt(RowData row) throws ExecutionException {`
`164`	`164`	`}`
`165`	`165`	`} else {`
`166`	`166`	`String key =`
`167`		`- getPstmtCacheKey(jdbcConf.getSchema(), jdbcConf.getTable(), row.getRowKind());`
	`167`	`+ getPstmtCacheKey(jdbcConf.getSchema(), jdbcConf.getTable(), RowKind.INSERT);`
`168`	`168`	`DynamicPreparedStmt fieldNamedPreparedStatement =`
`169`	`169`	`pstmtCache.get(`
`170`	`170`	`key,`