如何使用libpq-fe创建并连接新数据库？C语言技术问询

要实现创建并连接新数据库，核心逻辑是先连接到PostgreSQL已存在的系统数据库（如默认的postgres或template1），执行创建数据库的SQL语句，再重新连接新创建的数据库。直接连接不存在的数据库必然报错，因为libpq需要先通过现有数据库建立会话。

完整实现代码示例 #

#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>

// 错误处理辅助函数
void handle_error(PGconn *conn, PGresult *res) {
    fprintf(stderr, "错误: %s\n", PQerrorMessage(conn));
    if (res != NULL) {
        PQclear(res);
    }
    PQfinish(conn);
    exit(EXIT_FAILURE);
}

int main() {
    // 1. 连接到已存在的postgres数据库
    const char *conninfo = "host=localhost user=postgres password=your_password dbname=postgres";
    PGconn *conn = PQconnectdb(conninfo);

    // 检查连接状态
    if (PQstatus(conn) != CONNECTION_OK) {
        handle_error(conn, NULL);
    }
    printf("已成功连接到postgres数据库\n");

    // 2. 执行CREATE DATABASE语句
    const char *create_db_sql = "CREATE DATABASE my_new_db";
    PGresult *res = PQexec(conn, create_db_sql);

    // 检查执行结果：CREATE DATABASE的成功状态是PGRES_COMMAND_OK
    if (PQresultStatus(res) != PGRES_COMMAND_OK) {
        handle_error(conn, res);
    }
    printf("新数据库my_new_db创建成功\n");
    PQclear(res);

    // 3. 关闭原有连接
    PQfinish(conn);

    // 4. 连接新创建的数据库
    const char *new_conninfo = "host=localhost user=postgres password=your_password dbname=my_new_db";
    PGconn *new_conn = PQconnectdb(new_conninfo);

    if (PQstatus(new_conn) != CONNECTION_OK) {
        handle_error(new_conn, NULL);
    }
    printf("已成功连接到新数据库my_new_db\n");

    // 后续操作：在这里执行新数据库的相关逻辑

    // 清理资源
    PQfinish(new_conn);
    return EXIT_SUCCESS;
}

关键注意事项 #

• 连接参数调整：把代码中的host、user、password替换成你的PostgreSQL实际配置。
• 数据库存在处理：如果要避免重复创建报错，可以修改SQL语句为CREATE DATABASE IF NOT EXISTS my_new_db（PostgreSQL 11+支持该语法）。
• 权限要求：连接数据库的用户需要有CREATEDB权限，否则会执行失败。
• 资源清理：所有PGresult对象必须用PQclear释放，PGconn对象必须用PQfinish关闭，避免内存泄漏。

内容的提问来源于stack exchange，提问作者aziz aon