4

我正在学习 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", ?, ? );

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

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

4

3 回答 3

4

感谢@Eelke 对cname和的评论hold。

我想出了如何使 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;
}
于 2013-04-21T22:07:32.033 回答
2

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

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

该保持指的是游标的 WITH HOLD 选项，来自文档：

WITH HOLD 指定游标在创建它的事务成功提交后可以继续使用。WITHOUT HOLD 指定游标不能在创建它的事务之外使用。如果既未指定 WITHOUT HOLD 也未指定 WITH HOLD，则 WITHOUT HOLD 为默认值。

于 2013-04-21T06:11:38.597 回答
1

这是另一个游标示例，使用 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;
于 2020-02-17T22:25:08.083 回答