| 91 | ) |
| 92 | |
| 93 | func ToEventDML(eventType replication.EventType) int8 { |
| 94 | switch eventType { |
| 95 | case replication.WRITE_ROWS_EVENTv0, replication.WRITE_ROWS_EVENTv1, replication.WRITE_ROWS_EVENTv2: |
| 96 | return InsertDML |
| 97 | case replication.UPDATE_ROWS_EVENTv0, replication.UPDATE_ROWS_EVENTv1, replication.UPDATE_ROWS_EVENTv2: |
| 98 | return UpdateDML |
| 99 | case replication.DELETE_ROWS_EVENTv0, replication.DELETE_ROWS_EVENTv1, replication.DELETE_ROWS_EVENTv2: |
| 100 | return DeleteDML |
| 101 | default: |
| 102 | return NotDML |
| 103 | } |
| 104 | } |
| 105 | |
| 106 | type SchemaTable struct { |
| 107 | Schema string |