libpq

    使用libpq的前端程序必须包括头文件libpq-fe.h并且必须与libpq库链接。

    开发流程

    1. 解压相应的发布包（如openGauss-*.*.0-***-64bit-Libpq.tar.gz）文件，其中include文件夹下的头文件为所需的头文件，lib文件夹中为所需的libpq库文件。

    2. 包含libpq-fe.h头文件：

    4. 如果要使用制作文件(makefile)，向CPPFLAGS、LDFLAGS、LIBS变量中增加如下选项：

      1. CPPFLAGS += -I (头文件所在目录)
      2. LDFLAGS += -L (libpq库所在目录)
      3. LIBS += -lpq

    创建表

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <libpq-fe.h>
    5. static void
    6. exit_nicely(PGconn *conn)
    7. {
    8.     PQfinish(conn);
    9.     exit(1);
    10. }
    12. int
    13. main(int argc, char **argv)
    14. {
    15.     const char *conninfo;
    16.     PGconn     *conn;
    17.     PGresult   *res;
    18.     int         nFields;
    19.     int         i,j;
    21.     if (argc > 1)
    22.         conninfo = argv[1];
    23.     else
    24.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
    26.     conn = PQconnectdb(conninfo);
    28.     if (PQstatus(conn) != CONNECTION_OK)
    29.     {
    30.         fprintf(stderr, "Connection to database failed: %s",
    31.                 PQerrorMessage(conn));
    32.         exit_nicely(conn);
    33.     }
    35.     res = PQexec(conn, "CREATE TABLE customer_t1(c_customer_sk INTEGER, c_customer_name VARCHAR(32))");
    36.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
    37.     {
    38.         fprintf(stderr, "CREATE command failed: %s", PQerrorMessage(conn));
    39.         PQclear(res);
    40.         exit_nicely(conn);
    41.     }
    43.     /* 关闭数据库连接并清理 */
    44.     PQfinish(conn);
    46.     return 0;
    47. }
    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <libpq-fe.h>
    4. static void
    5. exit_nicely(PGconn *conn)
    6. {
    7.     PQfinish(conn);
    8.     exit(1);
    9. }
    11. int
    13. {
    14.     const char *conninfo;
    15.     PGconn     *conn;
    16.     PGresult   *res;
    18.     if (argc > 1)
    19.         conninfo = argv[1];
    20.     else
    21.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
    23.     conn = PQconnectdb(conninfo);
    25.     if (PQstatus(conn) != CONNECTION_OK)
    26.     {
    27.         fprintf(stderr, "Connection to database failed: %s",
    28.                 PQerrorMessage(conn));
    29.         exit_nicely(conn);
    30.     }
    32.     res = PQexec(conn, "insert into customer_t1 values(25,'li')");
    33.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
    34.     {
    35.         fprintf(stderr, "INSERT command failed: %s", PQerrorMessage(conn));
    36.         PQclear(res);
    37.         exit_nicely(conn);
    38.     }
    40.     /* 关闭数据库连接并清理 */
    41.     PQfinish(conn);
    43.     return 0;
    44. }

    SELECT操作

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <libpq-fe.h>
    5. static void
    6. exit_nicely(PGconn *conn)
    7. {
    8.     PQfinish(conn);
    9.     exit(1);
    10. }
    12. int
    13. main(int argc, char **argv)
    14. {
    15.     const char *conninfo;
    16.     PGconn     *conn;
    17.     PGresult   *res;
    18.     int         nFields;
    19.     int         i,j;
    21.     if (argc > 1)
    22.         conninfo = argv[1];
    23.     else
    24.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
    27.     if (PQstatus(conn) != CONNECTION_OK)
    28.     {
    29.         fprintf(stderr, "Connection to database failed: %s",
    31.         exit_nicely(conn);
    32.     }
    34.     res = PQexec(conn, "update customer_t1 set c_customer_sk = 1000 where c_customer_name = 'li'");
    35.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
    36.     {
    37.         fprintf(stderr, "UPDATE command failed: %s", PQerrorMessage(conn));
    38.         PQclear(res);
    39.         exit_nicely(conn);
    40.     }
    42.     /* 关闭数据库连接并清理 */
    43.     PQfinish(conn);
    45.     return 0;
    46. }

    删除操作

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <libpq-fe.h>
    5. static void
    6. exit_nicely(PGconn *conn)
    7. {
    8.     PQfinish(conn);
    9.     exit(1);
    10. }
    12. int
    13. main(int argc, char **argv)
    14. {
    15.     const char *conninfo;
    16.     PGconn     *conn;
    17.     PGresult   *res;
    18.     int         nFields;
    19.     int         i,j;
    21.     if (argc > 1)
    22.         conninfo = argv[1];
    23.     else
    24.         conninfo = "dbname=postgres port=42121 host='10.44.133.171' application_name=test connect_timeout=5 sslmode=allow user='test' password='test_1234'";
    26.     conn = PQconnectdb(conninfo);
    28.     if (PQstatus(conn) != CONNECTION_OK)
    29.     {
    30.         fprintf(stderr, "Connection to database failed: %s",
    31.                 PQerrorMessage(conn));
    32.         exit_nicely(conn);
    33.     }
    35.     res = PQexec(conn, "delete from customer_t1 where c_customer_name = 'li");
    36.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
    37.     {
    38.         fprintf(stderr, "DELETE command failed: %s", PQerrorMessage(conn));
    39.         PQclear(res);
    40.         exit_nicely(conn);
    41.     }
    43.     /* 关闭数据库连接并清理 */
    44.     PQfinish(conn);