Add test for delayedquery.
--- a/.hgignore Tue Dec 06 16:20:53 2011 +0100
+++ b/.hgignore Tue Dec 06 16:45:29 2011 +0100
@@ -1,3 +1,7 @@
.*\.pyc
+.project
+.pydevproject
+.settings/org.eclipse.core.resources.prefs
pgtoolkit\.conf
build
+tests/tests\.conf
--- a/extras/test-db.sql Tue Dec 06 16:20:53 2011 +0100
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,6 +0,0 @@
-CREATE TABLE test
-(
- id serial NOT NULL,
- name varchar,
- PRIMARY KEY (id)
-);
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/tests/delayedquery.py Tue Dec 06 16:45:29 2011 +0100
@@ -0,0 +1,42 @@
+#!/usr/bin/env python3
+
+import logging
+import time
+
+from pgtoolkit import pgmanager
+from pgtoolkit.delayedquery import DelayedQuery
+
+
+class Config(dict):
+ def __init__(self, fname):
+ data = open(fname).read()
+ exec(data, dict(), self)
+
+
+if __name__ == '__main__':
+ cfg = Config('tests.conf')
+
+ pgm = pgmanager.get_instance()
+ pgm.create_conn(isolation_level = 'autocommit', **cfg)
+
+ handler = logging.StreamHandler()
+ logger = logging.getLogger('pgmanager')
+ logger.addHandler(handler)
+ logger.setLevel(logging.DEBUG)
+
+ dq = DelayedQuery(pgm)
+
+ print('add 1')
+ dq.add(10, 'INSERT INTO test (name) VALUES (%s)', ['spam1'], queryid=1)
+ dq.add(10, 'INSERT INTO test (name) VALUES (%s)', ['spam1'], queryid=1)
+ print('after 1')
+
+ time.sleep(5)
+
+ print('add 2')
+ dq.add(10, 'INSERT INTO test (name) VALUES (%s)', ['spam2'])
+
+ time.sleep(5)
+ print('after 10')
+
+ time.sleep(10)
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/tests/tests.conf.example Tue Dec 06 16:45:29 2011 +0100
@@ -0,0 +1,4 @@
+hostaddr='127.0.0.1'
+dbname='test'
+user='test'
+password='pass'
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/tests/tests.sql Tue Dec 06 16:45:29 2011 +0100
@@ -0,0 +1,6 @@
+CREATE TABLE test
+(
+ id serial NOT NULL,
+ name varchar,
+ PRIMARY KEY (id)
+);