diff options
| -rw-r--r-- | lem/postgres/queued.lua | 4 | ||||
| -rwxr-xr-x | test.lua | 5 |
2 files changed, 8 insertions, 1 deletions
diff --git a/lem/postgres/queued.lua b/lem/postgres/queued.lua index f405dc0..bfedd3f 100644 --- a/lem/postgres/queued.lua +++ b/lem/postgres/queued.lua @@ -82,6 +82,10 @@ end QConnection.exec = wrap(Connection.exec) QConnection.prepare = wrap(Connection.prepare) QConnection.run = wrap(Connection.run) +QConnection.get = wrap(Connection.get) +QConnection.put = wrap(Connection.put) +QConnection.done = wrap(Connection.done) +QConnection.reset = wrap(Connection.reset) local qconnect do @@ -58,7 +58,8 @@ do end local utils = require 'lem.utils' -local postgres = require 'lem.postgres' +--local postgres = require 'lem.postgres' +local postgres = require 'lem.postgres.queued' local dbconnstr = [[ host=localhost @@ -69,6 +70,8 @@ dbname=mydb local db = assert(postgres.connect(dbconnstr)) +assert(db:reset()) + assert(db:exec( 'CREATE TEMPORARY TABLE mytable (id serial PRIMARY KEY, name TEXT, foo integer)')) |