如何在C++中执行PostgreSQL批量操作

在C++中执行PostgreSQL批量操作，您可以使用libpqxx库

sudo apt-get install libpqxx-dev

接下来，创建一个C++源文件（例如：batch_operations.cpp），并包含以下代码：

#include <iostream>
#include <pqxx/pqxx>
#include <vector>
#include <string>

void execute_batch(const std::string &connection_info, const std::vector<std::string> &queries) {
    try {
        // 创建一个连接到PostgreSQL服务器的对象
        pqxx::connection conn(connection_info);
        if (conn.is_open()) {
            std::cout << "Opened database successfully" << std::endl;
        } else {
            std::cerr << "Can't open database" << std::endl;
            return;
        }

        // 开始一个事务
        pqxx::nontransaction tx(conn);

        // 创建一个准备语句对象
        pqxx::prepare pstmt("INSERT INTO your_table (column1, column2) VALUES ($1, $2)");

        // 开始批量操作
        pqxx::work batch(tx);

        // 遍历查询向量并执行批量插入
        for (const auto &query : queries) {
            pqxx::result r = batch.exec(pstmt, query);
            if (r.affected_rows() > 0) {
                std::cout << "Inserted row: " << query << std::endl;
            } else {
                std::cerr << "Failed to insert row: " << query << std::endl;
            }
        }

        // 提交事务
        batch.commit();
        std::cout << "Batch operations completed" << std::endl;
    } catch (const std::exception &e) {
        std::cerr << "Error: " << e.what() << std::endl;
    }
}

int main() {
    std::string connection_info = "dbname=your_database user=your_user password=your_password host=your_host port=your_port";
    std::vector<std::string> queries = {"INSERT INTO your_table (column1, column2) VALUES ('value1', 'value2')",
                                       "INSERT INTO your_table (column1, column2) VALUES ('value3', 'value4')"};

    execute_batch(connection_info, queries);

    return 0;
}

请确保将your_database、your_user、your_password、your_host、your_port、your_table、column1、column2以及value1、value2等占位符替换为您的实际数据库连接信息和数据。

编译代码：

g++ -o batch_operations batch_operations.cpp -lpqxx -lpq

运行编译后的程序：

./batch_operations

这个示例将向表中插入两行数据。您可以根据需要修改代码以执行其他类型的批量操作（如更新、删除等）。