Skip to content

Commit ac32b48

Browse files
wangzwbaloo
authored andcommitted
failed to get table information (julien-duponchelle#199)
should specify information_schema schema name.
1 parent c23d6a3 commit ac32b48

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pymysqlreplication/binlogstream.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -498,7 +498,7 @@ def __get_table_information(self, schema, table):
498498
COLUMN_NAME, COLLATION_NAME, CHARACTER_SET_NAME,
499499
COLUMN_COMMENT, COLUMN_TYPE, COLUMN_KEY
500500
FROM
501-
columns
501+
information_schema.columns
502502
WHERE
503503
table_schema = %s AND table_name = %s
504504
""", (schema, table))

0 commit comments

Comments
 (0)