PostgreSQL連接C/C++接口實(shí)例
本教程講解C/C++連接PostgreSQL,使用libpqxx庫,這是官方的C++客戶端API用于連接PostgreSQL。libpqxx源代碼在BSD許可下,可以免費(fèi)下載,傳遞給他人,改變它或出售,它包括在你自己的代碼,并分享你的代碼更改。
安裝
libpqxx最新版本的可供下載鏈接下載libpqxx。所以下載的最新版本,并遵循以下步驟:Download Libpqxx.
- wget http://pqxx.org/download/software/libpqxx/libpqxx-4.0.tar.gz
- tar xvfz libpqxx-4.0.tar.gz
- cd libpqxx-4.0
- ./configure
- make
- make install
在開始使用C/C++ PostgreSQL界面,找到PostgreSQL安裝目錄pg_hba.conf文件中添加下面一行:
- # IPv4 local connections:
- host all all 127.0.0.1/32 md5
可以start/restart Postgres的服務(wù)器的情況下,它沒有運(yùn)行使用下面的命令:
- [root@host]# service postgresql restart
- Stopping postgresql service: [ OK ]
- Starting postgresql service:
C/C++ APIs
以下是重要接口例程可滿足工作需求與PostgreSQL數(shù)據(jù)庫的C/C + +程序。如果正在尋找一個(gè)更復(fù)雜的應(yīng)用程序,那么可以尋找到libpqxx官方文檔,或者可以使用商用的API。
連接到數(shù)據(jù)庫
以下C代碼段說明了如何在本地機(jī)器上運(yùn)行端口5432連接到一個(gè)現(xiàn)有的數(shù)據(jù)庫。在這里用斜線\續(xù)行。
- #include <iostream>
- #include <pqxx/pqxx>
- using namespace std;
- using namespace pqxx;
- int main(int argc, char* argv[])
- {
- try{
- connection C("dbname=testdb user=postgres password=cohondob \
- hostaddr=127.0.0.1 port=5432");
- if (C.is_open()) {
- cout << "Opened database successfully: " << C.dbname() << endl;
- } else {
- cout << "Can't open database" << endl;
- return 1;
- }
- C.disconnect ();
- }catch (const std::exception &e){
- cerr << e.what() << std::endl;
- return 1;
- }
- }
現(xiàn)在,讓我們編譯和運(yùn)行上面的程序,使用用戶postgres和密碼pass123訪問連接到我們的數(shù)據(jù)庫testdb。可以使用基于數(shù)據(jù)庫設(shè)置用戶ID和密碼。在給定的順序,記住要保持使用-lpqxx和-plq!否則,鏈接器將提示缺少以"pq"開始的函數(shù)名字。
- $g++ test.cpp -lpqxx -lpq
- $./a.out
- Opened database successfully: testdb
#p#
創(chuàng)建表
下面的C代碼段將被用于先前創(chuàng)建的數(shù)據(jù)庫中創(chuàng)建一個(gè)表:
- #include <iostream>
- #include <pqxx/pqxx>
- using namespace std;
- using namespace pqxx;
- int main(int argc, char* argv[])
- {
- char * sql;
- try{
- connection C("dbname=testdb user=postgres password=cohondob \
- hostaddr=127.0.0.1 port=5432");
- if (C.is_open()) {
- cout << "Opened database successfully: " << C.dbname() << endl;
- } else {
- cout << "Can't open database" << endl;
- return 1;
- }
- /* Create SQL statement */
- sql = "CREATE TABLE COMPANY(" \
- "ID INT PRIMARY KEY NOT NULL," \
- "NAME TEXT NOT NULL," \
- "AGE INT NOT NULL," \
- "ADDRESS CHAR(50)," \
- "SALARY REAL );";
- /* Create a transactional object. */
- work W(C);
- /* Execute SQL query */
- W.exec( sql );
- W.commit();
- cout << "Table created successfully" << endl;
- C.disconnect ();
- }catch (const std::exception &e){
- cerr << e.what() << std::endl;
- return 1;
- }
- return 0;
- }
上述程序編譯和執(zhí)行時(shí),它會在testdb數(shù)據(jù)庫,并創(chuàng)建COMPANY 表會顯示下面的語句:
- Opened database successfully: testdb
- Table created successfully
插入操作
下面的C代碼段顯示了我們?nèi)绾文軌蛟谏厦娴睦又袆?chuàng)建COMPANY 表中的記錄:
- #include <iostream>
- #include <pqxx/pqxx>
- using namespace std;
- using namespace pqxx;
- int main(int argc, char* argv[])
- {
- char * sql;
- try{
- connection C("dbname=testdb user=postgres password=cohondob \
- hostaddr=127.0.0.1 port=5432");
- if (C.is_open()) {
- cout << "Opened database successfully: " << C.dbname() << endl;
- } else {
- cout << "Can't open database" << endl;
- return 1;
- }
- /* Create SQL statement */
- sql = "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) " \
- "VALUES (1, 'Paul', 32, 'California', 20000.00 ); " \
- "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) " \
- "VALUES (2, 'Allen', 25, 'Texas', 15000.00 ); " \
- "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)" \
- "VALUES (3, 'Teddy', 23, 'Norway', 20000.00 );" \
- "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY)" \
- "VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 );";
- /* Create a transactional object. */
- work W(C);
- /* Execute SQL query */
- W.exec( sql );
- W.commit();
- cout << "Records created successfully" << endl;
- C.disconnect ();
- }catch (const std::exception &e){
- cerr << e.what() << std::endl;
- return 1;
- }
- return 0;
- }
上述程序編譯和執(zhí)行時(shí),它會創(chuàng)建COMPANY表中的記錄,并會顯示以下兩行:
- Opened database successfully: testdb
- Records created successfully