Alibaba mysql database binlog incremental subscription & consumer components Canal's php client[阿里巴巴mysql数据库binlog的增量订阅&消费组件 Canal 的 php 客户端 ] https://github.com/alibaba/canal
384
stars
67
forks
source link
测试成功了,但是没有答应出SQL 语句 #27
Open
ChenghuaMi opened 3 years ago
-------> before id : 29 update= false catid : 6 update= false modelid : 2 update= false title : 案例展示 update= false thumb : https://img.staticdj.com/5db9190f2c7cfa1b8dcd1572b1862965_1080x.jpg update= false keywords : update= false description : update= false listorder : 0 update= false status : 1 update= false hits : 5 update= false username : admin update= false time : 1392974386 update= false -------> after
这个没打印出 SQL语句,岂不是要根据 foreach ($rowChange->getRowDatas() as $rowData) { switch ($evenType) { case EventType::DELETE: self::ptColumn($rowData->getBeforeColumns()); break; case EventType::INSERT: self::ptColumn($rowData->getAfterColumns()); break; default: echo '-------> before', PHP_EOL; self::ptColumn($rowData->getBeforeColumns()); echo '-------> after', PHP_EOL; self::ptColumn($rowData->getAfterColumns()); break; } } 里面的 增删改查 把每种情况的字段都取出来,然后根据条件 插入到ES ?