#include #include #include #include "pqxx/pqxx" using namespace pqxx; using namespace PGSTD; using namespace std; int main( ) { connection c( "dbname=test" ); //c.trace( stdout ); cout << "Conntected to database." << endl << "Backend protocol version: " << c.server_version( ) << endl << "Protocol version: " << c.protocol_version( ) << endl << "Prepared Statements: " << c.supports( c.cap_prepared_statements ) << endl; work t( c, "test transaction" ); t.exec( "create table test( a integer, b integer)" ); for( unsigned int i = 0; i < 1000; i++ ) { ostringstream sql; sql << "insert into test values( '" << i << "', '" << i << "' )"; t.exec( sql.str( ) ); } result r( t.exec( "select * from test" ) ); cout << "a\tb" << endl; for( result::size_type i = 0; i < r.size( ); i++ ) { cout << r[i]["a"] << "\t" << r[i]["b"] << endl; } t.exec( "drop table test" ); t.commit( ); return 0; }