言库·海豚：MySQL 与 MariaDB 驱动

yanbao add mysql --package 言库海豚 --version "^1.0"

[依赖]
言库海豚 = { git = "https://github.com/yanxulang/yanxu-mysql.git", 修订 = "v1.0.0", 版 = "^1.0" }

[权限]
网络 = ["db.example:3306"]
原生扩展 = true

引「包:言库海豚」为 海豚；

定 配置：典 为 {
    「主机」：「db.example」，
    「端口」：3306，
    「数据库」：「account」，
    「用户」：「account-service」，
    「密码」：安全配置【「数据库密码」】，
    「TLS」：「验证完整」，
    「选项」：{
        「连接超时毫秒」：5000，
        「读取超时毫秒」：10000，
        「写入超时毫秒」：10000
    }
}；

定 数据库 为 海豚.打开配置（配置）；

数据库.执行（
    「CREATE TABLE users(id BIGINT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(64) NOT NULL, profile JSON NOT NULL)」，
    【】
）；

定 插入 为 数据库.预编译（
    「INSERT INTO users(name, profile) VALUES(%s, %s)」
）；

插入.执行（【「子衿」，{「等级」：10}】）；
言 插入.参数数（）；
插入.关闭（）；

定 用户 为 数据库.查询（
    「SELECT id, name, profile FROM users WHERE name = %s」，
    【「子衿」】
）.首行（）；

引「包:言库」为 言库；

法 转账（事务）则
    事务.执行（
        「UPDATE accounts SET balance = balance - %s WHERE id = %s」，
        【10，甲】
    ）；

    定 保存点 为 事务.保存点（）；
    保存点.执行（
        「UPDATE accounts SET balance = balance + %s WHERE id = %s」，
        【10，乙】
    ）；
    保存点.提交（）；
    归 「已提交」；
终

定 结果 为 数据库.托管事务（
    转账，
    言库.事务选项（）
        .隔离（「可重复读」）
        .只读（假）
        .超时（5000）
）；

定 选项 为 言库.执行选项（）
    .超时（2000）
    .请求标识（「report-20260718」）；

定 结果 为 数据库.查询带选项（SQL，参数，选项）；

定 池配置 为 言库.连接池配置（）
    .最小（2）
    .最大（16）
    .取得超时（2000）
    .空闲超时（300000）
    .最大生命周期（3600000）
    .健康间隔（30000）
    .等待上限（64）；

定 连接池 为 海豚.创建连接池（配置，池配置）；
定 租约 为 连接池.取得（）；

言 租约.查询（「SELECT CURRENT_TIMESTAMP AS current_time」，【】）.首行（）；
租约.释放（）；
连接池.关闭平缓（10000）；

逐 数据库名 于 数据库.模式清单（） 则
    言 数据库名；
终

定 结构 为 数据库.当前表结构（「users」）；
若 结构【「存在」】 则
    言 结构【「列」】；
    言 结构【「约束」】；
    言 结构【「索引」】；
    言 结构【「外键」】；
终

定 各迁移 为 【
    海豚.迁移（
        1，
        「创建用户」，
        「CREATE TABLE users(id BIGINT PRIMARY KEY) ENGINE=InnoDB」，
        「DROP TABLE users」
    ），
    海豚.迁移（
        2，
        「增加姓名」，
        「ALTER TABLE users ADD COLUMN name VARCHAR(64)」，
        「ALTER TABLE users DROP COLUMN name」
    ）
】；

定 迁移器 为 海豚.默认迁移器（数据库）；
言 迁移器.检查（各迁移）；
言 迁移器.干运行升级（各迁移）；
迁移器.升级（各迁移）；

定 写入值 为 数据库.言据写入值（资料，「原生结构」）；
数据库.执行（「INSERT INTO profiles(data) VALUES(%s)」，【写入值】）；

定 条件 为 数据库.言据路径（「data」，【「等级」】）.至少（10）；
定 各行 为 数据库.查询（
    （「SELECT data FROM profiles WHERE 」 加 条件.SQL），
    条件.参数（）
）.全部（）；