Skip to content

Commit 94c2bcb

Browse files
committed
Drop extraneous checks for compiled cache in SA executemany
1 parent b505841 commit 94c2bcb

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

aiomysql/sa/connection.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -108,10 +108,7 @@ async def _executemany(self, query, dps, cursor):
108108
compiled = self._compiled_cache.get(key)
109109
if not compiled:
110110
compiled = query.compile(dialect=self._dialect)
111-
dp_checks = [dp and dp.keys() == compiled.params.keys()
112-
or not (dp or compiled.params) for dp in dps]
113-
if all(dp_checks):
114-
self._compiled_cache[key] = compiled
111+
self._compiled_cache[key] = compiled
115112
else:
116113
compiled = query.compile(dialect=self._dialect)
117114

@@ -162,7 +159,6 @@ async def _execute(self, query, *multiparams, **params):
162159
compiled = query.compile(dialect=self._dialect)
163160
if dp and dp.keys() == compiled.params.keys() \
164161
or not (dp or compiled.params):
165-
# we only want queries with bound params in cache
166162
self._compiled_cache[key] = compiled
167163
else:
168164
compiled = query.compile(dialect=self._dialect)

0 commit comments

Comments
 (0)