Skip to content

针对mysql 有replace语句的进行更新优化 #4

Description

@baisui1981

我在实际测试过程中,发现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

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions