libpq-PostgreSQL客户端编程接口（一）----libpq中的数据库连接

发布时间：2020-12-13 17:38:50 所属栏目：百科来源：网络整理

导读：PostgreSQL作为目前最优秀的跨平台的开源数据库，其介绍及优点这里不再赘述，它能让我以最快的速度忘记my*，ms*。libpq是PostgreSQL的C应用程序接口，它允许客户程序向PostgreSQL服务器进程发送查询并获得查询结果。我的实验环境是：操作系统：Linux wheez

PostgreSQL作为目前最优秀的跨平台的开源数据库，其介绍及优点这里不再赘述，它能让我以最快的速度忘记my*，ms*。libpq是PostgreSQL的C应用程序接口，它允许客户程序向PostgreSQL服务器进程发送查询并获得查询结果。

我的实验环境是：

操作系统：Linux wheezy 3.2.0-4-amd64 #1 SMP Debian 3.2.41-2 x86_64 GNU/Linux

数据库：EnterpriseDB （PostgreSQL Plus Advanced Server）9.2.1.3

示例语言：c++

工具：cmake2.8.9，g++ (Debian 4.7.2-5) 4.7.2

可能大家只知道PostgreSQL，对EnterpriseDB则比较陌生，这里简单介绍一下EnterpriseDB。EnterpriseDB是在PostgreSQL基础上，针对企业级应用进行了专门的优化，同时增加了一系列如动态性能调优(DynaTune)、EDB Loader、高效批量SQL处理等高级特性;另外EnterpriseDB与Oracle近乎完美的兼容性以及相对Oracle低廉的价格更是一大亮点，这些优异的特点加上IBM与Redhat的巨额注资，我看好它。EnterpriseDB的libpq与PostgreSQL开源版本完全一致，所以这里您也可以使用PostgreSQL。

一、准备项目文件CMakeLists.txt，设置libpq的依赖项

使用 libpq 的前端程序必须包括头文件 libpq-fe.h 并且必须与 libpq 库链接。我们创建一个简单的示例项目，并且用cmake作为项目管理工具，这样可以同时复习之前介绍过的cmake相关的知识。

创建CMakeLists.txt文件，里面的内容如下：

 
 
  
  project(edbconn)
  
  cmake_minimum_required(VERSION2.8)
  
  aux_source_directory(.SRC_LIST)
  
  add_executable(${PROJECT_NAME}${SRC_LIST})
  
  
  
  SET(PG_BASE"/opt/PostgresPlus/9.2AS")
  
  INCLUDE_DIRECTORIES("${PG_BASE}/include")
  
  LINK_DIRECTORIES("${PG_BASE}/lib")
  
  TARGET_LINK_LIBRARIES(${PROJECT_NAME}"${PG_BASE}/lib/libpq.so")

简单解释一下：

INCLUDE_DIRECTORIES("${PG_BASE}/include")

告诉编译器在哪里去找PostgreSQL的头文件，我的EnterpriseDB安装目录是在/opt/PostgresPlus/9.2AS，INCLUDE_DIRECTORIES("/opt/PostgresPlus/9.2AS/include")这样写也是一样的。

LINK_DIRECTORIES("/opt/PostgresPlus/9.2AS/lib")

告诉编译器外部依赖库，也就是libpq的位置

最后不要忘了告诉编译器依赖项

TARGET_LINK_LIBRARIES(${PROJECT_NAME} "/opt/PostgresPlus/9.2AS/lib/libpq.so")

二、用c++通过libpq连接PostgreSQL数据库

类似学习一门新的编程语言从hello world！开始，现在先从连接数据库开始。这次demo是用c++作为开发语言，我陆续会写写 C#与PostgreSQL相关的笔记。

别忘记包含libpq-fe.h头文件。

使用libpq连接PostgreSQL，首先要创建一个PGconn对象。

PGconn *conn；

1、PQconnectdb

定义：PGconn *PQconnectdb(const char *conninfo);

函数PQconnectdb的参数conninfo定义为：

 
 
  
  char*conninfo="hostaddr=127.0.0.1port=5444dbname=mydbuser=enterprisedbpassword=edb";

conninfo字符串指定数据库的连接信息，各参数之间用空格隔开。参数hostaddr指定数据库主机的IP地址，port指定EnterpriseDB的端口，dbname指定连接的数据库，user和password...。

conn = PQconnectdb(conninfo);

2、PQsetlogin

定义：PGconn *PQsetdbLogin(const char *pghost,

const char *pgport,

const char *pgoptions,

const char *pgtty,

const char *dbName,

const char *login,

const char *pwd);

如果没有给固定参数指定默认值，写NULL或一个空字符串就可以了。

 
 
  
  conn=PQsetdbLogin("localhost","5444",NULL,"mydb","enterprisedb","edb");

PQconnectdb和PQsetdbLogin函数区别不大，怎么用方便就怎么用。

三、连接状态函数

1、返回连接建立时的参数，这些值是固定的

返回连接的数据库名

char *PQdb(const PGconn *conn);

返回连接的用户名

char *PQuser(const PGconn *conn);

返回连接的密码

char *PQpass(const PGconn *conn);

返回连接的服务器主机名

char *PQhost(const PGconn *conn);

…

返回连接的端口

char *PQport(const PGconn *conn);

2、返回对PGconn对象操作时的状态数据

返回连接的状态。

ConnStatusType PQstatus(const PGconn *conn);

