C++操作PostgreSQL存储过程实战

<p>pqxx调用PostgreSQL存储过程需改写为RETURNS TABLE或RETS SETOF并用SELECT * FROM调用；不可直接获取OUT参数，避免保存row/field引用，NULL值须先is_null()再as()，事务失败后须新建连接。</p>

如何用 pqxx 绑定参数调用 PostgreSQL 存储过程

pqxx 不支持类似 JDBC 的命名参数（如 :name）或自动类型推导绑定，所有参数必须按位置、显式类型、严格顺序传入 prepare() 或直接拼入 exec_params()。存储过程若声明为 LANGUAGE plpgsql 且含 INOUT 或 OUT 参数，pqxx 无法直接接收返回值——它只处理 SQL 查询结果集（SELECT），不解析函数返回的复合类型或多输出参数。

实际可行路径只有两条：

• 把存储过程改写为 RETURNS TABLE(...) 或 RETURNS SETOF record，并以 SELECT * FROM my_proc(...) 方式调用
• 若必须用 CALL（如带 OUT 参数的过程），则改用 exec("CALL my_proc(...)") + 单独 exec("FETCH ALL IN \"my_cursor\"")（需提前在过程内声明游标并 RETURN NEXT）

推荐第一种。例如 PostgreSQL 中定义：

CREATE OR REPLACE FUNCTION get_users_by_age(min_age INT) 
RETURNS TABLE(id INT, name TEXT, created_at TIMESTAMPTZ) AS $$
BEGIN
  RETURN QUERY SELECT u.id, u.name, u.created_at 
                FROM users u WHERE u.age >= min_age;
END;
$$ LANGUAGE plpgsql;

c++ 中调用：

auto txn = conn.transaction();
auto rs = txn.exec_params("SELECT * FROM get_users_by_age($1)", 
                         pqxx::binarystring{min_age});

pqxx 结果集遍历中容易崩溃的三个操作

常见错误不是语法错，而是生命周期管理失控。pqxx 的 result、row、field 全部是轻量引用，底层数据随 transaction 或 connection 销毁而释放。

• 不要保存 row 或 field 的裸指针/引用：它们不是独立拷贝
• 不要在 transaction 提交/回滚后访问 result —— 即使没报错，行为未定义
• 避免在循环中反复调用 row["col_name"].c_str() 并存为 const char*：每次调用都可能返回新地址，上一次的指针立刻失效

安全做法是立即转成 std::string 或 int 等值类型：

for (const auto &row : rs) {
  int id = row["id"].as();
  std::string name = row["name"].as();
  auto ts = row["created_at"].as();
}

处理 NULL 值和类型不匹配的健壮写法

pqxx 对 NULL 的处理很“硬”：调用 as() 时若字段为 NULL，直接抛 pqxx::conversion_error；而 is_null() 必须在 as() 前调用，否则已触发转换逻辑。

• 永远先检查 row["col"].is_null()，再决定是否调用 as()
• 对可空整数列，别用 as()，改用 as>()（pqxx 7.7+ 支持）
• 时间戳列优先用 as()，而非 as() 再手动解析——后者易因时区或格式差异失败

示例：

if (!row["score"].is_null()) {
  float score = row["score"].as();
} else {
  // 处理 NULL 分数逻辑
}

事务提交失败后连接状态与重试边界

pqxx 的 transaction 对象析构时会自动 rollback，但若网络中断或 backend 异常断连，commit() 抛出异常后，连接可能处于不可用状态（conn.is_open() == false）。此时不能复用原 connection 对象。

• 不要在 catch 块里直接 conn.reconnect() 后继续用旧 transaction —— 它已绑定到失效连接
• 重试逻辑必须新建 connection 和 transaction，且注意幂等性（存储过程本身是否可重入）
• 若过程含 INSERT ... RETURNING，重试前需确认上一次是否已写入（例如查主键是否存在）

连接恢复建议封装为工厂函数，避免裸 new / raw pointer：

std::unique_ptr make_conn() {
  return std::make_unique("host=localhost dbname=test");
}

实际中最容易被忽略的是：PostgreSQL 存储过程的 OUT 参数在 pqxx 里根本不可见，你看到的只是执行成功与否的状态码。想拿数据，就老老实实让它返回结果集。