|
6 | 6 | import warnings |
7 | 7 |
|
8 | 8 | import aiomysql |
9 | | -from sqlalchemy import util, exc, sql |
| 9 | +from sqlalchemy import util, exc |
10 | 10 | from sqlalchemy.dialects.mysql import (JSON, ENUM) |
11 | 11 | from sqlalchemy.dialects.mysql.base import ( |
12 | 12 | MySQLCompiler, |
@@ -176,7 +176,6 @@ async def _async_executemany(self, conn, query, args): |
176 | 176 | q_prefix = m.group(1) |
177 | 177 | q_values = m.group(2).rstrip() |
178 | 178 | q_postfix = m.group(3) or '' |
179 | | - assert q_values[0] == '(' and q_values[-1] == ')' |
180 | 179 | return (await self._do_execute_many( |
181 | 180 | conn, q_prefix, q_values, q_postfix, args)) |
182 | 181 | else: |
@@ -396,7 +395,8 @@ def __init__(self, *args, **kwargs): |
396 | 395 | async def init_pool(self, url, loop, pool_class=None): |
397 | 396 | if pool_class is None: |
398 | 397 | pool_class = Pool |
399 | | - return await pool_class(url, loop, init=self.on_connect(), **self._pool_kwargs) |
| 398 | + return await pool_class( |
| 399 | + url, loop, init=self.on_connect(), **self._pool_kwargs) |
400 | 400 |
|
401 | 401 | # noinspection PyMethodMayBeStatic |
402 | 402 | def transaction(self, raw_conn, args, kwargs): |
|
0 commit comments