PostgreSQL C/C++ 接口

本教程将使用 libpqxx 库，它是 PostgreSQL 的官方 C++ 客户端 API。 libpqxx 的源代码在 BSD 许可下可用，因此你可以自由下载、将其传递给其他人、更改它、出售它、将其包含在你自己的代码中，并与你选择的任何人共享你的更改。

安装

最新版本的 libpqxx 可从链接下载 下载 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 接口之前，找到 pg_hba.conf 在 PostgreSQL 安装目录中的文件中添加以下行： 

# IPv4 local connections:
host    all         all         127.0.0.1/32          md5

你可以使用以下命令启动/重启 postgres 服务器，以防它没有运行： 

[root@host]# service postgresql restart
Stopping postgresql service:                               [  OK  ]
Starting postgresql service:                               [  OK  ]

C/C++ 接口 API

以下是重要的接口例程，它们可以满足你从 C/C++ 程序使用 PostgreSQL 数据库的要求。如果你正在寻找更复杂的应用程序，那么你可以查看 libpqxx 官方文档，或者你可以使用商用 API。

序号 API & 描述
1

pqxx::connection C( const std::string & dbstring )

这是一个 typedef，将用于连接到数据库。这里，dbstring 提供了连接数据库所需的参数，例如 dbname = testdb 用户 = postgres 密码=pass123 hostaddr=127.0.0.1 port=5432 .

如果连接设置成功，那么它会创建带有连接对象的 C，该对象提供各种有用的函数公共函数。

2

C.is_open()

方法 is_open() 是连接对象的公共方法，返回布尔值。如果连接处于活动状态，则此方法返回 true，否则返回 false。

3

C.断开()

此方法用于断开已打开的数据库连接。

4

pqxx::work W( C )

这是一个 typedef，将用于使用连接 C 创建事务对象，最终将用于在事务模式下执行 SQL 语句。

如果事务对象创建成功，则将其分配给变量 W，该变量将用于访问与事务对象相关的公共方法。

5

W.exec(const std::string & sql)

这个来自事务对象的公共方法将用于执行 SQL 语句。

6

W.commit()

来自事务对象的这个公共方法将用于提交事务。

7

W.abort()

这个来自事务对象的公共方法将用于回滚事务。

8

pqxx::nontransaction N( C )

这是一个 typedef，将用于使用连接 C 创建非事务对象，最终将用于在非事务模式下执行 SQL 语句。

如果事务对象创建成功，则将其分配给变量 N，该变量将用于访问与非事务对象相关的公共方法。

9

N.exec(const std::string & sql)

这个来自非事务性对象的公共方法将用于执行 SQL 语句并返回一个结果对象，它实际上是一个包含所有返回记录的交互器。

连接到数据库

下面的 C 代码段显示了如何连接到在本地机器上运行的现有数据库的 5432 端口。在这里，我使用反斜杠 \ 来延续行。 

#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;
    }
}

现在，让我们编译并运行上面的程序来连接到我们的数据库 testdb ，它已经在你的模式中可用，可以使用用户访问 postgres 和密码 pass123 .

你可以根据你的数据库设置使用用户 ID 和密码。请记住按照给定的顺序保留 -lpqxx 和 -lpq！否则，链接器会抱怨缺少名称以“PQ”开头的函数。 

$g++ test.cpp -lpqxx -lpq
$./a.out
Opened database successfully: testdb

创建表

以下 C 代码段将用于在之前创建的数据库中创建表： 

#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;
}

当上面给出的程序被编译和执行时，它会在你的 testdb 数据库中创建 COMPANY 表并显示以下语句： 

Opened database successfully: testdb
Table created successfully

插入操作

以下 C 代码段展示了如何在上面示例中创建的 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;
}

当上述给定程序被编译和执行时，它会在 COMPANY 表中创建给定记录并显示以下两行： 

Opened database successfully: testdb
Records created successfully

选择操作

以下 C 代码段展示了我们如何从上面示例中创建的 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 = "SELECT * from COMPANY";

        /* Create a non-transactional object. */
        nontransaction N(C);
      
        /* Execute SQL query */
        result R( N.exec( sql ));
      
        /* List down all the records */
        for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
            cout << "ID = " << c[0].as<int>() << endl;
            cout << "Name = " << c[1].as<string>() << endl;
            cout << "Age = " << c[2].as<int>() << endl;
            cout << "Address = " << c[3].as<string>() << endl;
            cout << "Salary = " << c[4].as<float>() << endl;
        }
        cout << "Operation done successfully" << endl;
        C.disconnect ();
    } catch (const std::exception &e) {
        cerr << e.what() << std::endl;
        return 1;
    }

    return 0;
}

