如何使用 libpqxx 中的 pqxx::stateless_cursor 类？答案

【问题标题】：How to use pqxx::stateless_cursor class from libpqxx?如何使用 libpqxx 中的 pqxx::stateless_cursor 类？
【发布时间】：2013-04-21 05:02:52
【问题描述】：

我正在学习 libpqxx，它是 PostgreSQL 的 C++ API。我想使用 pqxx::stateless_cursor 类，但是 1) 我发现 Doxygen 输出在这种情况下没有帮助，2) pqxx.org 网站已经关闭了一段时间。

有人知道怎么用吗？

我相信这就是我构建的方式：

pqxx::stateless_cursor <pqxx::cursor_base::read_only, pqxx::cursor_base::owned>
    cursor( work, "SELECT * FROM mytable", ?, ? );

最后两个参数称为 cname 和 hold，但没有记录。

一旦创建了游标，我将如何在 for() 循环中使用它来获取每一行，一次一个？

【问题讨论】：

标签： c++ postgresql libpqxx

【解决方案1】：

感谢@Eelke 在cname 和hold 上的cmets。

我想出了如何使 pqxx::stateless_cursor 工作。我不知道是否有更清洁或更明显的方法，但这里有一个例子：

pqxx::work work( conn );
pqxx::stateless_cursor<pqxx::cursor_base::read_only, pqxx::cursor_base::owned>
    cursor( work, "SELECT * FROM mytable", "mycursor", false );

for ( size_t idx = 0; true; idx ++ )
{
    pqxx::result result = cursor.retrieve( idx, idx + 1 );
    if ( result.empty() )
    {
        // nothing left to read
        break;
    }

    // Do something with "result" which contains a single
    // row in this example since we told the cursor to
    // retrieve row #idx (inclusive) to idx+1 (exclusive).
    std::cout << result[ 0 ][ "name" ].as<std::string>() << std::endl;
}

【讨论】：

【解决方案2】：

我不知道 pqxx 库，但我猜是基于 postgresql 的底层 DECLARE 命令

cname 是游标的名称，所以它可以是 postgresql 通常接受的任何游标名称。

hold 指的是光标的 WITH HOLD 选项，来自文档：

WITH HOLD 指定光标在创建它的事务成功提交。无保留指定游标不能在事务之外使用创造了它。如果既没有指定 WITHOUT HOLD 也没有指定 WITH HOLD， WITHOUT HOLD 是默认设置。

【讨论】：

【解决方案3】：

这是另一个游标示例，使用 do-while() 循环：

     const std::conStr("user=" + opt::dbUser + " password=" + opt::dbPasswd + " host=" + opt::dbHost + " dbname=" + opt::dbName);                                            

      pqxx::connection conn(connStr);
      pqxx::work txn(conn);
      std::string selectString = "SELECT id, name FROM table_name WHERE condition";

      pqxx::stateless_cursor<pqxx::cursor_base::read_only, pqxx::cursor_base::owned> 
      cursor(txn, selectString, "myCursor", false);

      //cursor variables
      size_t idx = 0;       //starting location
      size_t step = 10000;  //number of rows for each chunk
      pqxx::result result;
      do{
        //get next cursor chunk and update the index
        result = cursor.retrieve( idx, idx + step );
        idx += step;

        size_t records = result.size();
        cout << idx << ": records pulled = " << records << endl;

        for( pqxx::result::const_iterator row : result ){
          //iterate over cursor rows
        }
      }
      while( result.size() == step ); //if the result.size() != step, we're on our last loop
      cout << "Done!" << endl;

【讨论】：