C++ postagesql 连接

/*
 * PgConnector.cpp
 *
 *  Created on: 2012-9-12
 *      Author: Gabriel
 */

#include "db/PgConnector.h"
#include <stdio.h>
#include <stdlib.h>
#include "libpq-fe.h"

namespace gaby {

	PgConnector::PgConnector() {
	}

	PgConnector::~PgConnector() {
	}

} /* namespace gaby */

int main(	int argc,
			char **argv) {
	const char *conninfo = "dbname=mvmdb";
	PGconn *conn;
	PGresult *res;
	int nFields;
	int i, j;

	/* Make a connection to the database */
	conn = PQconnectdb(conninfo);

	/* 检查后端连接成功建立 */
	if (PQstatus(conn) != CONNECTION_OK) {
		fprintf(stderr, "Connection to database failed: %s",
		PQerrorMessage(conn));
		PQfinish(conn);
		return -1;
	}

		/*
		 * 我们的测试实例涉及游标的使用，这个时候我们必须使用事务块
		 * 我们可以把全部事情放在一个  "select * from pg_database"
		 * PQexec() 里，不过那样太简单了，不是个好例子。
		 */

		/* 开始一个事务块 */
	res = PQexec(conn, "BEGIN");
	if (PQresultStatus(res) != PGRES_COMMAND_OK) {
		fprintf(stderr, "BEGIN command failed: %s", PQerrorMessage(conn));
		PQclear(res);
		PQfinish(conn);
		return -1;
	}

		/*
		 * 应该在结果不需要的时候 PQclear PGresult，以避免内存泄漏
		 */
	PQclear(res);
	//fprintf(stderr, "测试输出错误: %s", PQerrorMessage(conn));
	/*
	 * 从系统表 pg_database 里抓取数据
	 */
	res = PQexec(conn, "DECLARE myportal CURSOR FOR select * from pg_database");
	if (PQresultStatus(res) != PGRES_COMMAND_OK) {
		fprintf(stderr, "DECLARE CURSOR failed: %s", PQerrorMessage(conn));
		PQclear(res);
		PQfinish(conn);
		return -1;
	}
	PQclear(res);

	res = PQexec(conn, "FETCH ALL in myportal");
	if (PQresultStatus(res) != PGRES_TUPLES_OK) {
		fprintf(stderr, "FETCH ALL failed: %s", PQerrorMessage(conn));
		PQclear(res);
		PQfinish(conn);
		return -1;
	}

		/* 首先，打印属性名称 */
	nFields = PQnfields(res);
	for (i = 0; i < nFields; i++)
		printf("%-15s", PQfname(res, i));
	printf("\n\n");

	/* 然后打印行 */
	for (i = 0; i < PQntuples(res); i++) {
		for (j = 0; j < nFields; j++)
			printf("%-15s", PQgetvalue(res, i, j));
		printf("\n");
	}

	PQclear(res);

	/* 关闭游标 ... 我们不用检查错误 ... */
	res = PQexec(conn, "CLOSE myportal");
	PQclear(res);

	/* 结束事务 */
	res = PQexec(conn, "END");
	PQclear(res);

	/* 关闭数据库连接并清理 */
	PQfinish(conn);

	return 0;
}

 

经过测试,可以用

工程设置:

include :   .....\postgresql-9.1.1-1-windows-binaries\include

lib:            -lpg