当上面给出的程序被编译和执行时，它会产生以下结果： 

Opened database successfully: testdb
ID = 1
Name = Paul
Age = 32
Address = California
Salary = 20000
ID = 2
Name = Allen
Age = 25
Address = Texas
Salary = 15000
ID = 3
Name = Teddy
Age = 23
Address = Norway
Salary = 20000
ID = 4
Name = Mark
Age = 25
Address = Rich-Mond
Salary = 65000
Operation done successfully

更新操作

下面的 C 代码段展示了我们如何使用 UPDATE 语句更新任何记录，然后从我们的 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 a transactional object. */
        work W(C);
        /* Create  SQL UPDATE statement */
        sql = "UPDATE COMPANY set SALARY = 25000.00 where ID=1";
        /* Execute SQL query */
        W.exec( sql );
        W.commit();
        cout << "Records updated successfully" << endl;
      
        /* Create SQL SELECT statement */
        sql = "SELECT * from COMPANY";

        /* Create a non-transactional object. */
        nontransaction N(C);
      
        /* Execute SQL query */
        result R( N.exec( sql ));
      
        /* List down all the records */
        for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
            cout << "ID = " << c[0].as<int>() << endl;
            cout << "Name = " << c[1].as<string>() << endl;
            cout << "Age = " << c[2].as<int>() << endl;
            cout << "Address = " << c[3].as<string>() << endl;
            cout << "Salary = " << c[4].as<float>() << endl;
        }
        cout << "Operation done successfully" << endl;
        C.disconnect ();
    } catch (const std::exception &e) {
        cerr << e.what() << std::endl;
        return 1;
    }

    return 0;
}

当上面给出的程序被编译和执行时，它会产生以下结果： 

Opened database successfully: testdb
Records updated successfully
ID = 2
Name = Allen
Age = 25
Address = Texas
Salary = 15000
ID = 3
Name = Teddy
Age = 23
Address = Norway
Salary = 20000
ID = 4
Name = Mark
Age = 25
Address = Rich-Mond
Salary = 65000
ID = 1
Name = Paul
Age = 32
Address = California
Salary = 25000
Operation done successfully

删除操作

以下 C 代码段展示了如何使用 DELETE 语句删除任何记录，然后从 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 a transactional object. */
        work W(C);
        /* Create  SQL DELETE statement */
        sql = "DELETE from COMPANY where ID = 2";
        /* Execute SQL query */
        W.exec( sql );
        W.commit();
        cout << "Records deleted successfully" << endl;
      
        /* Create SQL SELECT statement */
        sql = "SELECT * from COMPANY";

        /* Create a non-transactional object. */
        nontransaction N(C);
      
        /* Execute SQL query */
        result R( N.exec( sql ));
      
        /* List down all the records */
        for (result::const_iterator c = R.begin(); c != R.end(); ++c) {
            cout << "ID = " << c[0].as<int>() << endl;
            cout << "Name = " << c[1].as<string>() << endl;
            cout << "Age = " << c[2].as<int>() << endl;
            cout << "Address = " << c[3].as<string>() << endl;
            cout << "Salary = " << c[4].as<float>() << endl;
        }
        cout << "Operation done successfully" << endl;
        C.disconnect ();
    } catch (const std::exception &e) {
        cerr << e.what() << std::endl;
        return 1;
    }

    return 0;
}

当上面给出的程序被编译和执行时，它会产生以下结果： 

Opened database successfully: testdb
Records deleted successfully
ID = 3
Name = Teddy
Age = 23
Address = Norway
Salary = 20000
ID = 4
Name = Mark
Age = 25
Address = Rich-Mond
Salary = 65000
ID = 1
Name = Paul
Age = 32
Address = California
Salary = 25000
Operation done successfully
< 上一篇（PostgreSQL 有用的函数）
下一篇（PostgreSQL JAVA 接口） >

声明 :本网站尊重并保护知识产权，根据《信息网络传播权保护条例》，如果我们转载的作品侵犯了您的权利，请在一个月内通知我们（support@newbiego.com），我们会及时删除。

Copyright©小牛教程 2015-2021 粤ICP备15003982号