python
from twisted.internet import reactor
from twisted.enterprise import adbapi
import txpostgres
db_params = {
'host': 'localhost',
'port': 5432,
'database': 'mydatabase',
'user': 'myuser',
'password': 'mypassword'
}
connection_pool = adbapi.ConnectionPool(
"txpostgres",
cp_min=1,
cp_max=10,
cp_reconnect=True,
**db_params
)
def query_database():
query = "SELECT * FROM users"
return connection_pool.runQuery(query)
deferred = query_database()
def handle_result(result):
for row in result:
print(row)
deferred.addCallback(handle_result)
reactor.run()
