将 TransactionScope 与 MySQL 和读锁结合使用

Question

我有以下情况：

如果有一个带有 InnoDB 表的 MySQL 数据库，我用它来存储唯一的数字。 我启动一个事务，读取值（例如 1000471），将该值存储在另一个表中并更新增量值（100472）。 现在我想避免其他人在我的事务运行时读取该值。

如果我使用普通 MySQL，我会这样做：

Exceute("LOCK tbl1 READ");
执行("从 tbl1 选择 ...");
执行(“插入到tbl2”);
执行（“解锁表”）；

但由于我使用 SubSonic 作为 DAL 并且代码应该独立于 mysql，所以我必须使用 TransactionScope。

我的代码：

        TransactionOptions TransOpt = new TransactionOptions();
        TransOpt.IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted;
        TransOpt.Timeout = new TimeSpan(0, 2, 0);

        using (TransactionScope ts = new TransactionScope(TransactionScopeOption.RequiresNew, TransOpt))
        {

             // Select Row from tbl1

             // Do something

             ts.Complete();
        }

根据 TransactionOptions

的帮助system.transactions.isolationlevel

我想要达到的效果可以用 IsolationLevel.ReadCommited 来实现，但我仍然可以从事务外部读取该行（如果我尝试更改它，我会获得锁定，因此事务正在工作）

有人有建议吗？ TransactionScope 是否可以实现读锁

Answer 1

如果有人感兴趣，这就是 TransactionOptions 如何影响 MySql：

可以说我有两种方法。

Method1 启动一个事务，从表中选择一行，增加值并更新表。

方法2是一样的，但是在select和update之间我添加了1000ms的睡眠。

现在假设我有以下代码：

    Private Sub Button1_Click(sender as Object, e as System.EventArgs) Handles Button1.Click

        Dim thread1 As New Threading.Thread(AddressOf Method1)
        Dim thread2 As New Threading.Thread(AddressOf Method2)

        thread2.Start() // I start thread 2 first, because this one sleeps
        thread1.Start()

    End Sub

如果没有事务，就会发生这种情况：
thread2 启动，读取值 5，然后休眠，
线程1启动，读取值5，将值更新为6，
thread2 也将值更新为 6。

效果：我有两次唯一的号码。

我想要什么：
thread2 启动，读取值 5，然后休眠，
thread1 启动，尝试读取值，但获得锁并休眠，
thread2将值更新为6，
thread1 继续，读取值 6，将值更新为 7

这就是如何使用 TransactionScope 启动事务：

        TransactionOptions Opts = new TransactionOptions();
        Opts.IsolationLevel = IsolationLevel.ReadUncommitted;

        // start Transaction
        using (TransactionScope ts = new TransactionScope(TransactionScopeOption.RequiresNew, Opts))
        {
            // Do your work and call complete
            ts.Complete();
        }

甚至可以管理分布式事务。 如果抛出异常，则永远不会调用 ts.Complete，并且作用域的 Dispose() 部分将回滚事务。

以下概述了不同的 IsolationLevels 如何影响事务：

• IsolationLevel.Chaos
  抛出 NotSupportedException - 不支持混沌隔离级别

• IsolationLevel.ReadCommited
  事务不会互相干扰（两次相同的读取，不好）

• IsolationLevel.ReadUncomfilled
  事务不会相互干扰（两次相同的读取，不好）

• IsolationLevel.RepeatableRead
  事务不会互相干扰（两次相同的读取，不好）

• IsolationLevel.Serialized
  抛出 MySqlException - 尝试获取锁时发现死锁； 尝试在更新期间重新启动事务

• IsolationLevel.Snapshot
  抛出 MySqlException - SQL 语法有错误； 检查与您的 MySQL 服务器版本相对应的手册，了解在 Connection.Open() 期间第 1 行 '' 附近使用的正确语法

• IsolationLevel.Unspecified
  抛出 MySqlException - 尝试获取锁时发现死锁； 尝试在更新期间重新启动事务

• TransactionOptions 未设置
  抛出 MySqlException - 尝试获取锁时发现死锁； 尝试在更新期间重新启动事务

Answer 2

我的第一个猜测是使用SELECT FOR UPDATE，经过快速搜索后，我找到了一个关于锁定读取。

如果我理解正确的话，这与使用的隔离级别无关。 请注意 - 隔离级别仅说明当前事务如何受到其他事务更改的影响。 它没有告诉其他交易可以做什么。 然而，更高的隔离级别需要更多限制性的锁。

Answer 3

由于我没有找到一种方法来锁定一行以使用 InnoDB 和 TransactionScope 进行读取（我可能是错的），这应该可以工作：

如果我同时运行两个事务（没有 TransactionOptions）并且一个完成，另一个则无法完成，因为“死锁”异常。

根据 MySQL 文档，预计会出现死锁并重新启动事务。

如果您设置：

    TransactionOptions TransOpt = new TransactionOptions();
    TransOpt.IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted;

对于您的事务，您不会遇到死锁异常，但是，就我而言，这会导致重复的唯一编号，这更糟糕。

Answer 4

由于 SubSonic 似乎不支持 SELECT ... FOR UPDATE ，并且在我看来使用隔离级别将是一种误用 - 那么拥有一个 用户定义函数，它返回一个新的 id？ 该函数将使用 SELECT ... FOR UPDATE 读取 tbl1 中的当前值，更新该行并返回该值。

在您插入新值的应用程序代码中，您只需使用：

insert into tbl2 (id, ....) values (next_id(), ...)

Answer 5

好吧，我决定使用“后门”，现在使用内联查询：

        // start transaction
        using (TransactionScope ts = new TransactionScope(TransactionScopeOption.RequiresNew))
        {
            using (SharedDbConnectionScope scope = new SharedDbConnectionScope(DB._provider))
            {

                try
                {

                    Record r = new InlineQuery().ExecuteAsCollection<RecordCollection>(
                        String.Format("SELECT * FROM {0} WHERE {1} = ?param FOR UPDATE",
                                        Record.Schema.TableName,
                                        Record.Columns.Column1), "VALUE")[0];

                    // do something

                    r.Save();
                 }
             }
         }

我同时启动了 10 个线程，它按预期工作。 感谢鲁道夫森的“选择更新”提示。