python
from twisted.internet import reactor
from twisted.enterprise import adbapi
import txpostgres
db_params = {
'database': 'mydatabase',
'user': 'myuser',
'password': 'mypassword',
'host': 'localhost',
'port': 5432,
}
db_pool = adbapi.ConnectionPool(txpostgres, **db_params)
@db_pool.runQuery
def select_data(txn):
txn.execute('SELECT * FROM mytable')
return txn.fetchall()
def handle_result(result):
for row in result:
print(row)
d = select_data()
d.addCallback(handle_result)
reactor.run()
pip install twisted
pip install txpostgres
