Skip to content

Commit 8883176

Browse files
committed
Hush golinter
1 parent c574789 commit 8883176

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

canal/canal.go

+9-9
Original file line numberDiff line numberDiff line change
@@ -486,17 +486,17 @@ func (c *Canal) Execute(cmd string, args ...interface{}) (rr *mysql.Result, err
486486
}
487487

488488
rr, err = c.conn.Execute(cmd, args...)
489-
if err != nil && !mysql.ErrorEqual(err, mysql.ErrBadConn) {
490-
return
491-
} else if mysql.ErrorEqual(err, mysql.ErrBadConn) {
492-
c.conn.Close()
493-
c.conn = nil
494-
continue
495-
} else {
496-
return
489+
if err != nil {
490+
if mysql.ErrorEqual(err, mysql.ErrBadConn) {
491+
c.conn.Close()
492+
c.conn = nil
493+
continue
494+
}
495+
return nil, err
497496
}
497+
break
498498
}
499-
return
499+
return rr, nil
500500
}
501501

502502
func (c *Canal) SyncedPosition() mysql.Position {

0 commit comments

Comments
 (0)