diff --git a/core/async_mysql.py b/core/async_mysql.py index 022ee56..66862ed 100644 --- a/core/async_mysql.py +++ b/core/async_mysql.py @@ -35,6 +35,7 @@ class AsyncMySQL: await cursor.execute(sql, params or ()) return await cursor.fetchall() + async def execute(self, sql: str, params=None): """执行 SQL(insert/update/delete)""" await self.init_pool()