2
import psycopg2.extensions
4
class Portal(psycopg2.extensions.cursor):
5
def __init__(self, name, curs):
7
psycopg2.extensions.cursor.__init__(self, curs.connection, name)
9
CURSOR = psycopg2.extensions.new_type((1790,), "CURSOR", Portal)
10
psycopg2.extensions.register_type(CURSOR)
12
conn = psycopg2.connect("dbname=test")
15
curs.execute("SELECT reffunc2()")
16
portal = curs.fetchone()[0]
17
print portal.fetchone()
19
print portal.fetchall()
23
#print curs.statusmessage
24
#print curs.fetchone()
26
#print curs.statusmessage
27
#print curs.fetchone()
29
#print curs.statusmessage