use multi-value (bulk) insert / replace

对于大量insert, 在目标端应使用形如
replace into ... values ( ), ( ), ( ), ...
的语句回放.

要考虑这种回放和prepare statement之间如何整合.

关联问题

• MySQL 一个 RowsEvent 可以表示多行
• dtle中间结构 DataEvent 只表示一行. 需要优化.

步骤1: 重构DataEvent, 每个DataEvent可对应多行.

引入API版本机制, 避免新老版本混用导致错误.

update 拆分问题

对于update前后Where结果不一样的, 需要转化为对应的delete / insert. 例如

任务:

• job1: where val % 2 = 0
• job2: where val % 2 = 1

执行: update set val = 3 where val = 0 or val = 1

执行前数据:

• src: (0,0), (1,1)
• dst1: (0,0)
• dst2: (1,1)

执行后:

• src: (0,3), (1,3)

需要执行:

• job1: delete where id = 0
• job2
  • insert values (0,3)
  • update set val = 3 where id = 1

同一个MySQL RowsEvent (update) 需要被转化为不同的DML. 故update需要保持一个dtle DataEvent对应一行修改.

之前：

• DataEvent.Rows只有1个或2个元素
• insert/delete：Rows[0]
• update：Rows[0] -> Rows[1]

现在：

• DataEvent.Rows 含有N个元素
• insert/delete逐个使用Rows[i]
• update配对使用Rows[i]、Rows[i+1]