python
from twisted.internet import reactor
from txpostgres import txpostgres
dbpool = txpostgres.ConnectionPool(
host='localhost',
port=5432,
database='mydatabase',
user='myuser',
password='mypassword'
)
def handle_error(error):
print("Database error:", error)
def handle_connect(conn):
print("Connected to database")
def handle_disconnect(conn):
print("Disconnected from database")
dbpool.start()
dbpool.addCallback(handle_connect)
dbpool.addErrback(handle_error)
dbpool.addDisconnectCallback(handle_disconnect)
reactor.run()
python
from twisted.internet import reactor
from txpostgres import txpostgres
def handle_query_success(result):
print("Query result:", result)
def handle_query_error(error):
print("Query error:", error)
def handle_connect(conn):
d = conn.runQuery("SELECT * FROM mytable")
d.addCallback(handle_query_success)
d.addErrback(handle_query_error)
reactor.run()
python
from twisted.internet import reactor
from txpostgres import txpostgres
def handle_transaction_success(result):
print("Transaction succeeded")
def handle_transaction_error(error):
print("Transaction error:", error)
def handle_connect(conn):
conn.runOperation("BEGIN")
d = conn.runOperation("INSERT INTO mytable (column1, column2) VALUES (value1, value2)")
d.addCallback(handle_transaction_success)
d.addErrback(handle_transaction_error)
d.addBoth(lambda _: conn.runOperation("COMMIT"))
reactor.run()
