在获取到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)//判断游标生成是否成功 {
代码语言：javascript复制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) {
代码语言：javascript复制fprintf(stderr, "FETCH ALL failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);} // 首先，打印出列名 nFields = PQnfields(res); for (i = 0; i < nFields; i )
代码语言：javascript复制printf("%-15s", PQfname(res, i));printf("nn"); // 接下来，打印出行 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) {
代码语言：javascript复制fprintf(stderr, "delete failed: %s", PQerrorMessage(conn));
PQclear(res);
exit_nicely(conn);} printf("updatelin:%s",PQcmdTuples(res));//解析并打印受影响行数 PQclear(res);执行 命令，可以完成libpq程序.c文件的编译，生成可执行文件终止连接在我们完成操作后，可以选择通过PQfinish()函数终止连接以释放资源:gcc -L
