如何在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

這個示例將向表中插入兩行數據。您可以根據需要修改代碼以執行其他類型的批量操作（如更新、刪除等）。