示例

常用功能示例代码

示例1：

  1. /*
  2.  * testlibpq.c
  3.  */
  4. #include <stdio.h>
  5. #include <stdlib.h>
  6. #include <libpq-fe.h>
  8. static void
  9. exit_nicely(PGconn *conn)
  10. {
  11.     PQfinish(conn);
  12.     exit(1);
  13. }
  15. int
  16. main(int argc, char **argv)
  17. {
  18.     const char *conninfo;
  19.     PGconn     *conn;
  20.     PGresult   *res;
  21.     int         nFields;
  22.     int         i,j;
  24.     /*
  25.      * 用户在命令行上提供了conninfo字符串的值时使用该值
  26.      * 否则环境变量或者所有其它连接参数
  27.      * 都使用缺省值。
  28.      */
  29.     if (argc > 1)
  30.         conninfo = argv[1];
  31.     else
  32.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
  34.     /* 连接数据库 */
  35.     conn = PQconnectdb(conninfo);
  37.     /* 检查后端连接成功建立 */
  38.     if (PQstatus(conn) != CONNECTION_OK)
  39.     {
  40.         fprintf(stderr, "Connection to database failed: %s",
  41.                 PQerrorMessage(conn));
  42.         exit_nicely(conn);
  43.     }
  45.     /*
  46.      * 测试实例涉及游标的使用时候必须使用事务块
  47.      *把全部放在一个  "select * from pg_database"
  48.      * PQexec() 里，过于简单，不推荐使用
  49.      */
  51.     /* 开始一个事务块 */
  52.     res = PQexec(conn, "BEGIN");
  53.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
  54.     {
  55.         fprintf(stderr, "BEGIN command failed: %s", PQerrorMessage(conn));
  56.         PQclear(res);
  57.         exit_nicely(conn);
  58.     }
  60.     /*
  61.      * 在结果不需要的时候PQclear PGresult，以避免内存泄漏
  62.      */
  63.     PQclear(res);
  65.     /*
  66.      * 从系统表 pg_database（数据库的系统目录）里抓取数据
  67.      */
  68.     res = PQexec(conn, "DECLARE myportal CURSOR FOR select * from pg_database");
  69.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
  70.     {
  71.         fprintf(stderr, "DECLARE CURSOR failed: %s", PQerrorMessage(conn));
  72.         PQclear(res);
  73.         exit_nicely(conn);
  74.     }
  75.     PQclear(res);
  77.     res = PQexec(conn, "FETCH ALL in myportal");
  78.     if (PQresultStatus(res) != PGRES_TUPLES_OK)
  79.     {
  80.         fprintf(stderr, "FETCH ALL failed: %s", PQerrorMessage(conn));
  81.         PQclear(res);
  82.         exit_nicely(conn);
  83.     }
  85.     /* 打印属性名称 */
  86.     nFields = PQnfields(res);
  87.     for (i = 0; i < nFields; i++)
  88.         printf("%-15s", PQfname(res, i));
  89.     printf("\n\n");
  91.     /* 打印行 */
  92.     for (i = 0; i < PQntuples(res); i++)
  93.     {
  94.         for (j = 0; j < nFields; j++)
  95.             printf("%-15s", PQgetvalue(res, i, j));
  96.         printf("\n");
  97.     }
  99.     PQclear(res);
  101.     /* 关闭入口 ... 不用检查错误 ... */
  102.     res = PQexec(conn, "CLOSE myportal");
  103.     PQclear(res);
  105.     /* 结束事务 */
  106.     res = PQexec(conn, "END");
  107.     PQclear(res);
  109.     /* 关闭数据库连接并清理 */
  110.     PQfinish(conn);
  112.     return 0;
  113. }

示例2：

  1. /*
  2.  * testlibpq2.c
  3.  *      测试外联参数和二进制I/O。
  4.  *
  5.  * 在运行这个例子之前，用下面的命令填充一个数据库
  6.  * 
  7.  *
  8.  * CREATE TABLE test1 (i int4, t text);
  9.  *
  10.   * INSERT INTO test1 values (2, 'ho there');
  11.  *
  12.  * 期望的输出如下
  13.  *
  14.  *
  15.  * tuple 0: got
  16.  *  i = (4 bytes) 2
  17.  *  t = (8 bytes) 'ho there'
  18.  *  
  19.  */
  20. #include <stdio.h>
  21. #include <stdlib.h>
  22. #include <string.h>
  23. #include <sys/types.h>
  24. #include <libpq-fe.h>
  26. /* for ntohl/htonl */
  27. #include <netinet/in.h>
  28. #include <arpa/inet.h>
  30. static void
  31. exit_nicely(PGconn *conn)
  32. {
  33.     PQfinish(conn);
  34.     exit(1);
  35. }
  37. /*
  38.  * 这个函数打印查询结果，这些结果是二进制格式，从上面的
  39.  * 注释里面创建的表中抓取出来的
  40.  */
  41. static void
  42. show_binary_results(PGresult *res)
  43. {
  44.     int         i;
  45.     int         i_fnum,
  46.                 t_fnum;
  48.     /* 使用 PQfnumber 来避免对结果中的字段顺序进行假设 */
  49.     i_fnum = PQfnumber(res, "i");
  50.     t_fnum = PQfnumber(res, "t");
  52.     for (i = 0; i < PQntuples(res); i++)
  53.     {
  54.         char       *iptr;
  55.         char       *tptr;
  56.         int         ival;
  58.         /* 获取字段值（忽略可能为空的可能） */
  59.         iptr = PQgetvalue(res, i, i_fnum);
  60.         tptr = PQgetvalue(res, i, t_fnum);
  62.         /*
  63.          * INT4 的二进制表现形式是网络字节序
  64.          * 建议转换成本地字节序
  65.          */
  66.         ival = ntohl(*((uint32_t *) iptr));
  68.         /*
  69.          * TEXT 的二进制表现形式是文本，因此libpq能够给它附加一个字节零
  70.          * 把它看做 C 字符串
  71.          *
  72.          */
  74.         printf("tuple %d: got\n", i);
  75.         printf(" i = (%d bytes) %d\n",
  76.                PQgetlength(res, i, i_fnum), ival);
  77.         printf(" t = (%d bytes) '%s'\n",
  78.                PQgetlength(res, i, t_fnum), tptr);
  79.         printf("\n\n");
  80.     }
  81. }
  83. int
  84. main(int argc, char **argv)
  85. {
  86.     const char *conninfo;
  87.     PGconn     *conn;
  88.     PGresult   *res;
  89.     const char *paramValues[1];
  90.     int         paramLengths[1];
  91.     int         paramFormats[1];
  92.     uint32_t    binaryIntVal;
  94.     /*
  95.      * 如果用户在命令行上提供了参数，
  96.      * 那么使用该值为conninfo 字符串；否则
  97.      * 使用环境变量或者缺省值。
  98.      */
  99.     if (argc > 1)
  100.         conninfo = argv[1];
  101.     else
  102.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
  104.     /* 和数据库建立连接 */
  105.     conn = PQconnectdb(conninfo);
  107.     /* 检查与服务器的连接是否成功建立 */
  108.     if (PQstatus(conn) != CONNECTION_OK)
  109.     {
  110.         fprintf(stderr, "Connection to database failed: %s",
  111.                 PQerrorMessage(conn));
  112.         exit_nicely(conn);
  113.     }
  115.     /* 把整数值 "2" 转换成网络字节序 */
  116.     binaryIntVal = htonl((uint32_t) 2);
  118.     /* 为 PQexecParams 设置参数数组 */
  119.     paramValues[0] = (char *) &binaryIntVal;
  120.     paramLengths[0] = sizeof(binaryIntVal);
  121.     paramFormats[0] = 1;        /* 二进制 */
  123.     res = PQexecParams(conn,
  124.                        "SELECT * FROM test1 WHERE i = $1::int4",
  125.                        1,       /* 一个参数 */
  126.                        NULL,    /* 让后端推导参数类型 */
  127.                        paramValues,
  128.                        paramLengths,
  129.                        paramFormats,
  130.                        1);      /* 要求二进制结果 */
  132.     if (PQresultStatus(res) != PGRES_TUPLES_OK)
  133.     {
  134.         fprintf(stderr, "SELECT failed: %s", PQerrorMessage(conn));
  135.         PQclear(res);
  136.         exit_nicely(conn);
  137.     }
  139.     show_binary_results(res);
  141.     PQclear(res);
  143.     /* 关闭与数据库的连接并清理 */
  144.     PQfinish(conn);
  146.     return 0;
  147. }