言库·象城：PostgreSQL 驱动

yanbao add postgres --package 言库象城 --version "^1.0"

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

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

引「包:言库象城」为 象城；

定 数据库 为 象城.打开配置（{
    「地址」：「postgresql://app@db.example/app」，
    「密码」：安全配置【「数据库密码」】，
    「应用名」：「account-service」，
    「TLS」：「验证完整」，
    「选项」：{
        「连接超时毫秒」：5000
    }
}）；

数据库.执行（
    「CREATE TEMP TABLE users(id BIGSERIAL PRIMARY KEY, name TEXT NOT NULL, profile JSONB NOT NULL)」，
    【】
）；

定 插入 为 数据库.预编译（
    「INSERT INTO users(name, profile) VALUES($1, $2) RETURNING id」
）；

定 编号 为 插入.查询（【「子衿」，{「等级」：10}】）.标量（）；
插入.关闭（）；

定 用户 为 数据库.查询（
    「SELECT id, name, profile FROM users WHERE id = $1」，
    【编号】
）.首行（）；

引「包:言库」为 言库；

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

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

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

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

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

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

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

试 则
    言 租约.查询（「SELECT now() AS current_time」，【】）.首行（）；
    租约.释放（）；
救 所误 则
    租约.释放（）；
    抛 所误；
终

连接池.关闭平缓（10000）；

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

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

定 各迁移 为 【
    象城.迁移（
        1，
        「创建用户」，
        「CREATE TABLE users(id BIGINT PRIMARY KEY)」，
        「DROP TABLE users」
    ），
    象城.迁移（
        2，
        「增加姓名」，
        「ALTER TABLE users ADD COLUMN name TEXT」，
        「ALTER TABLE users DROP COLUMN name」
    ）
】；

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

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

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