我正在学习libpqxx, PostgreSQL的c++ API。我想使用pqxx::stateless_cursor类,但是1)我发现在这种情况下氧输出没有帮助,2)pqxx.org网站现在已经关闭了一段时间。
有人知道怎么用吗?
我相信我是这样构造的:
pqxx::stateless_cursor <pqxx::cursor_base::read_only, pqxx::cursor_base::owned>
cursor( work, "SELECT * FROM mytable", ?, ? );
最后两个参数称为cname
和hold
,但没有记录。
一旦创建了游标,我将如何在for()循环中使用它来获取每一行,一次一个?
感谢@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;
}
我不知道pqxx库,但基于postgresql的底层DECLARE命令,我猜
该cname是游标的名称,所以它可以是postgresql通常接受的游标名称。
这个hold指的是游标的WITH hold选项,来自文档:
WITH HOLD指定该游标可以在操作结束后继续使用创建它的事务成功提交。没有举行指定不能在事务之外使用游标这就产生了它。如果没有指定WITHOUT HOLD和WITH HOLD,默认为"WITHOUT HOLD"
下面是另一个使用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;