要在事務中執行SQL語句,可以按照以下步驟進行操作:
connection = pymysql.connect(host='localhost', user='root', password='password', database='mydatabase')
cursor = connection.cursor()
connection.begin()
sql = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)"
data = ("value1", "value2")
cursor.execute(sql, data)
connection.commit()
connection.rollback()
cursor.close()
connection.close()
通過以上步驟,就可以在一個事務中執行多個SQL語句,并確保它們要么全部成功執行,要么全部不執行。