@@ -101,15 +101,16 @@ void exec(transaction_base& txn, char const* sql, ...)
101101 txn.exec (buf);
102102}
103103
104- xid_t execQuery ( transaction_base& txn,char const * sql, ...)
104+ template <class T >
105+ TexecQuery ( transaction_base& txn,char const * sql, ...)
105106{
106107 va_list args;
107108va_start (args, sql);
108109char buf[1024 ];
109110vsprintf (buf, sql, args);
110111va_end (args);
111112 result r = txn.exec (buf);
112- return r[0 ][0 ].as (xid_t ());
113+ return r[0 ][0 ].as (T ());
113114}
114115
115116void *reader (void * arg)
@@ -154,8 +155,8 @@ void* writer(void* arg)
154155exec (txn," update t set v = v + 1 where u=%d"
155156 t.updates +=2 ;
156157 }else {
157- int64_t sum =execQuery (txn," select v from t where u=%d"
158- +execQuery (txn," select v from t where u=%d"
158+ int64_t sum = execQuery< int64_t > (txn," select v from t where u=%d"
159+ + execQuery< int64_t > (txn," select v from t where u=%d"
159160if (sum > cfg.nIterations *cfg.nWriters || sum < -cfg.nIterations *cfg.nWriters ) {
160161printf (" Wrong sum=%ld\n "
161162 }
@@ -164,6 +165,7 @@ void* writer(void* arg)
164165 txn.commit ();
165166 t.transactions +=1 ;
166167 }catch (pqxx_exceptionconst & x) {
168+ printf (" EXCEPTION: %s\n " base ().what ());
167169 txn.abort ();
168170 t.aborts +=1 ;
169171 i -=1 ;