fix int(column_type)

naihe2010 · naihe2010 · commit 79716a5d99b7 · 2021-04-21T15:28:53.000+08:00
diff --git a/pymysqlreplication/row_event.py b/pymysqlreplication/row_event.py
@@ -617,7 +617,7 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
                         'COLUMN_TYPE': 'BLOB',  # we don't know what it is, so let's not do anything with it.
                         'COLUMN_KEY': '',
                     }
-                col = Column(column_type, column_schema, from_packet)
+                col = Column(int(column_type), column_schema, from_packet)
                 self.columns.append(col)
 
         self.table_obj = Table(self.column_schemas, self.table_id, self.schema,

Original file line number	Diff line number	Diff line change
`@@ -617,7 +617,7 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)`
`617`	`617`	`'COLUMN_TYPE': 'BLOB', # we don't know what it is, so let's not do anything with it.`
`618`	`618`	`'COLUMN_KEY': '',`
`619`	`619`	`}`
`620`		`- col = Column(column_type, column_schema, from_packet)`
	`620`	`+ col = Column(int(column_type), column_schema, from_packet)`
`621`	`621`	`self.columns.append(col)`
`622`	`622`
`623`	`623`	`self.table_obj = Table(self.column_schemas, self.table_id, self.schema,`