我在实际测试过程中,发现source中 执行update语句操作,根据DynamicPreparedStmt 的执行逻辑 在mysql中也是会根据UPDATE_BEFORE,和UPDATE_AFTER 分成一个 delete 语句和一个 insert语句来实现sink端的 更新,实际上mysql有 replace 只需要一句 就能执行了。 https://github.com/DTStack/chunjun/blob/4ff992cf68ea890161eb42b8c22762c9ea4f1e00/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/sink/DynamicPreparedStmt.java#L134-L155