ConnStatusType的值最常用的两个是CONNECTION_OK或 CONNECTION_BAD。

 
 
  
  //判断与PostgreSQL的连接是否成功
  
  if(PQstatus(conn)!=CONNECTION_OK)
  
  {
  
  //donothing...
  
  }

查询服务器当前的参数设置

const char *PQparameterStatus(const PGconn *conn,const char *paramName);

参数paramName可使用的值有：server_version,server_encoding， client_encoding， session_authorization， DateStyle， TimeZone， integer_datetimes 和 standard_conforming_strings

 
 
  
  //PQparameterStatus
  
  //
  
  cout<<"server_version:"<<PQparameterStatus(conn,"server_version")<<endl;
  
  cout<<"server_encoding:"<<PQparameterStatus(conn,"server_encoding")<<endl;
  
  cout<<"client_encoding:"<<PQparameterStatus(conn,"client_encoding")<<endl;
  
  cout<<"session_authorization:"<<PQparameterStatus(conn,"session_authorization")<<endl;
  
  cout<<"DateStyle:"<<PQparameterStatus(conn,"DateStyle")<<endl;
  
  cout<<"TimeZone:"<<PQparameterStatus(conn,"TimeZone")<<endl;
  
  cout<<"integer_datetimes:"<<PQparameterStatus(conn,"integer_datetimes")<<endl;
  
  cout<<"standard_conforming_strings:"<<PQparameterStatus(conn,"standard_conforming_strings")<<endl;

返回连接中操作产生的最近的错误信息。

char *PQerrorMessage(const PGconn *conn);

返回当前连接的进程ID（PID）

int PQbackendPID(const PGconn *conn);

到这里，已经可以通过libpq连接到PostgreSQL数据库了。

 
 
  
  #include<iostream>
  
  
  
  #include"libpq-fe.h"
  
  
  
  usingnamespacestd;
  
  
  
  staticvoidexit_nicely(PGconn*conn)
  
  {
  
  PQfinish(conn);
  
  }
  
  
  
  intmain()
  
  {
  
  PGconn*conn;
  
  
  
  /*
  
  *PGconn*PQconnectdb(constchar*conninfo);
  
  */
  
  
  
  //constchar*conninfo="hostaddr=127.0.0.1port=5444dbname=mydbuser=enterprisedbpassword=edb";
  
  //conn=PQconnectdb(conninfo);
  
  conn=PQconnectdb("hostaddr=127.0.0.1port=5444dbname=mydbuser=enterprisedbpassword=edb");
  
  
  
  /*
  
  *PGconn*PQsetdbLogin(constchar*pghost,
  
  constchar*pgport,
  
  constchar*pgoptions,
  
  constchar*pgtty,
  
  constchar*dbName,
  
  constchar*login,
  
  constchar*pwd);
  
  */
  
  
  
  /*Makeaconnectiontothedatabase*/
  
  //conn=PQsetdbLogin("localhost","5444","mydb","enterprisedb","edb");
  
  
  
  /*Checktoseethatthebackendconnectionwassuccessfullymade*/
  
  if(PQstatus(conn)!=CONNECTION_OK)
  
  {
  
  cout<<"connectfailed.PQstatus:"<<PQstatus(conn)<<endl;
  
  //char*PQerrorMessage(constPGconn*conn);
  
  cout<<PQerrorMessage(conn)<<endl;
  
  exit_nicely(conn);
  
  
  
  return0;
  
  }
  
  
  
  //PQdb
  
  cout<<"数据库名:"<<PQdb(conn)<<endl;
  
  //PQuser
  
  cout<<"用户名:"<<PQuser(conn)<<endl;
  
  //PQpass
  
  cout<<"口令:"<<PQpass(conn)<<endl;
  
  
  
  switch(PQstatus(conn))
  
  {
  
  caseCONNECTION_STARTED:
  
  cout<<"正在连接..."<<endl;
  
  break;
  
  
  
  caseCONNECTION_MADE:
  
  cout<<"与服务器连接已建立..."<<endl;
  
  break;
  
  
  
  caseCONNECTION_AUTH_OK:
  
  cout<<"authisok."<<endl;
  
  break;
  
  
  
  caseCONNECTION_OK:
  
  cout<<"connected."<<endl;
  
  break;
  
  
  
  default:
  
  cout<<"正在连接..."<<endl;
  
  }
  
  
  
  cout<<"----------连接状态函数----------"<<endl;
  
  //
  
  //PQparameterStatus
  
  //server_version,server_encoding，client_encoding，session_authorization，DateStyle，TimeZone，integer_datetimes和standard_conforming_strings
  
  cout<<"server_version:"<<PQparameterStatus(conn,"standard_conforming_strings")<<endl;
  
  
  
  //PQprotocolVersion
  
  cout<<"PQprotocolVersion:"<<PQprotocolVersion(conn)<<endl;
  
  
  
  //PQbackendPID
  
  cout<<"PQbackendPID:"<<PQbackendPID(conn)<<endl;
  
  
  
  //PQgetssl
  
  cout<<"PQgetssl:"<<PQgetssl(conn)<<endl;
  
  
  
  PQfinish(conn);
  
  return0;
  
  }

作者：vincent zhang
出处：http://ode.cnblogs.com http://odevincent.blog.51cto.com
Email：wsaspx#hotmail.com

本作品由vincent zhang创作，采用知识共享署名-非商业性使用-禁止演绎 3.0 中国大陆许可协议进行许可。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!