Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1323588
  • 博文数量: 185
  • 博客积分: 50
  • 博客等级: 民兵
  • 技术积分: 3934
  • 用 户 组: 普通用户
  • 注册时间: 2007-09-11 13:11
个人简介

iihero@ChinaUnix, ehero.[iihero] 数据库技术的痴迷爱好者. 您可以通过iihero AT qq.com联系到我 以下是我的三本图书: Sybase ASE in Action, Oracle Spatial及OCI高级编程, Java2网络协议内幕

文章分类

全部博文(185)

文章存档

2014年(4)

2013年(181)

分类: Mysql/postgreSQL

2013-07-29 09:47:30

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的值指向正确的地方:

    这里是PGSQLSRC="c:\pgsql"

    后边还有很多目录位置需要调整,针对我们这种情况,通常都是保留安装版本的设置,如: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, 

    得到如下中间过程:

  

  1.         link.exe kernel32.lib ws2_32.lib advapi32.lib /nologo /dll /machine:I386  
  2.  shell32.lib secur32.lib wldap32.lib /libpath:"C:\hisql-x86-2.0.1"\lib libpq.lib  
  3.   "ObjDllRelease\binarystring.obj"  "ObjDllRelease\connection.obj"  "ObjDllRelea  
  4. se\connection_base.obj"  "ObjDllRelease\cursor.obj"  "ObjDllRelease\dbtransactio  
  5. n.obj"  "ObjDllRelease\errorhandler.obj"  "ObjDllRelease\except.obj"  "ObjDllRel  
  6. ease\field.obj"  "ObjDllRelease\largeobject.obj"  "ObjDllRelease\nontransaction.  
  7. obj"  "ObjDllRelease\notification.obj"  "ObjDllRelease\notify-listen.obj"  "ObjD  
  8. llRelease\pipeline.obj"  "ObjDllRelease\prepared_statement.obj"  "ObjDllRelease\  
  9. result.obj"  "ObjDllRelease\robusttransaction.obj"  "ObjDllRelease\statement_par  
  10. ameters.obj"  "ObjDllRelease\strconv.obj"  "ObjDllRelease\subtransaction.obj"  "  
  11. ObjDllRelease\tablereader.obj"  "ObjDllRelease\tablestream.obj"  "ObjDllRelease\  
  12. tablewriter.obj"  "ObjDllRelease\transaction.obj"  "ObjDllRelease\transaction_ba  
  13. se.obj"  "ObjDllRelease\tuple.obj"  "ObjDllRelease\util.obj"  "ObjDllRelease\lib  
  14. pqxx.obj" /out:"lib\libpqxx.dll" /implib:"lib\libpqxx.lib"  
  15.    Creating library lib\libpqxx.lib and object lib\libpqxx.exp  
   最终会在lib目录下生成:
  1. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0>dir/b/s lib  
  2. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpq.dll  
  3. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpq.lib  
  4. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.dll  
  5. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.dll.manifest  
  6. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.exp  
  7. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx.lib  
  8. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.dll  
  9. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.dll.manifest  
  10. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.exp  
  11. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.ilk  
  12. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.lib  
  13. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxxD.pdb  
  14. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx_static.lib  
  15. D:\Projects\hisql.svn\trunk\learning\libpqxx-4.0\lib\libpqxx_staticD.lib  
  16. 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


  1. iihero=> create table t(id int primary key, col2 varchar(32));  
  2. 注意:  CREATE TABLE / PRIMARY KEY 将要为表 "t" 创建隐含索引 "t_pkey"  
  3. CREATE TABLE  
  4. iihero=> \encoding  
  5. GBK  
  6. iihero=> insert into t values(1 ,'不同类型的列表');  
  7. INSERT 0 1  
  8. iihero=> select * from t;  
  9.  id |      col2  
  10. ----+----------------  
  11.   1 | 不同类型的列表  
  12. (1 行记录)  

将编译出来后的include, lib目录提取到固定的目录,与你原来的postgresql的include和lib目录,可以合到一起。给开发使用。


下边是一个最简单的示例代码,只为体会一下连接及取一行最简单的结果(1):


  1. "code" class="cpp">#include   
  2.   
  3. #include   
  4.   
  5. int main()  
  6. {  
  7.     pqxx::connection conn("dbname=iihero hostaddr=127.0.0.1 user=foo password=foo1" );  
  8.     if(conn.is_open())  
  9.     {  
  10.         std::cout << "Connection succesful!" << std::endl;  
  11.         std::cout << conn.options()<
  12.     }  
  13.     else  
  14.     {  
  15.         std::cout << "Something went wrong... oops" << std::endl;  
  16.     }  
  17.     pqxx::work w(conn);  
  18.     pqxx::result res = w.exec("SELECT 1");  
  19.     w.commit();  
  20.   
  21.     std::cout << res[0][0].as<int>() << std::endl;  
  22. }  

  23.   

需要注意的是,要将libpq.lib, libpqxx.lib, 以及头文件都设置上。如果动态库链接方式出现问题,可以尝试使用libpqxx的静态库。

上边的pqxx::connection对象, 要传入一个字符串作为连接串,这个连接串要求以空格将关键字串隔开,这与libpq的连接串是一致的。

dbname= hostaddr= user= password=

关键字不能弄错。否则会报异常。当然,上边的代码写的非常不规范,只是作为演示。正常情况下,需要加入异常处理。


好,下边我们将代码稍改进一下。

4. 改进的代码


  1. #include   
  2.   
  3. #include   
  4.   
  5.   
  6. int main()  
  7. {  
  8.     try   
  9.     {  
  10.         pqxx::connection conn("dbname=iihero hostaddr=127.0.0.1 user=foo password=foo1" );  
  11.         if(conn.is_open())  
  12.         {  
  13.             std::cout << "Connection succesful!" << std::endl;  
  14.             std::cout << conn.options()<
  15.         }  
  16.         else  
  17.         {  
  18.             std::cout << "Something went wrong... oops" << std::endl;  
  19.         }  
  20.         pqxx::work w(conn);  
  21.         pqxx::result res = w.exec("SELECT 1");  
  22.         // w.commit();  
  23.   
  24.         std::cout << res[0][0].as<int>() << std::endl;  
  25.   
  26.         // 接着示例 访问表t中的数据, 先设置client端的字符集编码, 否则会出现乱码  
  27.         conn.set_client_encoding("GBK");  
  28.         pqxx::result r = w.exec("SELECT * FROM t");  
  29.   
  30.         for (pqxx::result::const_iterator row = r.begin(); row != r.end(); ++row)  
  31.         {      
  32.             for (pqxx::tuple::const_iterator field = row->begin();  
  33.                 field != row->end();  
  34.                 ++field)  
  35.                 std::cout << field->c_str() << '\t';  
  36.             std::cout << std::endl;  
  37.         }  
  38.   
  39.     }  
  40.     catch (std::exception& e)   
  41.     {  
  42.         std::cerr << e.what() << std::endl;  
  43.         return 1;  
  44.     }  
  45.     return 0;  
  46. }  

上边,我们看到,需要设置客户端的编码。通过一个迭代器来访问一个查询中的数据。


需要说明的是,libpqxx的在线文档写的非常的烂,示例代码居然是错误的。里边,

pqxx::result::tuple::const_iterator
压根就不能编译。应该是pqxx::tuple. 
阅读(7073) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~