(tableLower string)
| 1251 | } |
| 1252 | |
| 1253 | func skipMysqlSchemaEvent(tableLower string) bool { |
| 1254 | switch tableLower { |
| 1255 | case "event", "func", "proc", "tables_priv", "columns_priv", "procs_priv", "user": |
| 1256 | return false |
| 1257 | default: |
| 1258 | return true |
| 1259 | } |
| 1260 | } |
| 1261 | |
| 1262 | func (b *BinlogReader) skipRowEvent(rowsEvent *replication.RowsEvent, dml int8) (bool, *common.TableContext) { |
| 1263 | tableOrigin := string(rowsEvent.Table.Table) |