import apypg
conn = apypg.Connection('dbname=loadtest')
cursor = conn.query("select * from transaction")
for row in cursor.tuples():
    pass
    #print row