OushuDB-编程接口 - libpq-数据查询和数据操纵

简介: OushuDB-编程接口 - libpq-数据查询和数据操纵

在获取到PGconn实例后,我们就可利用PGconn实例进行对数据库的操作了,Libpq执行sql命令的核心 函数为PQexec(PGconn conn, const char command);其中第一个参数为连接。第二个为执行的命 令,其中command字符串可以包含多条执行命令,如果不加入begin或者commit的关键字,command 字符串中的所有命令将在一个事务中执行,并且只要其中一条失败,就会导致整个command执行失 败。

PGresult PQexec(PGconn conn, const char *query); PQexec函数的返回类型为PGresult,如果返回值为null,说明执行失败,也可以通过

PQerrorMessage()方法查看错误消息。

在libpg中,查询语句和更新语句都是通过PQexec函数执行,但是很明显对于这两种语句我们需要的返 回值肯定不同,所以在解析PGresult时,libpq提供了不同的解析函数,这部分先说说解析查询结果用到 的几个函数

PQnfields(PGresult res):用于获取结果集中列的数目 PQfname(PGresult res,int i):用于获取结果集中列的名称 PQntuples(PGresult res):用于获取结果集中行的数目 PQgetvalue(PGresult res,int i,int j):用于获取结果集中i行j列的值

比如下面这一段:

res = PQexec(conn, "DECLARE myportal CURSOR FOR select * from pg_database");//为 查询语句声明一个游标

if (PQresultStatus(res) != PGRES_COMMAND_OK)//判断游标生成是否成功

{

fprintf(stderr, "DECLARE CURSOR failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);

} //这里需要注意不再使用的PGresult需要及时释放,否则可能会造成内存泄漏 PQclear(res);

res = PQexec(conn, "FETCH ALL in myportal");//FETCH ALL表示从结果中取回全部数据 if (PQresultStatus(res) != PGRES_TUPLES_OK)

{

fprintf(stderr, "FETCH ALL failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);

}

// 首先,打印出列名

nFields = PQnfields(res); for (i = 0; i < nFields; i++)

printf("%-15s", PQfname(res, i));

printf("\n\n");

// 接下来,打印出行

for (i = 0; i < PQntuples(res); i++)

对于select语句,我们在解析PGresult时需要的是结果集,所以在上面调用了以上几个函数,但是在插 入、删除和修改语句时我们更关心的受影响的行数,这时我们可以通过PQntuples(const PGresult *res) 来获取受影响函数,其中对于PGresult而言它的成员中包含了所有执行的结果,不同的解析函数只是用 来取得PGresult中相应的成员而已,更多的关于PGresult的实现,大家可以参考官方文档。

res = PQexec(conn, "delete from department where d_id=101;");
if (PQresultStatus(res) != PGRES_COMMAND_OK)
{
fprintf(stderr, "delete failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);

} printf("updatelin:%s",PQcmdTuples(res));//解析并打印受影响行数 PQclear(res);

执行 命令,可以完成libpq程序.c文件的编译,生成可执行文件

终止连接

在我们完成操作后,可以选择通过PQfinish()函数终止连接以释放资源:

gcc -L $libpath -I $includepath -lpq -o testlipq testlipq.c

目录
相关文章
|
SQL 关系型数据库 MySQL
使用DBeaver连接和管理RDS
DBeaver连接和管理RDS
2094 0
使用DBeaver连接和管理RDS
|
网络安全 数据安全/隐私保护 Linux
OushuDB 安装与升级之命令行安装的安装准备(上)
本节安装之前需要准备4台主机,各个节点上即将安装的组件如下表所示:
236 0
OushuDB 安装与升级之命令行安装的安装准备(上)
|
Windows
用网卡进行远程开机
软件名称:NetWaker for windows 简体中文版 简介:     这是一个通过网络进行远程开机的工具软件。只要被控的计算机主版/网卡/电源支持“网络唤醒”,同时,你也打开了这些功能(具体用法见附文),那么,利用这个程序你就可以通过网络远程启动你的计算机! 软件特点: 1,使用特别简单方便,而且是中文; 2,免费,没有使用时间限制,没有网卡限制。 3,可以添加任意多个被
1396 0
|
2天前
|
存储 弹性计算 人工智能
【2025云栖精华内容】 打造持续领先,全球覆盖的澎湃算力底座——通用计算产品发布与行业实践专场回顾
2025年9月24日,阿里云弹性计算团队多位产品、技术专家及服务器团队技术专家共同在【2025云栖大会】现场带来了《通用计算产品发布与行业实践》的专场论坛,本论坛聚焦弹性计算多款通用算力产品发布。同时,ECS云服务器安全能力、资源售卖模式、计算AI助手等用户体验关键环节也宣布升级,让用云更简单、更智能。海尔三翼鸟云服务负责人刘建锋先生作为特邀嘉宾,莅临现场分享了关于阿里云ECS g9i推动AIoT平台的场景落地实践。
【2025云栖精华内容】 打造持续领先,全球覆盖的澎湃算力底座——通用计算产品发布与行业实践专场回顾
|
4天前
|
云安全 数据采集 人工智能
古茗联名引爆全网,阿里云三层防护助力对抗黑产
阿里云三层校验+风险识别,为古茗每一杯奶茶保驾护航!
古茗联名引爆全网,阿里云三层防护助力对抗黑产