fix(canal): fix "Index of range error" for unsigned columns

Author: mefcorvi

canal/rows.go

@@ -2,6 +2,7 @@ package canal
 
 import (
 	"fmt"
+
 	"github.com/siddontang/go-mysql/replication"
 	"github.com/siddontang/go-mysql/schema"
 )
@@ -58,15 +59,14 @@ func (r *RowsEvent) handleUnsigned() {
 			case int16:
 				r.Rows[i][index] = uint16(t)
 			case int32:
-				if r.Table.Columns[i].Type == schema.TYPE_MEDIUM_INT {
+				if r.Table.Columns[index].Type == schema.TYPE_MEDIUM_INT {
 					// problem with mediumint is that it's a 3-byte type. There is no compatible golang type to match that.
 					// So to convert from negative to positive we'd need to convert the value manually
-					if i >= 0 {
+					if t >= 0 {
 						r.Rows[i][index] = uint32(t)
 					} else {
 						r.Rows[i][index] = uint32(maxMediumintUnsigned + t + 1)
 					}
-					return
 				} else {
 					r.Rows[i][index] = uint32(t)
 				}