1. 简介
习惯了c++来开发的人,可能更倾向于使用c++库来访问PG。libpqxx很早以前就推出了。目前已经到了4.0版。本文就简单的介绍如何使用它,linux平台编译相对简单,这里就介绍一下windows平台下的使用。
libpqxx的下载地址:直接上这里http://pqxx.org/development/libpqxx/wiki/DownloadPage
由于libpqxx对libpq的C-API进行了很好的封装,从而可以节省大量的编码时间。
有关帮助文档,可以直接参考: libpqxx的手册http://pqxx.org/devprojects/libpqxx/doc/4.0/html/Tutorial
libpqxx的类库帮助:http://pqxx.org/devprojects/libpqxx/doc/4.0/html/Reference/
2. 编译过程
将libpqxx解压到一固定目录。你需要提前编译好或安装好的客户端库,通常为了方便,这里假定你已经有一个PG的安装版或者解压缩版,在c:\pgsql里头。以PG9.x为例。
1. 进入libpqxx源码目录,备份并修改win32\common文件,将PGsqlSRC的值指向正确的地方:
后边还有很多目录位置需要调整,针对我们这种情况,通常都是保留安装版本的设置,如:LIBPQINC=$(PGsqlSRC)\include,而注释掉#LIBPQINC=$(PGsqlSRC)\interfaces\libpq,其它几个值都如此类推。
2. 拷贝一些编译相关的头文件
针对具体版本,9.0的,将config\sample-headers\libpq\9.0\pqxx复制到include下边
针对VS2008的,将config\sample-headers\compiler\VisualStudio2008\pqxx复制到include目录下边,如果是VS2005,以此类推。
3. 编译
program files->VS2008-->Visual studio tools->Visual Studio 2008 Command Prompt,进入命令行, 在此进入libpqxx的源代码根目录,执行:
nmake /f win32\vc-libpqxx.mak ALL,
得到如下中间过程:
link.exe kernel32.lib ws2_32.lib advapi32.lib /nologo /dll /machine:I386 shell32.lib secur32.lib wldap32.lib /libpath:"C:\hisql-x86-2.0.1"\lib libpq.lib "ObjDllRelease\binarystring.obj" "ObjDllRelease\connection.obj" "ObjDllRelea se\connection_base.obj" "ObjDllRelease\cursor.obj" "ObjDllRelease\dbtransactio n.obj" "ObjDllRelease\errorhandler.obj" "ObjDllRelease\except.obj" "ObjDllRel ease\field.obj" "ObjDllRelease\largeobject.obj" "ObjDllRelease\nontransaction. obj" "ObjDllRelease\notification.obj" "ObjDllRelease\notify-listen.obj" "ObjD llRelease\pipeline.obj" "ObjDllRelease\prepared_statement.obj" "ObjDllRelease\ result.obj" "ObjDllRelease\robusttransaction.obj" "ObjDllRelease\statement_par ameters.obj" "ObjDllRelease\strconv.obj" "ObjDllRelease\subtransaction.obj" " ObjDllRelease\tablereader.obj" "ObjDllRelease\tablestream.obj" "ObjDllRelease\ tablewriter.obj" "ObjDllRelease\transaction.obj" "ObjDllRelease\transaction_ba se.obj" "ObjDllRelease\tuple.obj" "ObjDllRelease\util.obj" "ObjDllRelease\lib pqxx.obj" /out:"lib\libpqxx.dll" /implib:"lib\libpqxx.lib" Creating library lib\libpqxx.lib and object lib\libpqxx.exp最终会在lib目录下生成:
D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0>dir/b/s lib D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpq.dll D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpq.lib D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.dll D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.dll.manifest D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.exp D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.lib D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.dll D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.dll.manifest D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.exp D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.ilk D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.lib D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.pdb D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx_static.lib D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx_staticD.lib D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\msdia80.dll
3. 简单示例
下边来看看最简单的示例,我们先创建示例用户foo,密码为foo1,并创建一个简单的表t (id,col),插入一条包含中文的记录,编码,可以看出,客户端为gbk。
iihero=# create user foo password 'foo1';
CREATE ROLE
iihero=> create table t(id int primary key,col2 varchar(32)); 注意: CREATE TABLE / PRIMARY KEY 将要为表 "t" 创建隐含索引 "t_pkey" CREATE TABLE iihero=> \encoding GBK iihero=> insert into t values(1,'不同类型的列表'); INSERT 0 1 iihero=> select * from t; id | col2 ----+---------------- 1 | 不同类型的列表 (1 行记录)
将编译出来后的include,lib目录提取到固定的目录,与你原来的postgresql的include和lib目录,可以合到一起。给开发使用。
下边是一个最简单的示例代码,只为体会一下连接及取一行最简单的结果(1):
#include <iostream> #include <pqxx/pqxx> int main() { pqxx::connection conn("dbname=iihero hostaddr=127.0.0.1 user=foo password=foo1" ); 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; }
需要注意的是,要将libpq.lib,libpqxx.lib,以及头文件都设置上。如果动态库链接方式出现问题,可以尝试使用libpqxx的静态库。
上边的pqxx::connection对象,要传入一个字符串作为连接串,这个连接串要求以空格将关键字串隔开,这与libpq的连接串是一致的。
dbname=<database> hostaddr=<IP地址或主机名> user=<usrename> password=<password>
关键字不能弄错。否则会报异常。当然,上边的代码写的非常不规范,只是作为演示。正常情况下,需要加入异常处理。
好,下边我们将代码稍改进一下。
4. 改进的代码
#include <iostream> #include <pqxx/pqxx> int main() { try { pqxx::connection conn("dbname=iihero hostaddr=127.0.0.1 user=foo password=foo1" ); 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 t"); 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; } } catch (std::exception& e) { std::cerr << e.what() << std::endl; return 1; } return 0; }
上边,我们看到,需要设置客户端的编码。通过一个迭代器来访问一个查询中的数据。
需要说明的是,libpqxx的在线文档写的非常的烂,示例代码居然是错误的。里边,
pqxx::result::tuple::const_iterator压根就不能编译。应该是pqxx::tuple.