canal delete

Message[id=3,entries=[header {
  version: 1
  logfileName: "mysql-bin.000004"
  logfileOffset: 1949
  serverId: 1
  serverenCode: "UTF-8"
  executeTime: 1641372592000
  sourceType: MYSQL
  schemaName: ""
  tableName: ""
  eventLength: 73
}
entryType: TRANSACTIONBEGIN
storeValue: " \n"
, header {
  version: 1
  logfileName: "mysql-bin.000004"
  logfileOffset: 2084
  serverId: 1
  serverenCode: "UTF-8"
  executeTime: 1641372592000
  sourceType: MYSQL
  schemaName: "canaldb_a"
  tableName: "canal_test"
  eventLength: 51
  eventType: DELETE
  props {
    key: "rowsCount"
    value: "1"
  }
}
entryType: ROWDATA
storeValue: "\b#\020\003P\000b\233\001\n\031\b\000\020\004\032\001a \001(\0000\000B\0011R\aint(11)\n\032\b\001\020\001\032\001b \000(\0000\000B\002bbR\achar(2)\n\031\b\002\020\004\032\001c \000(\0000\000B\0013R\aint(11)\n,\b\003\020]\032\001d \000(\0000\000B\0232021-12-31 15:03:08R\bdatetime\n\031\b\004\020\001\032\001e \000(\0000\000B\001eR\achar(1)"
, header {
  version: 1
  logfileName: "mysql-bin.000004"
  logfileOffset: 2135
  serverId: 1
  serverenCode: "UTF-8"
  executeTime: 1641372592000
  sourceType: MYSQL
  schemaName: ""
  tableName: ""
  eventLength: 27
}
entryType: TRANSACTIONEND
storeValue: "\022\003386"
],raw=false,rawEntries=[]]
---------------------------------------------------------------
3 3
16:49:55.178 [Thread-0] INFO  org.canal.CanalClient - 当前有[3]条数据需要同步。
16:49:55.179 [Thread-0] INFO  org.canal.CanalClient - 实体类型 [TRANSACTIONBEGIN]
16:49:55.179 [Thread-0] INFO  org.canal.util.Transaction - 开启事务...
16:49:55.179 [Thread-0] INFO  org.canal.CanalClient - 实体类型 [ROWDATA]
16:49:55.190 [Thread-0] INFO  org.canal.CanalClient - executeTime 1641372592000
16:49:55.190 [Thread-0] INFO  org.canal.CanalClient - delayTime 3190
16:49:55.190 [Thread-0] INFO  org.canal.CanalClient - serverId 1
16:49:55.191 [Thread-0] INFO  org.canal.CanalClient - schemaName canaldb_a
16:49:55.191 [Thread-0] INFO  org.canal.CanalClient - tableName canal_test
16:49:55.191 [Thread-0] INFO  org.canal.CanalClient - binlogName mysql-bin.000004
16:49:55.191 [Thread-0] INFO  org.canal.CanalClient - position 2084
16:49:55.191 [Thread-0] INFO  org.canal.CanalClient - entryType [ROWDATA] [ROWDATA]
16:49:55.191 [Thread-0] INFO  org.canal.CanalClient - 数据变更类型 [DELETE]
rowDataList [1]
beforeColumns {
  index: 0
  sqlType: 4
  name: "a"
  isKey: true
  updated: false
  isNull: false
  value: "1"
  mysqlType: "int(11)"
}
beforeColumns {
  index: 1
  sqlType: 1
  name: "b"
  isKey: false
  updated: false
  isNull: false
  value: "bb"
  mysqlType: "char(2)"
}
beforeColumns {
  index: 2
  sqlType: 4
  name: "c"
  isKey: false
  updated: false
  isNull: false
  value: "3"
  mysqlType: "int(11)"
}
beforeColumns {
  index: 3
  sqlType: 93
  name: "d"
  isKey: false
  updated: false
  isNull: false
  value: "2021-12-31 15:03:08"
  mysqlType: "datetime"
}
beforeColumns {
  index: 4
  sqlType: 1
  name: "e"
  isKey: false
  updated: false
  isNull: false
  value: "e"
  mysqlType: "char(1)"
}

16:49:55.266 [Thread-0] INFO  org.canal.CanalClient - 实体类型 [TRANSACTIONEND]
16:49:55.266 [Thread-0] INFO  org.canal.util.Transaction - 提交事务

Logo

更多推荐