工作需要，虽然有libpqxx，但是目前为了刚刚够用，尽量不要引入第三方库。在网上找到简单的封装http://www.touspassagers.com/2010/12/a-postgresql-database-interface-wrapper-in-c/

直接贴上代码:

#include <iostream> #include <st<a href="/tag/dio/" target="_blank" class="keywords">dio</a>.h> #include <string> #include <stdlib.h> #include <libpq-fe.h> #include <map> #include <math.h> #include <string.h> using namespace std; typedef map<int,map<string,string> > map_result; static void finish_connection(PGconn *conn) { PQfinish(conn); } class Conn { public: // Methods Conn(char *connstring); ~Conn(); map_result fetch(char *<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); int insert(char *<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); void reset(); private: // Members PGconn *conn; const char *conninfo; PGresult *res; }; Conn::Conn(char *connstring) { // Connect to the DB conninfo = connstring; conn = PQconnectdb(conninfo); // See if the connection took: if (PQstatus(conn) != CONNECTION_OK) { fprintf(stderr,"Could not connect to db/n%s",PQerrorMessage(conn)); finish_connection(conn); } } Conn::~Conn() { finish_connection(conn); } void Conn::reset() { PQfinish(conn); conn = PQconnectdb(conninfo); } map_result Conn::fetch(char *<a href="/tag/sql/" target="_blank" class="keywords">sql</a>) { int row,col; map_result results; map<string,string> pairs; // Check the connection: if (PQstatus(conn) != CONNECTION_OK) this->reset(); // Start a transaction: res = PQexec(conn,"BEGIN"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr,"<a href="/tag/Failed/" target="_blank" class="keywords">Failed</a> to BEGIN transaction /n%s",PQerrorMessage(conn)); PQclear(res); finish_connection(conn); } // Set up fetch query with a CURSOR: string Final<a href="/tag/sql/" target="_blank" class="keywords">sql</a> = string("DECLARE myportal CURSOR FOR ") + string(<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); // Declare CURSOR and execute query: res = PQexec(conn,Final<a href="/tag/sql/" target="_blank" class="keywords">sql</a>.c_str()); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr,"QUERY <a href="/tag/Failed/" target="_blank" class="keywords">Failed</a>/n%s/n",PQerrorMessage(conn)); PQclear(res); finish_connection(conn); } PQclear(res); // Fetch results: res = PQexec(conn,"FETCH ALL in myportal"); if (PQresultStatus(res) != PGRES_TUPLES_OK) { fprintf(stderr,"FETCH ALL <a href="/tag/Failed/" target="_blank" class="keywords">Failed</a>/n%s/n",PQerrorMessage(conn)); PQclear(res); finish_connection(conn); } else { row = col = 0; for (row=0; row<PQntuples(res); row++) { for(col=0; col<PQnfields(res); col++) { pairs[PQfname(res,col)] = PQgetvalue(res,row,col); } results[row] = pairs; } } return results; } int Conn::insert(char *<a href="/tag/sql/" target="_blank" class="keywords">sql</a>) { // Check the connection: if (PQstatus(conn) != CONNECTION_OK) this->reset(); // Start a transaction: res = PQexec(conn,"START TRANSACTION;"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr,"<a href="/tag/Failed/" target="_blank" class="keywords">Failed</a> to BEGIN transaction /n%s/n",PQerrorMessage(conn)); PQclear(res); finish_connection(conn); } // Execute Insert: res = PQexec(conn,<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr,"<a href="/tag/Failed/" target="_blank" class="keywords">Failed</a> to execute INSERT /n%s/n",PQerrorMessage(conn)); PQclear(res); finish_connection(conn); } // COMMIT transaction: res = PQexec(conn,"COMMIT"); if (PQresultStatus(res) != PGRES_COMMAND_OK) { fprintf(stderr,"<a href="/tag/Failed/" target="_blank" class="keywords">Failed</a> to COMMIT transaction/n%s/n",PQerrorMessage(conn)); PQclear(res); finish_connection(conn); } return 0; }

使用代码：

#include <iostream> #include <boost/lexical_cast.hpp> #include "PGConn.hpp" using namespace std; int main() { map_result res; Conn *postgres = new Conn("dbname=mydb user=postgres"); for( int i=0; i<10; ++i ) { std::string strTemp( "(" +boost::lexical_cast<std::string>(i) + "," ); strTemp += boost::lexical_cast<std::string>(i+1) + ","; strTemp += boost::lexical_cast<std::string>(i+2) + ");"; std::string str<a href="/tag/sql/" target="_blank" class="keywords">sql</a>("INSERT INTO exam_en(language,math,computer) VALUES " + strTemp ); postgres->insert( (char*)str<a href="/tag/sql/" target="_blank" class="keywords">sql</a>.c_str() ); } char <a href="/tag/sql/" target="_blank" class="keywords">sql</a>[] = "SELECT * FROM exam_en;"; res = postgres->fetch(<a href="/tag/sql/" target="_blank" class="keywords">sql</a>); map_result::iterator it = res.begin(); for( ; it!=res.end(); ++it ) { std::cout << "ROW:" << it->first << std::endl; map<string,string>::iterator itField = it->second.begin(); for( ; itField!=it->second.end(); ++itField ) { std::cout << "Field:" << itField->first << " Value:" << itField->second << std::endl; } } return 0; }