@@ -339,9 +339,7 @@ type Position struct {
339
339
340
340
// handleQueryEvent is handle some common query events (e.g., DDL,CREATE or DROP USER,GRANT),
341
341
// others use UnknownQueryEvent unified callbacks to expose to users
342
- func (c * Canal ) handleQueryEvent (ev * replication.BinlogEvent , e * replication.QueryEvent ,
343
- stmt ast.StmtNode , pos * Position ) error {
344
-
342
+ func (c * Canal ) handleQueryEvent (ev * replication.BinlogEvent , e * replication.QueryEvent , stmt ast.StmtNode , pos * Position ) error {
345
343
switch t := stmt .(type ) {
346
344
case * ast.RenameTableStmt , * ast.AlterTableStmt , * ast.DropTableStmt , * ast.CreateTableStmt , * ast.TruncateTableStmt :
347
345
return c .handleDDLEvent (ev , e , t , pos )
@@ -350,8 +348,7 @@ func (c *Canal) handleQueryEvent(ev *replication.BinlogEvent, e *replication.Que
350
348
}
351
349
}
352
350
353
- func (c * Canal ) handleDDLEvent (ev * replication.BinlogEvent , e * replication.QueryEvent ,
354
- stmt ast.StmtNode , pos * Position ) error {
351
+ func (c * Canal ) handleDDLEvent (ev * replication.BinlogEvent , e * replication.QueryEvent , stmt ast.StmtNode , pos * Position ) error {
355
352
nodes := parseStmt (stmt )
356
353
for _ , node := range nodes {
357
354
if node .db == "" {
0 commit comments