graph LR
SQLAlchemy_Engine_Factory["SQLAlchemy Engine Factory"]
SQLAlchemy_Core_Engine["SQLAlchemy Core Engine"]
SQLAlchemy_Async_Connection["SQLAlchemy Async Connection"]
SQLAlchemy_Integration_Exceptions["SQLAlchemy Integration Exceptions"]
SQLAlchemy_Engine_Factory -- "instantiates" --> SQLAlchemy_Core_Engine
SQLAlchemy_Engine_Factory -- "raises" --> SQLAlchemy_Integration_Exceptions
SQLAlchemy_Core_Engine -- "manages" --> SQLAlchemy_Async_Connection
SQLAlchemy_Core_Engine -- "invokes operations on" --> SQLAlchemy_Async_Connection
SQLAlchemy_Async_Connection -- "raises" --> SQLAlchemy_Integration_Exceptions
SQLAlchemy_Integration_Exceptions -- "is raised by" --> SQLAlchemy_Engine_Factory
SQLAlchemy_Integration_Exceptions -- "is raised by" --> SQLAlchemy_Async_Connection
The SQLAlchemy Engine Integration subsystem in aiomysql provides the necessary components to allow SQLAlchemy applications to interact with MySQL asynchronously using aiomysql. This subsystem acts as an adapter layer, translating SQLAlchemy's synchronous-oriented operations into aiomysql's asynchronous patterns.
This module serves as the primary entry point for SQLAlchemy applications. It provides the create_engine function, which is responsible for initializing and configuring SQLAlchemy-compatible database engines that leverage aiomysql for asynchronous operations. It also handles the initial setup and management of the engine's lifecycle, including its eventual closure.
Related Classes/Methods:
This class represents the core SQLAlchemy engine within the aiomysql.sa integration. It encapsulates the connection pooling mechanism and manages dialect-specific behaviors necessary for SQLAlchemy to interact correctly with MySQL via aiomysql. It is responsible for acquiring and releasing asynchronous database connections.
Related Classes/Methods:
This class is an asynchronous database connection object that acts as the bridge between SQLAlchemy's execution layer and aiomysql's low-level connection. It translates SQLAlchemy's operations into aiomysql calls and manages the asynchronous flow of query execution and transaction handling.
Related Classes/Methods:
Provides a specific exception type for argument validation and error handling within the SQLAlchemy integration layer. This ensures that invalid parameters or configurations are caught and reported appropriately, contributing to the robustness of the integration.
Related Classes/Methods: