在获取到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