Windows環境C/C++訪問PostgreSQL主要有兩種方式:利用Qt封裝的數據庫訪問組件、利用PostgreSQL的API函數。使用Qt平台訪問PostgreSQL的局限性很大,一旦脫離了訪問組件,數據庫就無法操作。使用數據庫自帶的API函數訪問數據庫具有較好的性能,但是API函數操作、理解比較難,網上相關資料少時需要閱讀API文檔。
1、環境配置
(1)文本使用的IDE是VS2010,我們需要配置包含目錄(include)、庫目錄(lib)、鏈接器輸入附加依賴(libpq.lib);

(2)工程目錄下需要加入4個dll文件(libeay32.dll、libintl.dll、libpq.dll、ssleay32.dll),這些文件都能在PostgreSQL安裝目錄下找到;
(3)工程cpp文件中加入頭文件#include <libpq-fe.h>,libpq-fe.h頭文件包含了API接口函數聲明及注釋,下面介紹的函數在libpq-fe.h中都能找到。
2、連接數據庫
(1)數據庫連接函數
extern PGconn *PQsetdbLogin(const char *pghost, const char *pgport,
const char *pgoptions, const char *pgtty,
const char *dbName,
const char *login, const char *pwd);
返回值PGconn *指針,即連接指針。如果你要對PQsetdbLogin函數封裝的話,記得將形參連接指針設成PGconn *&引用類型,因為連接函數需要對連接指針修改,而不是修改對象!pghost:主機地址,本機為127.0.0.1或localhost;pgport:端口值,一般為5432;pgoptions:額外選項,NULL即可;pgtty:NULL即可;dbName:數據庫名;user:用戶名;pwd:密碼;
(2)錯誤顯示函數extern char *PQerrorMessage(const PGconn *conn)
當連接有誤時,可以使用PQerrorMessage函數顯示出錯信息。
封裝成ConnectToDB函數:
bool ConnectToDB(PGconn *&conn,char *pghost,char *pgport,char *dbname,char *user,char *pwd)
{
//pgoptions、pgtty參數默認為NULL
char *pgoptions,*pgtty;
pgoptions=NULL;
pgtty=NULL;
conn=PQsetdbLogin(pghost,pgport,pgoptions,pgtty,dbname,user,pwd);
if(PQstatus(conn)==CONNECTION_BAD) // or conn==NULL
{
cout<<"Connection db "<<dbname<<" failed!"<<endl;
cout<<PQerrorMessage(conn)<<endl;
return false;
}
else
{
cout<<"Connection db "<<dbname<<" success!"<<endl;
return true;
}
}
3、執行SQL語句
執行SQL語句主要是增刪改查,只有查詢會返回有效記錄集。
(1)SQL執行函數extern PGresult *PQexec(PGconn *conn, const char *query)
返回值PGresult *:查詢集指針;conn:連接指針;query:SQL語句;
(2)元組數函數extern int PQntuples(const PGresult *res)
返回值:查詢集中記錄數;res:查詢集指針;
(3)字段數函數extern int PQnfields(const PGresult *res)
返回值:每條記錄中列數(字段數);res:查詢集指針;
(4)取值函數extern char *PQgetvalue(const PGresult *res, int tup_num, int field_num);
返回值:查詢集中每個位置的值;res:查詢集指針;tup_num:行號,從0開始;field_num:列號,從0開始;
封裝成ExecSQL函數:
bool ExecSQL(PGconn *conn,const char *sql)
{
PGresult *res=NULL;
if(conn==NULL)
{
cout<<"Conn is null"<<endl;
return false;
}
else
{
res=PQexec(const_cast<PGconn *>(conn),sql);
if(res==NULL)
{
return false;
}
else
{
// 輸出記錄
int tuple_num=PQntuples(res);
int field_num=PQnfields(res);
for(int i=0;i<tuple_num;++i)
{
for(int j=0;j<field_num;++j)
cout<<PQgetvalue(res,i,j)<<" ";
cout<<endl;
}
ClearQuery(res);
return true;
}
}
}
4、關閉連接
(1)查詢集清理函數extern void PQclear(PGresult *res)res:查詢集指針;
(1)關閉連接函數extern void PQfinish(PGconn *conn)conn:連接指針;
5、錯誤查詢
許多時候執行SQL語句后,數據表沒有變化,程序也不報錯,這種情況很難發現錯誤。我們需要使用PostgreSQL提供的errorMessage和status函數追蹤程序變量的狀態。
比如:
(1)PQerrorMessage函數提供了PGconn連接指針的出錯信息;
(2)PQresultErrorMessage函數提供了PGresult查詢集指針的出錯信息;
(3)PQresultStatus函數返回查詢集指針的狀態信息ExecStatusType,這是個枚舉enum類型:
typedef enum
{
PGRES_EMPTY_QUERY = 0, /* empty query string was executed */
PGRES_COMMAND_OK, /* a query command that doesn't return
* anything was executed properly by the
* backend */
PGRES_TUPLES_OK, /* a query command that returns tuples was
* executed properly by the backend, PGresult
* contains the result tuples */
PGRES_COPY_OUT, /* Copy Out data transfer in progress */
PGRES_COPY_IN, /* Copy In data transfer in progress */
PGRES_BAD_RESPONSE, /* an unexpected response was recv'd from the
* backend */
PGRES_NONFATAL_ERROR, /* notice or warning message */
PGRES_FATAL_ERROR, /* query failed */
PGRES_COPY_BOTH, /* Copy In/Out data transfer in progress */
PGRES_SINGLE_TUPLE /* single tuple from larger resultset */
} ExecStatusType;
有了這些工具,發現錯不是難事!
最后附上PostgreSQL中文文檔:PostgreSQL Document、API接口文檔
轉載自:http://tanhp.com/index.php/archives/208/
