rowChage.getEventType()获取的类型全部是是QUERY,但是rowChage.g

环境信息

canal version server ： canal.adapter-1.1.5-SNAPSHOT.tar.gz client： com.alibaba.otter canal.client 1.1.4 mysql version 5.7.30-log

问题描述

rowChage.getEventType()获取的类型全部是是QUERY,但是rowChage.getSql()获取sql语句都是INSERT或者UPDATE或者DELETE

步骤重现

RowChange rowChange = RowChange.parseFrom(entry.getStoreValue()); EventType eventType = rowChange.getEventType(); System.out.println("sql ："+ rowChange.getSql()); System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s", entry.getHeader().getLogfileName(), entry.getHeader().getLogfileOffset(), entry.getHeader().getSchemaName(), entry.getHeader().getTableName(), eventType)); for (RowData rowData : rowChange.getRowDatasList()) { if (eventType == EventType.DELETE) { printColumns(rowData.getBeforeColumnsList()); } else if (eventType == EventType.INSERT) { printColumns(rowData.getAfterColumnsList()); } else { System.out.println("-------> before"); printColumns(rowData.getBeforeColumnsList()); System.out.println("-------> after"); printColumns(rowData.getAfterColumnsList()); } }

实际执行情况

mysqld.cnf 配置如下： symbolic-links = 0 server-id = 1 log-bin = /var/lib/mysql/mysql-bin binlog_format = ROW binlog-rows-query-log-events = true

Just put your stack trace here!

原提问者GitHub用户