From e033dca19f598d7ec0eb9fd79e62ee21adce7b44 Mon Sep 17 00:00:00 2001 From: Filipp Ozinov Date: Thu, 23 Jan 2025 12:18:44 +0400 Subject: [PATCH] Apply quotes in USE statement --- mysql_ch_replicator/mysql_api.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mysql_ch_replicator/mysql_api.py b/mysql_ch_replicator/mysql_api.py index b1f461b..5e2f2da 100644 --- a/mysql_ch_replicator/mysql_api.py +++ b/mysql_ch_replicator/mysql_api.py @@ -39,7 +39,7 @@ def reconnect_if_required(self, force=False): raise self.cursor = self.db.cursor() if self.database is not None: - self.cursor.execute(f'USE {self.database}') + self.cursor.execute(f'USE `{self.database}`') self.last_connect_time = curr_time def drop_database(self, db_name): @@ -63,7 +63,7 @@ def set_database(self, database): self.reconnect_if_required() self.database = database self.cursor = self.db.cursor() - self.cursor.execute(f'USE {self.database}') + self.cursor.execute(f'USE `{self.database}`') def get_databases(self): self.reconnect_if_required(True) # New database appear only after new connection