pip install txpostgres
python
from twisted.internet import defer, task
from twisted.python import log
from txpostgres import txpostgres
python
db_config = {
'host': 'localhost',
'port': 5432,
'database': 'mydatabase',
'user': 'myuser',
'password': 'mypassword'
}
python
dbpool = txpostgres.ConnectionPool(
None,
**db_config
)
python
@defer.inlineCallbacks
def query_data():
try:
conn = yield dbpool.connection()
result = yield conn.runQuery("SELECT * FROM mytable")
for row in result:
print(row)
finally:
conn.close()
task.react(query_data)
python
@defer.inlineCallbacks
def query_data():
try:
conn = yield dbpool.connection()
result = yield conn.runQuery("SELECT * FROM mytable")
for row in result:
print(row)
except txpostgres.PostgresError as e:
print("Query error:", e)
finally:
conn.close()
