示例

    示例2：

    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.     i_fnum = PQfnumber(res, "i");
    51.     for (i = 0; i < PQntuples(res); i++)
    52.     {
    53.         char       *iptr;
    54.         char       *tptr;
    55.         int         ival;
    57.         /* 获取字段值（忽略可能为空的可能） */
    58.         iptr = PQgetvalue(res, i, i_fnum);
    59.         tptr = PQgetvalue(res, i, t_fnum);
    61.         /*
    62.          * INT4 的二进制表现形式是网络字节序
    63.          * 建议转换成本地字节序
    64.          */
    65.         ival = ntohl(*((uint32_t *) iptr));
    67.         /*
    68.          * TEXT 的二进制表现形式是文本，因此libpq能够给它附加一个字节零
    69.          * 把它看做 C 字符串
    70.          *
    71.          */
    73.         printf("tuple %d: got\n", i);
    74.         printf(" i = (%d bytes) %d\n",
    75.                PQgetlength(res, i, i_fnum), ival);
    76.         printf(" t = (%d bytes) '%s'\n",
    77.                PQgetlength(res, i, t_fnum), tptr);
    78.         printf("\n\n");
    79.     }
    80. }
    82. int
    83. main(int argc, char **argv)
    84. {
    85.     const char *conninfo;
    86.     PGconn     *conn;
    87.     PGresult   *res;
    88.     const char *paramValues[1];
    89.     int         paramLengths[1];
    90.     int         paramFormats[1];
    91.     uint32_t    binaryIntVal;
    93.     /*
    94.      * 如果用户在命令行上提供了参数，
    95.      * 那么使用该值为conninfo 字符串；否则
    96.      */
    98.         conninfo = argv[1];
    99.     else
    100.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
    102.     /* 和数据库建立连接 */
    103.     conn = PQconnectdb(conninfo);
    105.     /* 检查与服务器的连接是否成功建立 */
    106.     if (PQstatus(conn) != CONNECTION_OK)
    107.     {
    108.         fprintf(stderr, "Connection to database failed: %s",
    109.                 PQerrorMessage(conn));
    110.         exit_nicely(conn);
    111.     }
    113.     /* 把整数值 "2" 转换成网络字节序 */
    114.     binaryIntVal = htonl((uint32_t) 2);
    116.     /* 为 PQexecParams 设置参数数组 */
    117.     paramValues[0] = (char *) &binaryIntVal;
    118.     paramLengths[0] = sizeof(binaryIntVal);
    119.     paramFormats[0] = 1;        /* 二进制 */
    121.     res = PQexecParams(conn,
    122.                        "SELECT * FROM test1 WHERE i = $1::int4",
    123.                        1,       /* 一个参数 */
    124.                        NULL,    /* 让后端推导参数类型 */
    125.                        paramValues,
    126.                        paramLengths,
    127.                        paramFormats,
    128.                        1);      /* 要求二进制结果 */
    130.     if (PQresultStatus(res) != PGRES_TUPLES_OK)
    131.     {
    132.         fprintf(stderr, "SELECT failed: %s", PQerrorMessage(conn));
    133.         PQclear(res);
    134.         exit_nicely(conn);
    135.     }
    137.     show_binary_results(res);
    139.     PQclear(res);
    141.     /* 关闭与数据库的连接并清理 */
    142.     PQfinish(conn);
    144. }