python - 在 PyMySQL 中回滚多个查询

Question

有人发布了与此类似的问题，但不幸的是，没有一个建议的解决方案对我有用。

我想看看我是否可以在一个 try 子句中编写两个查询，并在其中一个抛出异常时让它们都回滚。为了确保抛出异常，我只是尝试创建同一个表两次。

def function():
        try:
            cursor = connection.cursor()
                
            q1 = "CREATE TABLE 0_test_table (column1 varchar(255))"
            cursor.execute(q1)
            
            q1 = "CREATE TABLE 0_test_table (column1 varchar(255))"
            cursor.execute(q1)
                
        except pymysql.Error as e:
            print("Exception encountered")
            print(e)
            try:
                connection.rollback()
            except:
                print("rollback failed")
                pass
            
        else:
            connection.commit()
            connection.close()
                   
function()

打印的是:

Exception encountered
(1050, "Table '0_test_table' already exists")

由于异常是由查询引发的，而不是由回滚引发的，我认为它一定是回滚了更改。我检查了数据库，表已经创建。为什么回滚不起作用？这也引出了关于 commit 方法的作用的问题。由于我从未在我的代码中访问过 else，因此我从未访问过提交方法，但事情显然已提交。

我试图改编我在 O'Reilly 网站上找到的一个例子 here .这让我有:

def function():
    try:
        connection.begin()
        cursor = connection.cursor()
            
        q1 = "CREATE TABLE 0_test_table (column1 varchar(255))"
        cursor.execute(q1)
        
        q1 = "CREATE TABLE 0_test_table (column1 varchar(255))"
        cursor.execute(q1)
        
        cursor.close()
        connection.commit()
            
    except pymysql.Error as e:
        print("Exception encountered")
        print(e)
        try:
            connection.rollback()
        except:
            print("rollback failed")
            pass
               
function()

再次打印:

Exception encountered
(1050, "Table '0_test_table' already exists")

又一次在数据库中创建了表。

Answer 1

正如您在引用中看到的，无法完成 CREATE TABLE 的 ROLLBACK。

"The CREATE TABLE statement in InnoDB is processed as a single transaction. This means that a ROLLBACK from the user does not undo CREATE TABLE statements the user made during that transaction."

参见 manual