1
0
Fork 0

Decode first, return second

This commit is contained in:
Gregory Eremin 2018-11-11 20:35:31 +01:00
parent 1308d3306a
commit 07fed4b4eb
1 changed files with 2 additions and 1 deletions

View File

@ -155,5 +155,6 @@ func (e Event) DecodeRows() (binlog.RowsEvent, error) {
if binlog.RowsEventVersion(e.Header.Type) < 0 {
return re, errors.New("invalid rows event")
}
return re, re.Decode(e.Buffer, e.Format, *e.Table)
err := re.Decode(e.Buffer, e.Format, *e.Table)
return re, err
}