python
from twisted.internet import reactor
from twisted.internet.defer import inlineCallbacks
from twisted.enterprise import adbapi
import txpostgres
dbparams = {
'user': 'postgres',
'password': 'password',
'database': 'mydatabase',
'host': 'localhost',
'port': 5432,
}
dbpool = adbapi.ConnectionPool("txpostgres", **dbparams)
@inlineCallbacks
def query_database():
conn = yield dbpool.connect()
try:
result = yield conn.execute("SELECT * FROM mytable")
for row in result:
print(row)
finally:
conn.close()
reactor.stop()
reactor.callWhenRunning(query_database)
reactor.run()
