from ...connectors.asyncio import AsyncAdapt_dbapi_connection
from ...connectors.asyncio import AsyncAdapt_dbapi_cursor
from ...connectors.asyncio import AsyncAdapt_dbapi_ss_cursor
-from ...engine.interfaces import DBAPIModule
from ...util.concurrency import await_
+from ...connectors.asyncio import AsyncAdapt_dbapi_module
if TYPE_CHECKING:
from ...connectors.asyncio import AsyncIODBAPIConnection
from ...engine.interfaces import DBAPIConnection
from ...engine.interfaces import DBAPICursor
+ from ...engine.interfaces import DBAPIModule
from ...engine.url import URL
from ...pool.base import PoolProxiedConnection
super()._handle_exception(error)
-class AsyncAdapt_aiosqlite_dbapi:
+class AsyncAdapt_aiosqlite_dbapi(AsyncAdapt_dbapi_module):
def __init__(self, aiosqlite: ModuleType, sqlite: ModuleType):
self.aiosqlite = aiosqlite
self.sqlite = sqlite
await_(connection),
)
- def __getattr__(self, key: str) -> Any: ...
-
class SQLiteExecutionContext_aiosqlite(SQLiteExecutionContext):
def create_server_side_cursor(self) -> DBAPICursor: