ErisPulse.Core.storage.mysql 模块
模块概述
ErisPulse MySQL 存储后端（aiomysql 异步原生实现）
通过 ErisPulse.storage.backend = "mysql" 启用，连接参数来自
ErisPulse.storage.mysql 配置节。需安装可选依赖：
pip install ErisPulse[mysql]
提示
- 连接池按事件循环惰性创建（同步桥接循环与用户异步循环各自独立）
- 池连接 autocommit 模式；事务使用池内专用连接（BEGIN/COMMIT/ROLLBACK）
类列表
class MySQLDialect(SQLDialect)
MySQL 方言实现
方法列表
translate_sql(sql: str)
内部方法
?→%s（PyMySQL 参数风格）
quote(name: str)
内部方法 反引号引用（
key为 MySQL 保留字，必须引用）
upsert_kv_sql(table: str, key_col: str, value_col: str)
内部方法 ON DUPLICATE KEY UPDATE 形式的 UPSERT
table_columns_sql(table_name: str)
内部方法 information_schema 列举表现有列名
has_table_sql(table_name: str)
内部方法 information_schema 查询当前数据库
create_index_sql(table: str, index: str, column: str)
内部方法 裸 CREATE INDEX（MySQL 不支持 IF NOT EXISTS，幂等由 has_index_sql 预检承接）
has_index_sql(table: str, index: str)
内部方法 information_schema 索引查询当前数据库
autoincrement_column(base_type: str)
内部方法
INT/BIGINT AUTO_INCREMENT PRIMARY KEY
last_insert_id_sql()
内部方法 连接级 LAST_INSERT_ID()
is_missing_table_error(exc: BaseException)
内部方法 MySQL 错误码 1146: ER_NO_SUCH_TABLE
class MySQLStorage(_SingletonMixin, SQLStorageBase)
MySQL 存储管理器（aiomysql 异步原生实现）
单例模式实现，接口与 SQLite 后端完全一致，可通过
ErisPulse.storage.backend 配置项无感切换。
提示
- 连接参数见
ErisPulse.storage.mysql配置节- 缺少驱动时提示安装
pip install ErisPulse[mysql]
方法列表
_check_config_changed()
内部方法 mysql 连接配置变更检查
_init_db()
内部方法 初始化数据库（创建默认 config 键值表）
_require_driver()
内部方法 惰性导入 aiomysql，缺失时给出安装指引
async _create_loop_resource()
内部方法 当前事件循环的连接池（autocommit 模式）
async _destroy_loop_resource(resource: Any)
内部方法 优雅关闭连接池
async _acquire_resource_conn(resource: Any)
内部方法 从池中获取连接
async _release_resource_conn(resource: Any, conn: Any)
内部方法 归还连接到池
async _open_txn_conn()
内部方法 事务使用池内专用连接（获取与释放在同一事件循环上）
async _close_txn_conn(conn: Any)
内部方法 归还事务专用连接
async _begin_txn(conn: Any)
内部方法 BEGIN
async _commit_txn(conn: Any, handle: Any = None)
内部方法 COMMIT
async _rollback_txn(conn: Any, handle: Any = None)
内部方法 ROLLBACK
async _exec_query_on(kind: str, sql: str, params: Any, conn: Any)
内部方法 MySQL 执行漏斗
- kind (
"select"): / "one" / "count" / "dml" / "dml_multi" 返回值 (select/one): 返回 (行, 列名列表或None)；其余返回受影响行数