From f7d6c811fc72324a83c8af635bbca8b268b0098e Mon Sep 17 00:00:00 2001 From: long2ice Date: Thu, 16 Sep 2021 09:58:21 +0800 Subject: [PATCH] bug fix --- lib/sqlalchemy/dialects/mysql/asyncmy.py | 1 + lib/sqlalchemy/dialects/mysql/base.py | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/lib/sqlalchemy/dialects/mysql/asyncmy.py b/lib/sqlalchemy/dialects/mysql/asyncmy.py index e649b8096d..bc91b3a268 100644 --- a/lib/sqlalchemy/dialects/mysql/asyncmy.py +++ b/lib/sqlalchemy/dialects/mysql/asyncmy.py @@ -161,6 +161,7 @@ class AsyncAdapt_asyncmy_ss_cursor(AsyncAdapt_asyncmy_cursor): def close(self): if self._cursor is not None: + self.await_(self._cursor.fetchall()) self.await_(self._cursor.close()) self._cursor = None diff --git a/lib/sqlalchemy/dialects/mysql/base.py b/lib/sqlalchemy/dialects/mysql/base.py index 9bf12e194c..04b0c1b6d9 100644 --- a/lib/sqlalchemy/dialects/mysql/base.py +++ b/lib/sqlalchemy/dialects/mysql/base.py @@ -2915,7 +2915,10 @@ class MySQLDialect(default.DefaultDialect): "WHERE TABLE_TYPE='SEQUENCE' and TABLE_NAME=:name AND " "TABLE_SCHEMA=:schema_name" ), - dict(name=sequence_name, schema_name=schema), + dict( + name=util.text_type(sequence_name), + schema_name=util.text_type(schema), + ), ) return cursor.first() is not None -- 2.47.2