libpqxx总结（包含例子解释）

1、例子 //test.cpp #include <iostream> #include <pqxx/pqxx> using namespace std; using namespace pqxx; int main() { try { connection Conn("dbname=test_db"); cout << "Connected to " << Conn.dbname() << endl; transaction<> Xaction(Conn, "DemoTransaction"); result R = Xaction.exec("SELECT name FROM user_t"); cout << "Found " << R.size() << "employees:" << endl; for (result::const_iterator r = R.begin(); r != R.end(); ++r) { cout << r[0].c_str() << endl; } Xaction.commit(); cout << "ok." << endl; } catch (const exception &e) { cerr << e.what() << endl; return 1; } return 0; } 2、编译 gcc -Wall -pedantic test.cpp -o test -lpqxx -I/usr/include/postgresql 3、解释 -lpqxx ：libpqxx库，编译时必须包含 -I/usr/include/postgresql ：-I指明路径，/usr/include/postgresql是postgresql SQL语句应该包含的头文件路径 connection 是连接类 Conn是一个连接的对象，该对象只能在被声明时用默认的构造函数进行初始化， 初始化使用一个字符串，为"dbname=" + "test_db"，前部分"dbname="为固定串，后部分"test_db"为数据库名。 transaction<> 为事务类 Xaction是一个事务对象，该对象只能在被声明时用默认的构造函数进行初始化， 初始化使用两个参数，前一个为连接对象，后一个为一个任意字符串（包括空串""，不能用NULL），对该事务进行描述。 事务Xaction调用exec()函数执行sql语句，参数为sql语句的字符串。 sql语句：由于exec()函数接收string类型参数，所以，得先把sql语句转换成string类型。 例1： string strSQL = "SELECT name FROM user_t"; Xaction.exec(strSQL); 例2： int iID = 5; string strID = "5"; string strSQL = "SELECT name FROM user_t WHERE id=" + iID; //NG string strSQL = "SELECT name FROM user_t WHERE id=" + strID; //ok Xaction.exec(strSQL); 例3： string strName1 = "xiaoming"; string strName2 = "'" + "xiaoming" + "'"; string strSQL = "SELECT id FROM user_t WHERE name=" + strName1; //NG string strSQL = "SELECT id FROM user_t WHERE name=" + strName2; //ok 数据库中的字符串需要加单引号 Xaction.exec(strSQL); result 是存储查询结果的类，R是一个结果对象，对R的遍历有两种方式， 方式1： for (result::const_iterator r = R.begin(); r != R.end(); ++r) { cout << r[0].c_str() << endl; } r[0]是一个filed类对象，查询结果表（result）中的第1列用r[0]表示，也可用列名表示如：r["name"]。 c_str()是filed类的成员函数，返回char*类型。一般可以用这样的语句string strName = r["name"].c_str(); 方式2： for (int i = 0; i < R.size(); i++) { cout << R[i]["id"].c_str() << endl; } R[i]["id"]是一个filed类对象，表示 i行"id"列的filed。R.size()表示行数。 Xaction.commit()是提交事务。 进一步了解： libpqxx，请参照http://pages.cs.wisc.edu/~ajkunen/libpqxx-2.4.2/Reference/annotated.html postgresql，请参照http://www.postgresql.org/docs/8.0/interactive/index.html try { pqxx::connection conn("dbname=test1 hostaddr=127.0.0.1 user=xxx password=xxx" ); if(conn.is_open()) { std::cout << "Connection succesful!" << std::endl; std::cout << conn.options()<<std::endl; } else { std::cout << "Something went wrong... oops" << std::endl; } pqxx::work w(conn); //pqxx::result res = w.exec("SELECT 1"); // w.commit(); //std::cout << res[0][0].as<int>() << std::endl; // 接着示例 访问表t中的数据, 先设置client端的字符集编码, 否则会出现乱码 conn.set_client_encoding("GBK"); pqxx::result r = w.exec("SELECT * FROM xxx"); for (pqxx::result::const_iterator row = r.begin(); row != r.end(); ++row) { for (pqxx::tuple::const_iterator field = row->begin();field != row->end();++field) { std::cout << field->c_str() << '\t'; } std::cout << std::endl; } conn.disconnect(); } catch (std::exception& e) { std::cerr << e.what() << std::endl; return 1; }