c++怎么连接PostgreSQL数据库_c++ PostgreSQL数据库连接方法

#include <iostream>
#include <libpq-fe.h>

void checkConnStatus(HANDLE conn) {
    if (PQstatus(conn) != CONNECTION_OK) {
        std::cerr << "连接失败: " << PQerrorMessage(conn) << std::endl;
        PQfinish(conn);
        exit(1);
    }
}

int main() {
    // 连接字符串，根据你的数据库配置修改
    const char* conninfo = "host=localhost port=5432 dbname=testdb user=postgres password=yourpassword";

    // 建立连接
    PGconn* conn = PQconnectdb(conninfo);

    // 检查连接是否成功
    if (PQstatus(conn) == CONNECTION_BAD) {
        std::cerr << "无法连接到数据库: " << PQerrorMessage(conn) << std::endl;
        PQfinish(conn);
        return 1;
    }

    std::cout << "数据库连接成功！" << std::endl;

    // 执行一个简单查询
    PGresult* res = PQexec(conn, "SELECT version();");
    if (PQresultStatus(res) != PGRES_TUPLES_OK) {
        std::cerr << "查询失败: " << PQerrorMessage(conn) << std::endl;
        PQclear(res);
        PQfinish(conn);
        return 1;
    }

    // 输出结果
    std::cout << "PostgreSQL 版本: " << PQgetvalue(res, 0, 0) << std::endl;

    // 清理资源
    PQclear(res);
    PQfinish(conn);

    return 0;
}

#include <iostream>
#include <pqxx/pqxx>

int main() {
    try {
        pqxx::connection conn("host=localhost port=5432 dbname=testdb user=postgres password=yourpassword");
        pqxx::work txn(conn);
        pqxx::result result = txn.exec("SELECT version();");
        std::cout << "版本: " << result[0][0].c_str() << std::endl;
        txn.commit();
    } catch (const std::exception& e) {
        std::cerr << "错误: " << e.what() << std::endl;
        return 1;
    }
    return 0;
}