pip install txpostgres
python
from twisted.internet import defer
from twisted.internet import reactor
from txpostgres import txpostgres
python
database = txpostgres.Connection(
host='localhost',
port=5432,
user='username',
password='password',
database='database_name'
)
python
def connect():
return database.connect()
python
def insert_data(txn):
query = "INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')"
return txn.execute(query)
def update_data(txn):
query = "UPDATE table_name SET column1 = 'new_value' WHERE column2 = 'value2'"
return txn.execute(query)
def delete_data(txn):
query = "DELETE FROM table_name WHERE column1 = 'value1'"
return txn.execute(query)
python
def execute_transaction(txn):
return d
python
def run_transaction():
return database.runInteraction(execute_transaction)
python
from twisted.internet import defer
from twisted.internet import reactor
from txpostgres import txpostgres
database = txpostgres.Connection(
host='localhost',
port=5432,
user='username',
password='password',
database='database_name'
)
def connect():
return database.connect()
def insert_data(txn):
query = "INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')"
return txn.execute(query)
def update_data(txn):
query = "UPDATE table_name SET column1 = 'new_value' WHERE column2 = 'value2'"
return txn.execute(query)
def delete_data(txn):
query = "DELETE FROM table_name WHERE column1 = 'value1'"
return txn.execute(query)
def execute_transaction(txn):
d = insert_data(txn)
d.addCallback(lambda _: update_data(txn))
d.addCallback(lambda _: delete_data(txn))
return d
def run_transaction():
return database.runInteraction(execute_transaction)
if __name__ == '__main__':
connect().addCallback(lambda _: run_transaction()).addBoth(lambda _: reactor.stop())
reactor.run()
