7

SQL Server 2008 で SELECT/UPDATE のデッドロックに問題があります。このスレッドからの回答を読みました: SQL Server は選択/更新または複数の選択の間でデッドロックしますが、デッドロックが発生する理由はまだわかりません。

次のテストケースで状況を再現しました。

私はテーブルを持っています:

CREATE TABLE [dbo].[SessionTest](
    [SessionId] UNIQUEIDENTIFIER ROWGUIDCOL NOT NULL,
    [ExpirationTime] DATETIME NOT NULL,
    CONSTRAINT [PK_SessionTest] PRIMARY KEY CLUSTERED (
        [SessionId] ASC
    ) WITH (
        PAD_INDEX  = OFF, 
        STATISTICS_NORECOMPUTE  = OFF, 
        IGNORE_DUP_KEY = OFF, 
        ALLOW_ROW_LOCKS  = ON, 
        ALLOW_PAGE_LOCKS  = ON
    ) ON [PRIMARY]
) ON [PRIMARY]
GO

ALTER TABLE [dbo].[SessionTest] 
    ADD CONSTRAINT [DF_SessionTest_SessionId] 
    DEFAULT (NEWID()) FOR [SessionId]
GO

最初にこのテーブルからレコードを選択しようとしています。レコードが存在する場合は、有効期限を現在の時刻に間隔を加えたものに設定します。次のコードを使用して実現します。

protected Guid? GetSessionById(Guid sessionId, SqlConnection connection, SqlTransaction transaction)
{
    Logger.LogInfo("Getting session by id");
    using (SqlCommand command = new SqlCommand())
    {
        command.CommandText = "SELECT * FROM SessionTest WHERE SessionId = @SessionId";
        command.Connection = connection;
        command.Transaction = transaction;
        command.Parameters.Add(new SqlParameter("@SessionId", sessionId));

        using (SqlDataReader reader = command.ExecuteReader())
        {
            if (reader.Read())
            {
                Logger.LogInfo("Got it");
                return (Guid)reader["SessionId"];
            }
            else
            {
                return null;
            }
        }
    }
}

protected int UpdateSession(Guid sessionId, SqlConnection connection, SqlTransaction transaction)
{
    Logger.LogInfo("Updating session");
    using (SqlCommand command = new SqlCommand())
    {
        command.CommandText = "UPDATE SessionTest SET ExpirationTime = @ExpirationTime WHERE SessionId = @SessionId";
        command.Connection = connection;
        command.Transaction = transaction;
        command.Parameters.Add(new SqlParameter("@ExpirationTime", DateTime.Now.AddMinutes(20)));
        command.Parameters.Add(new SqlParameter("@SessionId", sessionId));
        int result = command.ExecuteNonQuery();
        Logger.LogInfo("Updated");
        return result;
    }
}

public void UpdateSessionTest(Guid sessionId)
{
    using (SqlConnection connection = GetConnection())
    {
        using (SqlTransaction transaction = connection.BeginTransaction(IsolationLevel.Serializable))
        {
            if (GetSessionById(sessionId, connection, transaction) != null)
            {
                Thread.Sleep(1000);
                UpdateSession(sessionId, connection, transaction);
            }
            transaction.Commit();
        }
    }
}

次に、2 つのスレッドからテスト メソッドを実行しようとして、それらが同じレコードを更新しようとすると、次の出力が得られます。

[4] : Creating/updating session
[3] : Creating/updating session
[3] : Getting session by id
[3] : Got it
[4] : Getting session by id
[4] : Got it
[3] : Updating session
[4] : Updating session
[3] : Updated
[4] : Exception: Transaction (Process ID 59) was deadlocked 
on lock resources with another process and has been 
chosen as the deadlock victim. Rerun the transaction.

Serializable Isolation Level を使用してどのように発生するのか理解できません。最初の選択で行/テーブルをロックする必要があり、別の選択でロックを取得できないと思います。この例はコマンド オブジェクトを使用して記述されていますが、これは単なるテスト用です。元々、私はlinqを使用していますが、単純化された例を示したかったのです。Sql Server Profiler は、デッドロックがキー ロックであることを示しています。数分で質問を更新し、SQL サーバー プロファイラーからグラフを投稿します。どんな助けでも大歓迎です。この問題の解決策は、コード内にクリティカル セクションを作成することである可能性があることは理解していますが、Serializable Isolation Level でうまくいかない理由を理解しようとしています。

そして、これがデッドロック グラフです: デッドロック http://img7.imageshack.us/img7/9970/deadlock.gif

前もって感謝します。

4

1 に答える 1

4

これが機能するためにロックをヒントする必要があるシリアル化可能なトランザクションを持つだけでは十分ではありません。

シリアライズ可能な分離レベルは、通常、シリアライズ可能な条件 (反復可能な読み取り、ファントム行がないなど) が確実に満たされるようにすることができる「最も弱い」タイプのロックを取得します。

したがって、後で(シリアル化可能なトランザクションで)更新ロックにアップグレードしようとしているテーブルの共有ロックを取得しています。別のスレッドが共有ロックを保持している場合、アップグレードは失敗します (他のスレッドが共有ロックを保持していなければ機能します)。

おそらく、次のように変更する必要があります。

SELECT * FROM SessionTest with (updlock) WHERE SessionId = @SessionId

これにより、SELECT の実行時に更新ロックが確実に取得されます (したがって、ロックをアップグレードする必要はありません)。

于 2009-06-06T11:40:16.453 に答える