diff -r 73f0d53fef6b -r 26209e9984b2 tests/delayedquery.py --- /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)