summaryrefslogtreecommitdiff
path: root/sandbox/async.py
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/async.py')
-rw-r--r--sandbox/async.py36
1 files changed, 36 insertions, 0 deletions
diff --git a/sandbox/async.py b/sandbox/async.py
new file mode 100644
index 0000000..17e96d0
--- /dev/null
+++ b/sandbox/async.py
@@ -0,0 +1,36 @@
+import datetime
+import time
+import psycopg2
+
+#d = datetime.timedelta(12, 100, 9876)
+#print d.days, d.seconds, d.microseconds
+#print psycopg.adapt(d).getquoted()
+
+conn = psycopg2.connect("dbname=test_unicode")
+conn.set_client_encoding("xxx")
+curs = conn.cursor()
+#curs.execute("SELECT 1.0 AS foo")
+#print curs.fetchmany(2)
+#print curs.fetchall()
+
+def sleep(curs):
+ while not curs.isready():
+ print "."
+ time.sleep(.1)
+
+#curs.execute("""
+# DECLARE zz INSENSITIVE SCROLL CURSOR WITH HOLD FOR
+# SELECT now();
+# FOR READ ONLY;""", async = 1)
+curs.execute("SELECT now() AS foo", async=1);
+sleep(curs)
+print curs.fetchall()
+
+#curs.execute("""
+# FETCH FORWARD 1 FROM zz;""", async = 1)
+curs.execute("SELECT now() AS bar", async=1);
+print curs.fetchall()
+
+curs.execute("SELECT now() AS bar");
+sleep(curs)
+