@@ -184,13 +184,13 @@ async def __aexit__(
184
184
async def fetch_all (
185
185
self , query : typing .Union [ClauseElement , str ], values : dict = None
186
186
) -> typing .List [typing .Mapping ]:
187
- async with self ._self . _query_lock :
187
+ async with self ._query_lock :
188
188
return await self ._connection .fetch_all (self ._build_query (query , values ))
189
189
190
190
async def fetch_one (
191
191
self , query : typing .Union [ClauseElement , str ], values : dict = None
192
192
) -> typing .Optional [typing .Mapping ]:
193
- async with self ._self . _query_lock :
193
+ async with self ._query_lock :
194
194
return await self ._connection .fetch_one (self ._build_query (query , values ))
195
195
196
196
async def fetch_val (
@@ -199,27 +199,27 @@ async def fetch_val(
199
199
values : dict = None ,
200
200
column : typing .Any = 0 ,
201
201
) -> typing .Any :
202
- async with self ._self . _query_lock :
202
+ async with self ._query_lock :
203
203
row = await self ._connection .fetch_one (self ._build_query (query , values ))
204
204
return None if row is None else row [column ]
205
205
206
206
async def execute (
207
207
self , query : typing .Union [ClauseElement , str ], values : dict = None
208
208
) -> typing .Any :
209
- async with self ._self . _query_lock :
209
+ async with self ._query_lock :
210
210
return await self ._connection .execute (self ._build_query (query , values ))
211
211
212
212
async def execute_many (
213
213
self , query : typing .Union [ClauseElement , str ], values : list
214
214
) -> None :
215
215
queries = [self ._build_query (query , values_set ) for values_set in values ]
216
- async with self ._self . _query_lock :
216
+ async with self ._query_lock :
217
217
await self ._connection .execute_many (queries )
218
218
219
219
async def iterate (
220
220
self , query : typing .Union [ClauseElement , str ], values : dict = None
221
221
) -> typing .AsyncGenerator [typing .Any , None ]:
222
- async with self ._self . _query_lock :
222
+ async with self ._query_lock :
223
223
async for record in self ._connection .iterate (self ._build_query (query , values )):
224
224
yield record
225
225
0 commit comments