pip install twisted
pip install psycopg2
python
from twisted.enterprise import adbapi
dsn = "dbname=mydatabase user=myuser password=mypassword host=myhost port=myport"
dbpool = adbapi.ConnectionPool("txpostgres", dsn=dsn)
python
def query_result(result):
print(result)
dbpool.runQuery("SELECT * FROM tablename").addCallbacks(query_result, errback=None)
python
def transaction_result(result):
print("Transaction completed successfully.")
def transaction_error(error):
print("Transaction failed:", error)
dbpool.runInteraction(transaction_logic).addCallbacks(transaction_result, transaction_error)
python
try:
dbpool.runQuery("SELECT * FROM non_existing_table")
except Exception as e:
print("Error occurred:", e)
