#include <iostream>
#include <sstream>
#include <stdio.h>

#include "pqxx/pqxx"

using namespace pqxx;
using namespace PGSTD;
using namespace std;

int main( ) {
	connection c( "dbname=test" );

	//c.trace( stdout );

	work t( c, "test transaction" );

	t.exec( "create table test( a integer, b integer)" );
	c.prepare( "insertTestStmt",
		"insert into test(a,b) values($1,$2)" );
	for( unsigned int i = 0; i < 1000; i++ ) {
		t.prepared( "insertTestStmt" )(i)(i).exec( );
	}

	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;
}