pqxx 重用/重新激活工作事务

Question

我想将 pqxx::work 用于多个查询和承诺，而 commit 功能阻止我再次使用它。 这是一个简单的例子：

pqxx::connection G_connexion("dbname=basetest user=usertest password=1234");
pqxx::work G_work(G_connexion);

int main(int argc, char* argv[]) {
    G_work.exec("insert into test.table1(nom) VALUES('foo');");
    G_work.commit();//until here, no problem
    G_work.exec("insert into test.table1(nom) VALUES('bar');"); //error, transaction already closed
    G_work.commit();
}

当我尝试插入 'bar' 值时，在提交后，我得到一个 pqxx::usage_error : Error executing query. Attempt to activate transaction<READ COMMITTED> which is already closed

提交更改后如何避免关闭连接？我可以使用 G_work=pqxx::work(G_connexion) 或其他的后续等效项来重置 G_work 吗？ 此外，一个错误的请求不应该使整个进程崩溃，而只是一个正在处理的请求（G_work 在失败后仍然可用）。

我必须保留相同的变量 G_Work，因为它将是一个从程序中很多地方调用的全局变量。

Answer 1

pqxx::work 只是一个pqxx::transaction<>，它的大部分逻辑最终都来自pqxx::transaction_base。

这个类不打算为多个事务服务。相反，它适用于 try/catch 块中的单个事务。它有一个状态成员变量 (m_Status)，即使在提交之后也不会重新初始化。

正常模式是：

{
    pqxx::work l_work(G_connexion);
    try {
        l_work.exec("insert into test.table1(nom) VALUES('foo');");
        l_work.commit();
    } catch (const exception& e) {
        l_work.abort();
        throw;
    }
}

可以说，libpqxx 可以在删除时回滚事务（以完全避免 try/catch），但事实并非如此。

这似乎不适合您的使用模式，因为您希望 G_work 成为可从程序中的多个位置访问的全局变量。请注意，pqxx::work 不是连接对象的类，而只是一种使用 C++ 异常处理封装开始/提交/回滚的方法。

尽管如此，libpqxx 还允许您在事务之外（或至少在 libpqxx 管理的事务之外）执行语句。您应该使用 pqxx::nontransaction 类的实例。

#include "pqxx/nontransaction"

pqxx::connection G_connexion("dbname=basetest user=usertest password=1234");
pqxx::nontransaction G_work(G_connexion);

int f() {
    G_work.exec("insert into test.table1(nom) VALUES('foo');");
    G_work.exec("insert into test.table1(nom) VALUES('bar');");
}

请注意，这相当于：

#include "pqxx/nontransaction"

pqxx::connection G_connexion("dbname=basetest user=usertest password=1234");

int f() {
    pqxx::nontransaction l_work(G_connexion);
    l_work.exec("insert into test.table1(nom) VALUES('foo');");
    l_work.exec("insert into test.table1(nom) VALUES('bar');");
}

最终，没有什么能阻止您使用pqxx::nontransaction 管理交易。如果您想要savepoints，则尤其如此。如果您的事务旨在超出函数范围（例如在全局范围内），我还建议使用 pqxx::nontransaction。

#include "pqxx/nontransaction"

pqxx::connection G_connexion("dbname=basetest user=usertest password=1234");
pqxx::nontransaction G_work(G_connexion);

int f() {
    G_work.exec("begin;");
    G_work.exec("insert into test.table1(nom) VALUES('foo');");
    G_work.exec("savepoint f_savepoint;");
    // If the statement fails, rollback to checkpoint.
    try {
        G_work.exec("insert into test.table1(nom) VALUES('bar');");
    } catch (const pqxx::sql_error& e) {
        G_work.exec("rollback to savepoint f_savepoint;");
    }
    G_work.exec("commit;");
}