We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cb6570a commit 73a818dCopy full SHA for 73a818d
mysql_ch_replicator/mysql_api.py
@@ -39,7 +39,7 @@ def reconnect_if_required(self, force=False):
39
raise
40
self.cursor = self.db.cursor()
41
if self.database is not None:
42
- self.cursor.execute(f'USE {self.database}')
+ self.cursor.execute(f'USE `{self.database}`')
43
self.last_connect_time = curr_time
44
45
def drop_database(self, db_name):
@@ -63,7 +63,7 @@ def set_database(self, database):
63
self.reconnect_if_required()
64
self.database = database
65
66
67
68
def get_databases(self):
69
self.reconnect_if_required(True) # New database appear only after new connection
0 commit comments