@@ -866,6 +866,36 @@ func (e *TableMapEvent) JsonColumnCount() uint64 {
866
866
// RowsEventStmtEndFlag is set in the end of the statement.
867
867
const RowsEventStmtEndFlag = 0x01
868
868
869
+ // RowsEvent represents a MySQL rows event like DELETE_ROWS_EVENT,
870
+ // UPDATE_ROWS_EVENT, etc.
871
+ // RowsEvent.Rows saves the rows data, and the MySQL type to golang type mapping
872
+ // is
873
+ // - MYSQL_TYPE_NULL: nil
874
+ // - MYSQL_TYPE_LONG: int32
875
+ // - MYSQL_TYPE_TINY: int8
876
+ // - MYSQL_TYPE_SHORT: int16
877
+ // - MYSQL_TYPE_INT24: int32
878
+ // - MYSQL_TYPE_LONGLONG: int64
879
+ // - MYSQL_TYPE_NEWDECIMAL: string / "github.com/shopspring/decimal".Decimal
880
+ // - MYSQL_TYPE_FLOAT: float32
881
+ // - MYSQL_TYPE_DOUBLE: float64
882
+ // - MYSQL_TYPE_BIT: int64
883
+ // - MYSQL_TYPE_TIMESTAMP: string / time.Time
884
+ // - MYSQL_TYPE_TIMESTAMP2: string / time.Time
885
+ // - MYSQL_TYPE_DATETIME: string / time.Time
886
+ // - MYSQL_TYPE_DATETIME2: string / time.Time
887
+ // - MYSQL_TYPE_TIME: string
888
+ // - MYSQL_TYPE_TIME2: string
889
+ // - MYSQL_TYPE_DATE: string
890
+ // - MYSQL_TYPE_YEAR: int
891
+ // - MYSQL_TYPE_ENUM: int64
892
+ // - MYSQL_TYPE_SET: int64
893
+ // - MYSQL_TYPE_BLOB: []byte
894
+ // - MYSQL_TYPE_VARCHAR: string
895
+ // - MYSQL_TYPE_VAR_STRING: string
896
+ // - MYSQL_TYPE_STRING: string
897
+ // - MYSQL_TYPE_JSON: []byte / *replication.JsonDiff
898
+ // - MYSQL_TYPE_GEOMETRY: []byte
869
899
type RowsEvent struct {
870
900
// 0, 1, 2
871
901
Version int
0 commit comments