(
self,
query,
args,
timeout,
return_rows=False,
record_class=None,
)
| 1977 | return result, stmt |
| 1978 | |
| 1979 | async def _executemany( |
| 1980 | self, |
| 1981 | query, |
| 1982 | args, |
| 1983 | timeout, |
| 1984 | return_rows=False, |
| 1985 | record_class=None, |
| 1986 | ): |
| 1987 | executor = lambda stmt, timeout: self._protocol.bind_execute_many( |
| 1988 | state=stmt, |
| 1989 | args=args, |
| 1990 | portal_name='', |
| 1991 | timeout=timeout, |
| 1992 | return_rows=return_rows, |
| 1993 | ) |
| 1994 | timeout = self._protocol._get_timeout(timeout) |
| 1995 | with self._stmt_exclusive_section: |
| 1996 | with self._time_and_log(query, args, timeout): |
| 1997 | result, _ = await self._do_execute( |
| 1998 | query, executor, timeout, record_class=record_class |
| 1999 | ) |
| 2000 | return result |
| 2001 | |
| 2002 | async def _do_execute( |
| 2003 | self, |
no test coverage detected