c/c++连接postgresql

jenliang

c/c++怎样连接本机postgresql数据库，还有在表中读取和插入数据是什么格式的？

asdf2110

参考联机帮助的 libpq 接口，这是pg自己的通信接口
贴一个8.2的例子：

1. /*
   
2. * testlibpq.c
   
3. *
   
4. *      Test C 版本的 libpq，PostgreSQL 前端库
   
5. */
   
6. #include <stdio.h>
   
7. #include <stdlib.h>
   
8. #include "libpq-fe.h"
   
9. 
   
10. static void
    
11. exit_nicely(PGconn *conn)
    
12. {
    
13.     PQfinish(conn);
    
14.     exit(1);
    
15. }
    
16. 
    
17. int
    
18. main(int argc, char **argv)
    
19. {
    
20.     const char *conninfo;
    
21.     PGconn     *conn;
    
22.     PGresult   *res;
    
23.     int         nFields;
    
24.     int         i,
    
25.                 j;
    
26. 
    
27.     /*
    
28.      * 如果用户在命令行上提供了一个参数，则拿它当作 conninfo 字串使用；
    
29.      * 否则缺省为 dbname=postgres 并且使用环境变量或者所有其它连接参数
    
30.      * 都使用缺省值。
    
31.      */
    
32.     if (argc > 1)
    
33.         conninfo = argv[1];
    
34.     else
    
35.         conninfo = "dbname = postgres";
    
36. 
    
37.     /* Make a connection to the database */
    
38.     conn = PQconnectdb(conninfo);
    
39. 
    
40.     /* 检查后端连接成功建立 */
    
41.     if (PQstatus(conn) != CONNECTION_OK)
    
42.     {
    
43.         fprintf(stderr, "Connection to database failed: %s",
    
44.                 PQerrorMessage(conn));
    
45.         exit_nicely(conn);
    
46.     }
    
47. 
    
48.     /*
    
49.      * 我们的测试实例涉及游标的使用，这个时候我们必须使用事务块
    
50.      * 我们可以把全部事情放在一个  "select * from pg_database"
    
51.      * PQexec() 里，不过那样太简单了，不是个好例子。
    
52.      */
    
53. 
    
54.     /* 开始一个事务块 */
    
55.     res = PQexec(conn, "BEGIN");
    
56.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
    
57.     {
    
58.         fprintf(stderr, "BEGIN command failed: %s", PQerrorMessage(conn));
    
59.         PQclear(res);
    
60.         exit_nicely(conn);
    
61.     }
    
62. 
    
63.     /*
    
64.      * 应该在结果不需要的时候 PQclear PGresult，以避免内存泄漏
    
65.      */
    
66.     PQclear(res);
    
67. 
    
68.     /*
    
69.      * 从系统表 pg_database 里抓取数据
    
70.      */
    
71.     res = PQexec(conn, "DECLARE myportal CURSOR FOR select * from pg_database");
    
72.     if (PQresultStatus(res) != PGRES_COMMAND_OK)
    
73.     {
    
74.         fprintf(stderr, "DECLARE CURSOR failed: %s", PQerrorMessage(conn));
    
75.         PQclear(res);
    
76.         exit_nicely(conn);
    
77.     }
    
78.     PQclear(res);
    
79. 
    
80.     res = PQexec(conn, "FETCH ALL in myportal");
    
81.     if (PQresultStatus(res) != PGRES_TUPLES_OK)
    
82.     {
    
83.         fprintf(stderr, "FETCH ALL failed: %s", PQerrorMessage(conn));
    
84.         PQclear(res);
    
85.         exit_nicely(conn);
    
86.     }
    
87. 
    
88.     /* 首先，打印属性名称 */
    
89.     nFields = PQnfields(res);
    
90.     for (i = 0; i < nFields; i++)
    
91.         printf("%-15s", PQfname(res, i));
    
92.     printf("\n\n");
    
93. 
    
94.     /* 然后打印行 */
    
95.     for (i = 0; i < PQntuples(res); i++)
    
96.     {
    
97.         for (j = 0; j < nFields; j++)
    
98.             printf("%-15s", PQgetvalue(res, i, j));
    
99.         printf("\n");
    
100.     }
     
101. 
     
102.     PQclear(res);
     
103. 
     
104.     /* 关闭游标 ... 我们不用检查错误 ... */
     
105.     res = PQexec(conn, "CLOSE myportal");
     
106.     PQclear(res);
     
107. 
     
108.     /* 结束事务 */
     
109.     res = PQexec(conn, "END");
     
110.     PQclear(res);
     
111. 
     
112.     /* 关闭数据库连接并清理 */
     
113.     PQfinish(conn);
     
114. 
     
115.     return 0;
     
116. }

复制代码

sychangchun

通过PG的标准头文件看看。