MCPcopy
hub / github.com/sqlalchemy/sqlalchemy / exec_driver_sql

Method exec_driver_sql

lib/sqlalchemy/ext/asyncio/engine.py:504–523  ·  view source on GitHub ↗

r"""Executes a driver-level SQL string and return buffered :class:`_engine.Result`.

(
        self,
        statement: str,
        parameters: Optional[_DBAPIAnyExecuteParams] = None,
        execution_options: Optional[CoreExecuteOptionsParameter] = None,
    )

Source from the content-addressed store, hash-verified

502 await self.close()
503
504 async def exec_driver_sql(
505 self,
506 statement: str,
507 parameters: Optional[_DBAPIAnyExecuteParams] = None,
508 execution_options: Optional[CoreExecuteOptionsParameter] = None,
509 ) -> CursorResult[Any]:
510 r"""Executes a driver-level SQL string and return buffered
511 :class:`_engine.Result`.
512
513 """
514
515 result = await greenlet_spawn(
516 self._proxied.exec_driver_sql,
517 statement,
518 parameters,
519 execution_options,
520 _require_await=True,
521 )
522
523 return await _ensure_sync_result(result, self.exec_driver_sql)
524
525 @overload
526 def stream(

Callers

nothing calls this directly

Calls 2

greenlet_spawnFunction · 0.85
_ensure_sync_resultFunction · 0.85

Tested by

no test coverage detected