如何用C语言向PostgreSQL的measurements表插入float值？

错误原因分析 #

1. 第一个类型不兼容错误：
   PQexecParams的第5个参数paramValues要求的是const char *const *类型，也就是指向字符串数组的指针（每个元素对应一个参数的字符串表示）。你直接传单个char*（buffer_theta0），类型不匹配，所以编译器报错。

2. 第二个内存访问错误：
   你改成字符串数组后，未明确指定参数类型（paramTypes传了NULL），PostgreSQL可能无法正确推断参数类型，导致libpq内部处理时触发内存访问错误；另外用sprintf存在缓冲区溢出风险，也可能引发内存异常。

正确实现方式 #

方式一：文本格式传递（格式化float为字符串） #

用snprintf安全格式化float，明确指定参数类型，避免类型推断错误：

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

// 假设conn已正确连接数据库
float theta = 0.2;
char buffer_theta0[32]; // 预留足够缓冲区，避免溢出
// 用snprintf代替sprintf，防止缓冲区越界
snprintf(buffer_theta0, sizeof(buffer_theta0), "%.6f", theta);

// 构造参数数组：每个元素对应一个SQL参数
const char* param_values[] = {buffer_theta0};
// 指定参数类型：PostgreSQL中float类型（float4）的OID是700
Oid param_types[] = {700};

PGresult* res = PQexecParams(conn,
                             "INSERT INTO measurements(theta0) VALUES($1)",
                             1,          // 参数数量
                             param_types,// 参数类型OID数组
                             param_values,// 参数值数组
                             NULL,       // 字符串参数可传NULL，libpq自动计算长度
                             NULL,       // 0表示文本格式
                             0);         // 结果格式（0为文本）

// 检查执行结果
if (PQresultStatus(res) != PGRES_COMMAND_OK) {
    fprintf(stderr, "插入失败: %s\n", PQerrorMessage(conn));
    PQclear(res);
    // 此处添加错误处理逻辑
}
PQclear(res);

方式二：二进制格式传递（更高效） #

直接传递float的内存数据，避免字符串格式化的开销和精度损失：

#include <libpq-fe.h>

// 假设conn已正确连接数据库
float theta = 0.2;
// 参数值数组：直接取float变量的地址转成char*
const char* param_values[] = {(const char*)&theta};
// 参数长度：float的字节数
int param_lengths[] = {sizeof(float)};
// 参数类型：float4的OID是700
Oid param_types[] = {700};
// 参数格式：1表示二进制格式
int param_formats[] = {1};

PGresult* res = PQexecParams(conn,
                             "INSERT INTO measurements(theta0) VALUES($1)",
                             1,
                             param_types,
                             param_values,
                             param_lengths,
                             param_formats,
                             0);

// 检查执行结果
if (PQresultStatus(res) != PGRES_COMMAND_OK) {
    fprintf(stderr, "插入失败: %s\n", PQerrorMessage(conn));
    PQclear(res);
    // 此处添加错误处理逻辑
}
PQclear(res);

关键注意点 #

• 始终用snprintf代替sprintf，防止缓冲区溢出导致内存问题。
• 明确指定paramTypes参数，不要依赖PostgreSQL的类型推断，避免意外错误。
• 执行完PQexecParams后必须用PQclear释放PGresult，避免内存泄漏。

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