pip install txpostgres
[database]
host = localhost
port = 5432
database = mydatabase
user = myuser
password = mypassword
from twisted.enterprise import adbapi
from twisted.internet import reactor
import ConfigParser
config = ConfigParser.ConfigParser()
config.read('config.ini')
host = config.get('database', 'host')
port = config.getint('database', 'port')
database = config.get('database', 'database')
user = config.get('database', 'user')
password = config.get('database', 'password')
dbpool = adbapi.ConnectionPool('txpostgres',
host=host,
port=port,
user=user,
password=password,
database=database)
def insert_data(txn):
query = "INSERT INTO employees (name, age) VALUES (%s, %s)"
data = ("John Doe", 30)
txn.execute(query, data)
dbpool.runInteraction(insert_data)
def handle_success(result):
print("Transaction successful!")
def handle_failure(error):
print("Transaction failed:", error)
dbpool.runInteraction(insert_data).addCallback(handle_success).addErrback(handle_failure)
