tests/delayedquery.py
changeset 21 26209e9984b2
child 22 680631f35d83
--- /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)