diff --git a/mysql_ch_replicator/mysql_api.py b/mysql_ch_replicator/mysql_api.py index 8480933..35210ff 100644 --- a/mysql_ch_replicator/mysql_api.py +++ b/mysql_ch_replicator/mysql_api.py @@ -71,9 +71,9 @@ def get_databases(self): def get_tables(self): self.reconnect_if_required() - self.cursor.execute('SHOW TABLES') + self.cursor.execute('SHOW FULL TABLES') res = self.cursor.fetchall() - tables = [x[0] for x in res] + tables = [x[0] for x in res if x[1] == 'BASE TABLE'] return tables def get_binlog_files(self):