@@ -178,25 +178,20 @@ void* writer(void* arg)
178178
179179void initializeDatabase ()
180180{
181- // for (size_t i = 0; i < cfg.connections.size(); i++) {
182- // printf("creating extension %lu\n", i);
183- // try {
184- // connection conn(cfg.connections[i]);
185- // work txn(conn);
186- // //exec(txn, "drop extension if exists multimaster");
187- // exec(txn, "create extension multimaster");
188- // txn.commit();
189- // } catch (pqxx_exception const& x) {
190- // i -= 1;
191- // continue;
192- // }
193- // printf("extension %lu created\n", i);
194- // }
181+ connectionconn (cfg.connections [0 ]);
182+
183+ printf (" creating extension\n "
184+ {
185+ nontransactiontxn (conn);
186+ exec (txn," drop extension if exists multimaster"
187+ exec (txn," create extension multimaster"
188+ txn.commit ();
189+ }
190+ printf (" extension created\n "
195191
196192printf (" creating table t\n "
197- connectionconn (cfg.connections [0 ]);
198193{
199- work txn (conn);
194+ nontransaction txn (conn);
200195exec (txn," drop table if exists t"
201196exec (txn," create table t(u int primary key, v int)"
202197txn.commit ();