结果，例如返回，来自未提交的高管？

Question

使用 libpqxx，是否可以让一个 execs 但尚未被 committed 的准备好的语句将结果存储在 result 中以供以后准备好的语句中使用？

如果是这样，如何做到这一点？

代码

为了便于阅读，我已经对其进行了精简，但这基本上是我想要做的：

void prepare_write_parent_table(connection_base &c){
    try
    {
        c.prepare("write_parent_table", 
            "INSERT INTO parent_table (column_1) "
            "SELECT $1 "
            "RETURNING id"
        )
        ("character", pqxx::prepare::treat_string);
    }
    catch (const exception &e)
    {
        cerr << e.what() << endl;
    }
}

string write_parent_table(transaction_base &t, string data){
    try
    {
        result parent_table_result = t.prepared("write_parent_table")(data).exec();
        return parent_table_result[0][0].c_str();

    }
    catch (const exception &e)
    {
        cerr << e.what() << endl;
        return "";
    }
}

void prepare_write_child_table(connection_base &c){
    try
    {
        c.prepare("write_child_table", 
            "INSERT INTO child_table (parent_table_id, column_a) "
            "SELECT $1, $2 "
        )
        ("character", pqxx::prepare::treat_string)
        ("character", pqxx::prepare::treat_string);
    }
    catch (const exception &e)
    {
        cerr << e.what() << endl;
    }
}

检查来自write_parent_table 的return 以查看if( == "")。如果不是，则继续；否则，我将在那里commit 让它失败，或者如果可能的话最好取消交易；但是，如果可能的话，我还不知道该怎么做。

INSERTs 到 child_table 每 parent_table INSERT 的数量总是不确定的。

Answer 1

通过使用data-modifying CTE 对两个插入使用单个 SQL 语句来简化操作。这比在客户端中存储中间状态要快得多。

子表中的INSERT 仅在父表中的第一个INSERT 成功并返回id 时发生：

void prepare_write_both_tables(connection_base &c){
    try
    {
       c.prepare("write_both_tables", 
          "WITH p AS ("
             "INSERT INTO parent_table (column_1) "
             "SELECT $1 "
             "RETURNING id) "
          "INSERT INTO child_table (parent_table_id, column_a) "
          "SELECT p.id, $2 "
          "FROM   p"
        )
        ("character", pqxx::prepare::treat_string)
        ("character", pqxx::prepare::treat_string);
    }
    catch (const exception &e)
    {
        cerr << e.what() << endl;
    }
}

Search for [postgres] & "data-modifying CTE" 了解更多示例。
也称为“可写 CTE”（或“可写 CTE”）。

多个孩子

对于 单个 父级和 0 到多个 子级：

void prepare_write_both_tables(connection_base &c){
    try
    {
       c.prepare("write_both_tables", 
          "WITH p AS ("
             "INSERT INTO parent_table (column_1) "
             "SELECT $1 "
             "RETURNING id) "
          "INSERT INTO child_table (parent_table_id, column_a) "
          "SELECT p.id, a "
          "FROM   p, unnest($2::text[]) AS a"
        )
        ("character", pqxx::prepare::treat_string)
        ("character", pqxx::prepare::treat_string);
    }
    catch (const exception &e)
    {
        cerr << e.what() << endl;
    }
}

其中第二个参数是文本表示形式的array of text。示例：

{foo,bar,baz}

这会插入与文本数组中的元素一样多的行。对于 0 个孩子，传递 NULL 或一个空数组 {}。