使用c脚本将存储在变量中的数据插入Postgres数据库表
使用C脚本将存储在变量中的数据插入PostgreSQL数据库表的步骤如下：
- 引入必要的头文件和库：
#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>- 定义数据库连接参数：
const char *conninfo = "host=<数据库主机地址> port=<数据库端口> dbname=<数据库名> user=<用户名> password=<密码>";请将<数据库主机地址>、<数据库端口>、<数据库名>、<用户名>和<密码>替换为实际的数据库连接信息。
- 建立数据库连接：
PGconn *conn = PQconnectdb(conninfo);
if (PQstatus(conn) != CONNECTION_OK) {
fprintf(stderr, "数据库连接失败: %s\n", PQerrorMessage(conn));
PQfinish(conn);
exit(1);
}- 准备SQL语句和变量：
const char *sql = "INSERT INTO <表名> (<列1>, <列2>, ...) VALUES ($1, $2, ...)";
const char *data1 = "数据1";
const char *data2 = "数据2";
...请将<表名>、<列1>、<列2>等替换为实际的表名和列名，$1、$2等为占位符。
- 创建预处理语句：
PGresult *res = PQprepare(conn, "insert_stmt", sql, 0, NULL);
if (PQresultStatus(res) != PGRES_COMMAND_OK) {
fprintf(stderr, "预处理语句创建失败: %s\n", PQerrorMessage(conn));
PQclear(res);
PQfinish(conn);
exit(1);
}
PQclear(res);- 执行预处理语句：
const char *paramValues[<变量个数>] = {data1, data2, ...};
int paramLengths[<变量个数>] = {strlen(data1), strlen(data2), ...};
int paramFormats[<变量个数>] = {0, 0, ...}; // 0表示文本格式，1表示二进制格式
res = PQexecPrepared(conn, "insert_stmt", <变量个数>, paramValues, paramLengths, paramFormats, 0);
if (PQresultStatus(res) != PGRES_COMMAND_OK) {
fprintf(stderr, "插入数据失败: %s\n", PQerrorMessage(conn));
PQclear(res);
PQfinish(conn);
exit(1);
}
PQclear(res);请将<变量个数>替换为实际的变量个数。
- 关闭数据库连接：
PQfinish(conn);完整的C脚本示例代码如下：
#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>
int main() {
const char *conninfo = "host=<数据库主机地址> port=<数据库端口> dbname=<数据库名> user=<用户名> password=<密码>";
PGconn *conn = PQconnectdb(conninfo);
if (PQstatus(conn) != CONNECTION_OK) {
fprintf(stderr, "数据库连接失败: %s\n", PQerrorMessage(conn));
PQfinish(conn);
exit(1);
}
const char *sql = "INSERT INTO <表名> (<列1>, <列2>, ...) VALUES ($1, $2, ...)";
const char *data1 = "数据1";
const char *data2 = "数据2";
// ...
PGresult *res = PQprepare(conn, "insert_stmt", sql, 0, NULL);
if (PQresultStatus(res) != PGRES_COMMAND_OK) {
fprintf(stderr, "预处理语句创建失败: %s\n", PQerrorMessage(conn));
PQclear(res);
PQfinish(conn);
exit(1);
}
PQclear(res);
const char *paramValues[<变量个数>] = {data1, data2, ...};
int paramLengths[<变量个数>] = {strlen(data1), strlen(data2), ...};
int paramFormats[<变量个数>] = {0, 0, ...}; // 0表示文本格式，1表示二进制格式
res = PQexecPrepared(conn, "insert_stmt", <变量个数>, paramValues, paramLengths, paramFormats, 0);
if (PQresultStatus(res) != PGRES_COMMAND_OK) {
fprintf(stderr, "插入数据失败: %s\n", PQerrorMessage(conn));
PQclear(res);
PQfinish(conn);
exit(1);
}
PQclear(res);
PQfinish(conn);
return 0;
}请将<数据库主机地址>、<数据库端口>、<数据库名>、<用户名>、<密码>、<表名>、<列1>、<列2>等替换为实际的值。
对于腾讯云相关产品，可以使用腾讯云的云数据库 PostgreSQL（https://cloud.tencent.com/product/postgres）来存储和管理数据。
相关·内容
2回答
简单的Postgresql libpq代码太慢了？
c++、c、postgresql、libpq
我使用libpq在postgresql上工作。下面给出的代码花费了很多时间(在代码末尾给出了计时)。
#include "stdafx.h"
#include <stdlib.h>
#include <libpq-fe.h>
#include <windows.h>
static void exit_nicely(PGconn *conn)
{
PQfinish(conn);
exit(1);
}
int _tmain(int argc, _TCHAR* argv[])
{
const TCHAR *conninf
浏览 1提问于2012-05-09得票数 5
2回答
无法使用C将列添加到现有表中
sql、c、postgresql
下面的程序尝试将新行和新列插入到一个已有的数据库中，该数据库具有一个表"people“，其中包含四个cols (id、lastname、firstname、phonenumber)。虽然成功插入了行，但没有添加列。
#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>
#include <string.h>
int main()
{
PGconn *conn;
PGresult *res;
浏览 0提问于2014-04-08得票数 0
1回答
postgresql为长时间运行的连接在db服务器上消耗更多的内存。
c++、postgresql、memory-leaks、libpq
我们有一个c++服务器应用程序，它使用libpq库连接到postgresql数据库。创建到数据库的连接的应用程序和连接的大部分生命周期都是应用程序范围。
最初，应用程序运行良好，但经过一段时间，postgres服务器为长时间运行的连接消耗了更多内存。通过编写下面的示例程序，我了解到使用、PQsendPrepare、和创建准备好的语句会导致数据库服务器中的内存消耗问题。
我们如何解决这个服务器内存问题？是否有libpq函数来释放服务器中的内存？
#include <iostream>
#include <fstream>
#include <string>
#
浏览 0提问于2018-02-26得票数 1
回答已采纳
1回答
将C变量传递到SQL命令
c、postgresql、libpq
我是一个新手，在使用libpq和工作的postgresql数据库。
因此，只要给出引号内的实际值，我就可以使用C程序插入/update/etc一个postgresql数据库。
我想知道如何在命令中传递字符串/整数变量？
例如，下面的代码将一个名为“注释”的列添加到现有的表"people“中，其中包含"TRUE”默认值。我需要用"FALSE“更新”id=2“的”注释“值。
#include <stdio.h>
#include <stdlib.h>
#include <libpq-fe.h>
#inclu
浏览 2提问于2014-04-14得票数 2
回答已采纳
1回答
PostgreSQL C API - libq未定义引用
c、postgresql、gnat-gps
我正在尝试这里的testPostgreSqlAPI.cpp示例：http://www.yolinux.com/TUTORIALS/PostgreSQL-Programming-C-API.html#INSERT_SELECT 我已经在PostgreSQL中创建了数据库，可以看到它是成功的： bedrock=# SELECT * FROM employee;
idpk | employee_name | dept | jobtitle
------+----------------------+-------------
浏览 60提问于2020-07-08得票数 0
1回答
psql \从c++程序执行时复制命令错误
c++、postgresql、psql、libpq
ERROR: syntax error at or near "\"
LINE 1: \copy mytable FROM urishFile WITH (FORMAT csv, DELIMITER ','...
^
从c++程序运行命令时出现此错误。
command = "\\copy mytable FROM urishFile WITH (FORMAT csv, DELIMITER ',', NULL 'NULL');";
executCommand(conn, command);
vo
浏览 4提问于2013-05-18得票数 0
回答已采纳
2回答
PQexecparams -不支持绑定数组中的第三个参数
c++、database、postgresql
我是postgresql的新手，尝试用PQexecparams在db中插入值。当我在值数组中绑定两个参数时，它工作得很好，但是当我移到三个参数时，它显示了一个错误“插入失败:不能为输出缓冲区分配内存”，这是我的代码：
void InsertBinaryRec(PGconn *conn, double *valueX, char *nameString, double *valueY)
{
int paramLengths[10];
int paramFormats[3] = { 1, 0, 1 };
const char* val
浏览 0提问于2017-04-06得票数 0
回答已采纳
1回答
PostgreSql查询中的参数数据类型错误
c++、sql、c、postgresql、concatenation
我正在尝试使用以下代码在PostgreSQL中执行查询。它是用C/C++编写的，在声明游标时，我一直收到以下错误：
DECLARE CURSOR failed: ERROR: could not determine data type of parameter $1
在这里和谷歌上搜索，我都找不到解决方案。有没有人能找出我在哪里犯了错，为什么会这样？
void searchdb( PGconn *conn, char* name, char* offset )
{
// Will hold the number of field in table
int nFields;
// Start
浏览 0提问于2011-11-12得票数 3
回答已采纳
1回答
使用libpq准备多行
postgresql、libpq
如何使用PQprepare通过libpq在一行中插入大约100行？ 我不知道，也许我的参数是错误的..。 感谢您的回复。 const char command[] = "INSERT INTO car (id, name, price, day, time)"
"VALUES($1, $2, $3, $4, $5),"
"VALUES($1, $2, $3, $4, $5),"
"VALU
浏览 13提问于2020-07-08得票数 0
1回答
使用libpq在表中插入浮点数
c、postgresql、libpq
我使用libpq在表中插入一个浮点数。我得到了这个错误INSERT failed: ERROR: insufficient data left in message。
下面是我的代码库中相应的代码片段：
printf ("Enter write parameter_value");
scanf("%f", ¶meter_value);
char *stm = "INSERT INTO write_reg_set (parameter_value) VALUES ($1::double precision)";
int npa
浏览 1提问于2017-02-20得票数 3
1回答
libpq如何传递大量数据
sql、c、postgresql、libpq
我试图将多个行传递给一个测试表，并且我很难理解它在libpq中是如何实现的。
我已经找到了用于复制数据的命令，我认为这些命令是必要的，但是没有任何示例说明如何使用这些命令。
这是我想出的代码，但是我在PQputCopyEnd函数中得到了分段错误。我在这里迷路了，所以任何帮助都会很好。
/*
* testlibpq.c
*
* Test the C version of libpq, the PostgreSQL frontend library.
*/
#include <stdio.h>
#include <string>
#include <
浏览 1提问于2017-05-11得票数 4
回答已采纳
1回答
无法使用C++中的libpq在数据库中创建表
c、database、postgresql、libpq
我创建了一个c函数，用于在我的postgresql数据库上创建表。这里： #include <stdio.h>
#include <libpq-fe.h>
#include <stdlib.h>
PGconn *connection;
PGresult *re;
void create_table(){
re= PQexec(connection, "SELECT to_regclass('fp_stores_data')");
if(!re){
PQcl
浏览 18提问于2020-06-25得票数 2
回答已采纳
1回答
使用单引号的PQexecParams失败
c++、sql、libpq
我正在尝试使用libpq插入到我的SQL数据库中，代码如下：
void func(PGconn *conn)
{
const char * params[2] = { "1", "\'POINT(0 0)\'" };
res = PQexecParams(conn,
"INSERT INTO drive_test_point (id, geom) VALUES ($1, ST_GeomFromText($2, 900913));",
2,
NULL,
浏览 1提问于2012-04-25得票数 2
1回答
用C语言实现从PostgreSQL文件中检索数据
c、database、postgresql、null、data-retrieval
在我的C程序中使用libpq db引擎检索postgresql数据库中的数据时出现问题。在我存储数据之后，我可以使用我的终端验证它的完整性，这样它就会保存在数据库中，但是当我试图访问它时，我得到了一个segv (由于null ref / ptr)。下面是使用的相关例程/函数。
正在创建表：
int createTable() {
const char *conninfo = "user=tmp password=pass dbname=testdb hostaddr=127.0.0.1 port=5432 sslmode=require";
PGconn *co
浏览 9提问于2017-03-17得票数 0
2回答
使用C语言在postgres数据库中插入modbus值
c、postgresql
如何使用c语言在postgresql数据库中插入变量？我正在尝试使用“：”插入一个变量，但它不起作用 float g=1.23;
int main(int argc, char *argv[])
{
PGconn *conn = PQconnectdb("user=postgres password=postgres dbname=postgres");
if (PQstatus(conn) == CONNECTION_BAD) {
fprintf(stderr, "Connection to database failed: %s\
浏览 36提问于2019-10-18得票数 0
1回答
使用c脚本将存储在变量中的数据插入Postgres数据库表
c、postgresql、variables、sql-insert
我已经编写了一个c脚本来将数据插入到PostgreSQL表中。在代码中，我有缓冲区变量中的数据，我想将这些数据写入我的数据库。我试图使用“：”插入一个变量，但它不起作用。因为我在编码方面几乎没有经验，所以我仍然无法修改我的代码来完成这项工作。我已经在下面列出了代码部分。有没有人知道如何修改我的代码才能工作？ res = PQexec(conn, "INSERT INTO pressure(SENSORVAL) VALUES(:buffer)");
if (PQresultStatus(res) != PGRES_COMMAND_OK)
do_exit(co
浏览 19提问于2021-08-23得票数 0
2回答
数据库连接可以重用吗？
c++、sql、postgresql
我正在尝试创建一个可以访问PostgreSQL数据库的程序。问题是我一直得到一个
警告:已经有一项交易正在进行中。
消息和程序很快就会退出。当我需要连接时，我需要关闭并重新打开它吗?还是我可以修复这个问题，并在整个程序中重用相同的连接？
int i = 0;
std::string spassw = "";
std::string suname = "";
theconn = NULL;
// Make a connection to the database
theconn = PQconnectdb
浏览 3提问于2013-01-04得票数 1
回答已采纳
1回答
如何序列化数据库中的事件？
sql、database、postgresql、nosql
我的问题有点复杂，我会尝试用一个例子来简化它。
假设我想实现一个由SQL数据库支持的聊天系统。该系统由一个单独的房间组成，任何人都可以在这个房间上发消息。
要使用聊天，您需要安装一个应用程序(比如移动应用程序)。这个应用程序将历史记录保存在设备上，并定期连接到服务器，只获取新消息。
我想解决的问题是如何只获取这些新消息，而不会丢失任何消息。
天真的实现将使用带有两列(id AUTO_INCREMENT, message)的SQL表。客户端连接，第一次获取历史记录，然后只请求其id大于其上一个id的消息。
在实践中，这似乎不起作用，而且您有丢失消息的风险。我制作了两个使用PostgreSQL的
浏览 5提问于2017-04-27得票数 4
3回答
通过编程查找受Postgres副本影响的行数
c、postgresql
我使用Postgres 8.2和相关的libpq库进行ANSI C。我已经浏览了文档，没有找到能给我提供特定信息的东西。
在文件的“副本”一节中，“产出”是这样描述的：
成功完成后，复制命令将返回窗体的命令标记。
复制计数
计数是复制的行数。
假设conn引用的是一个有效的PGconn*，我想我可以使用这样的方法来返回复制的行数：
sprintf(queryString, "COPY table FROM '%s' WITH DELIMITER '|'",
tempFileName);
fprin
浏览 4提问于2009-02-19得票数 4
回答已采纳
1回答
如何通过postgres在准备好的语句中插入时间戳？
c++、postgresql、questdb
我将把记录发送到QuestDB中的一个表中，到目前为止，我有以下内容：
#include <libpq-fe.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/time.h>
#include <string.h>
void do_exit(PGconn* conn)
{
PQfinish(conn);
exit(1);
}
int main()
{
PGconn* conn = PQconnectdb(
"host=loc
浏览 2提问于2021-02-22得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频活动推荐
腾讯云开发者
