diff --git a/mysql_ch_replicator/converter.py b/mysql_ch_replicator/converter.py index f66cb76..c7ff0d1 100644 --- a/mysql_ch_replicator/converter.py +++ b/mysql_ch_replicator/converter.py @@ -585,7 +585,9 @@ def parse_mysql_table_structure(self, create_statement, required_table_name=None if not isinstance(tokens[2], sqlparse.sql.Identifier): raise Exception('wrong create statement', create_statement) - structure.table_name = strip_sql_name(tokens[2].normalized) + # get_real_name() returns the table name if the token is in the + # style `.` + structure.table_name = strip_sql_name(tokens[2].get_real_name()) if not isinstance(tokens[3], sqlparse.sql.Parenthesis): raise Exception('wrong create statement', create_statement)