循序渐进PostgreSQL: 学习pqxx C++ API访问
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源码目录，备份并修改win32common文件，将PGSQLSRC的值指向正确的地方： 这里是PGSQLSRC="c:pgsql" 后边还有很多目录位置需要调整，针对我们这种情况，通常都是保留安装版本的设置，如：LIBPQINC=$(PGSQLSRC)include,而注释掉#LIBPQINC=$(PGSQLSRC)interfaceslibpq,其它几个值都如此类推。 2. 拷贝一些编译相关的头文件 针对具体版本，9.0的，将configsample-headerslibpq9.0pqxx复制到include下边 针对VS2008的，将configsample-headerscompilerVisualStudio2008pqxx复制到include目录下边,如果是VS2005，以此类推。 3. 编译 program files->VS2008-->Visual studio tools->Visual Studio 2008 Command Prompt,进入命令行， 在此进入libpqxx的源代码根目录，执行： nmake /f win32vc-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 "ObjDllReleasebinarystring.obj" "ObjDllReleaseconnection.obj" "ObjDllRelea seconnection_base.obj" "ObjDllReleasecursor.obj" "ObjDllReleasedbtransactio n.obj" "ObjDllReleaseerrorhandler.obj" "ObjDllReleaseexcept.obj" "ObjDllRel easefield.obj" "ObjDllReleaselargeobject.obj" "ObjDllReleasenontransaction. obj" "ObjDllReleasenotification.obj" "ObjDllReleasenotify-listen.obj" "ObjD llReleasepipeline.obj" "ObjDllReleaseprepared_statement.obj" "ObjDllRelease result.obj" "ObjDllReleaserobusttransaction.obj" "ObjDllReleasestatement_par ameters.obj" "ObjDllReleasestrconv.obj" "ObjDllReleasesubtransaction.obj" " ObjDllReleasetablereader.obj" "ObjDllReleasetablestream.obj" "ObjDllRelease tablewriter.obj" "ObjDllReleasetransaction.obj" "ObjDllReleasetransaction_ba se.obj" "ObjDllReleasetuple.obj" "ObjDllReleaseutil.obj" "ObjDllReleaselib pqxx.obj" /out:"liblibpqxx.dll" /implib:"liblibpqxx.lib" Creating library liblibpqxx.lib and object liblibpqxx.exp最终会在lib目录下生成： D:Projectshisql.svntrunklearninglibpqxx-4.0>dir/b/s lib D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpq.dll D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpq.lib D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxx.dll D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxx.dll.manifest D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxx.exp D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxx.lib D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxxD.dll D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxxD.dll.manifest D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxxD.exp D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxxD.ilk D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxxD.lib D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxxD.pdb D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxx_static.lib D:Projectshisql.svntrunklearninglibpqxx-4.0liblibpqxx_staticD.lib D:Projectshisql.svntrunklearninglibpqxx-4.0libmsdia80.dll 3. 简单示例
下边来看看最简单的示例,我们先创建示例用户foo,密码为foo1,并创建一个简单的表t (id,col),插入一条包含中文的记录，编码，可以看出，客户端为gbk。 iihero=# create user foo password 'foo1'; 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)：
需要注意的是，要将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. （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |