python
from twisted.internet import defer
from twisted.python import log
from txpostgres import txpostgres
db_config = {
'database': 'mydatabase',
'user': 'myuser',
'password': 'mypassword',
'host': 'localhost',
'port': 5432
}
@defer.inlineCallbacks
def query_database():
connection_pool = txpostgres.ConnectionPool(**db_config)
conn = yield connection_pool.get()
try:
result = yield conn.runQuery('SELECT * FROM mytable')
for row in result:
print(row)
except Exception as e:
log.err(e)
finally:
connection_pool.put(conn)
query_database()
