在CDC中将mysql二进制日志转换为select

Question

我想从mysql中进行实时读取。想法很简单。我使用二进制日志来触发select语句。同时，我希望在每次更改时只读取新的行。目前我只考虑插入。

所以当有人这么做的时候

insert into sometable(uid,somecolumn) values(uid,something)

我的代码将被触发并执行

select from sometable where uid=uid

当然，我已经写下了哪些列是主键，因为它似乎没有来自binlog的信息。

我找不到工具分析mysql insert语句。所以我使用正则表达式来找出哪一列等于哪个值，然后提取主键。

但真正的问题是如果我这么做了会发生什么

Insert into `table` (`col`) values (select 0 as `col` from `dummy`);

我怎样才能找到col=0？

由insert语句触发的select语句选择新更改的行是不可能的吗？

Answer 1

在TRIGGER中，您可以访问OLD和NEW值。使用它们，您可以编写代码(在TRIGGER中)来记录日志，例如，只记录更改。就像..。

IF NEW.col1 != OLD.col1 THEN INSERT INTO LOG ...; END; 
IF NEW.col2 != OLD.col2 THEN INSERT INTO LOG ...; END;