fix: sql replace concat

Riversoft-Thomas · Riversoft-Thomas · commit 807bc7ade1d3 · 2025-02-27T10:42:26.000+08:00
diff --git a/pymysql/connections.py b/pymysql/connections.py
@@ -570,6 +570,8 @@ def query(self, sql, unbuffered=False):
         # if DEBUG:
         #     print("DEBUG: sending query:", sql)
         if isinstance(sql, str):
+            sql = sql.replace("json_extract(checkpoint, concat('$.channel_versions.', channel))",
+                              """json_extract(checkpoint, concat('$.channel_versions."', channel, '"'))""")
             sql = sql.encode(self.encoding, "surrogateescape")
         self._execute_command(COMMAND.COM_QUERY, sql)
         self._affected_rows = self._read_query_result(unbuffered=unbuffered)
