SELECT TABLOCKX 然后 MERGE vs MERGE with TABLOCKX答案

【问题标题】：SELECT TABLOCKX then MERGE vs MERGE with TABLOCKXSELECT TABLOCKX 然后 MERGE vs MERGE with TABLOCKX
【发布时间】：2021-11-24 12:11:12
【问题描述】：

我原以为以下查询会产生相同的结果：

MERGE [myTable] AS T WITH (TABLOCKX)
...

SELECT TOP 1 1 FROM [myTable] WITH (TABLOCKX);
MERGE [myTable] AS T
...

但是，当从多个进程并行运行我的 MERGE 语句时，第一个会导致死锁，而第二个运行得很好。我在这里遗漏了什么吗？

我应该注意它在事务中运行。

编辑

我创建了一个示例 DDL 和 testdata 来重新创建问题：

DROP TABLE IF EXISTS [dbo].[myReference]
GO

DROP TABLE IF EXISTS [dbo].[myTable]
GO

CREATE TABLE [dbo].[myTable](
    [Primary key] [int] IDENTITY(1,1) NOT NULL,
    [Dataset key] [int] NOT NULL,
    [Key] [int] NOT NULL,
 CONSTRAINT [PK myTable] PRIMARY KEY CLUSTERED ([Primary key] ASC)
)
GO

CREATE TABLE [dbo].[myReference](
    [Foreign key] INT NOT NULL,
 CONSTRAINT [FK myReference myTable] FOREIGN KEY ([Foreign key]) REFERENCES [dbo].[myTable] ([Primary key]) ON DELETE CASCADE
)
GO

DROP PROCEDURE IF EXISTS [dbo].[usp]
GO

CREATE PROCEDURE [dbo].[usp] @DatasetKey INT AS

WITH Val AS (
    SELECT *
    FROM ( VALUES 
        (1),(2),(3),(4),(5),(6),(7),(8),(9),(10)
    ) s ([Value])
)

SELECT t1.[Value]
    + (t2.[Value] - 1) * 10 
    + (t3.[Value] - 1) * 100    
    + (t4.[Value] - 1) * 1000   
    + (t5.[Value] - 1) * 10000  
    + (t6.[Value] - 1) * 100000
    AS [Key]
INTO #t
FROM Val t1
    cross apply Val t2
    cross apply Val t3
    cross apply Val t4
    cross apply Val t5
    cross apply Val t6
;

--SELECT TOP 1 1 FROM [dbo].[myTable] WITH (TABLOCKX);

MERGE [dbo].[myTable] WITH (TABLOCKX) AS T
USING #t AS S
ON T.[Dataset key] = @DatasetKey
    AND T.[Key] = S.[Key]
WHEN NOT MATCHED BY TARGET THEN
    INSERT ([Dataset key], [Key]) VALUES (@DatasetKey, S.[Key])
WHEN NOT MATCHED BY SOURCE AND T.[Dataset key] = @DatasetKey THEN
    DELETE
;
GO

EXEC [dbo].[usp] 1
GO

EXEC [dbo].[usp] 2
GO

INSERT INTO [dbo].[myReference]
SELECT [Primary key]
FROM [dbo].[myTable]
GO

同时运行以下两个事务时，结果每次都会死锁。

TRAN 1

BEGIN TRY;
    BEGIN TRANSACTION;

    exec [dbo].[usp] 1;

    COMMIT TRANSACTION;
END TRY
BEGIN CATCH
    DECLARE @XactState INT = XACT_STATE();

    IF @XactState <> 0
        ROLLBACK TRANSACTION;

    THROW;
END CATCH;

TRAN 2

BEGIN TRY;
    BEGIN TRANSACTION;

    exec [dbo].[usp] 2;

    COMMIT TRANSACTION;
END TRY
BEGIN CATCH
    DECLARE @XactState INT = XACT_STATE();

    IF @XactState <> 0
        ROLLBACK TRANSACTION;

    THROW;
END CATCH;

死锁报告

<deadlock>
 <victim-list>
  <victimProcess id="process273cd96d468" />
 </victim-list>
 <process-list>
  <process id="process273cd96d468" taskpriority="0" logused="0" waitresource="OBJECT: 42:1282103608:0 " waittime="2356" ownerId="2255393274" transactionname="user_transaction" lasttranstarted="2021-11-26T16:11:20.080" XDES="0x296a4fb64d0" lockMode="X" schedulerid="4" kpid="19904" status="suspended" spid="67" sbid="0" ecid="0" priority="0" trancount="2" lastbatchstarted="2021-11-26T16:11:20.080" lastbatchcompleted="2021-11-26T16:11:20.077" lastattention="1900-01-01T00:00:00.077" clientapp="Microsoft SQL Server Management Studio - Query" hostname="SV00415" hostpid="21276" loginname="VIECURI\mhoogeveen" isolationlevel="read committed (2)" xactid="2255393274" currentdb="42" currentdbname="Test20211126KanDaarnaWeg" lockTimeout="4294967295" clientoption1="671090784" clientoption2="390200">
   <executionStack>
    <frame procname="Test20211126KanDaarnaWeg.dbo.usp" line="29" stmtstart="1050" stmtend="1626" sqlhandle="0x03002a00aaa1534ecba70a01ecad000001000000000000000000000000000000000000000000000000000000">
MERGE [dbo].[myTable] WITH (TABLOCKX) AS T
USING #t AS S
ON T.[Dataset key] = @DatasetKey
    AND T.[Key] = S.[Key]
WHEN NOT MATCHED BY TARGET THEN
    INSERT ([Dataset key], [Key]) VALUES (@DatasetKey, S.[Key])
WHEN NOT MATCHED BY SOURCE AND T.[Dataset key] = @DatasetKey THEN
    DELETE    </frame>
    <frame procname="adhoc" line="4" stmtstart="72" stmtend="106" sqlhandle="0x020000009f228824b51645ad1d06b456eabe7b2b24f2e8fe0000000000000000000000000000000000000000">
unknown    </frame>
   </executionStack>
   <inputbuf>
BEGIN TRY;
    BEGIN TRANSACTION;

    exec [dbo].[usp] 2;

    COMMIT TRANSACTION;
END TRY
BEGIN CATCH
    DECLARE @XactState INT = XACT_STATE();

    IF @XactState &lt;&gt; 0
        ROLLBACK TRANSACTION;

    THROW;
END CATCH;   </inputbuf>
  </process>
  <process id="process273c6c4b088" taskpriority="0" logused="0" waitresource="OBJECT: 42:1250103494:0 " waittime="2994" ownerId="2255393256" transactionname="user_transaction" lasttranstarted="2021-11-26T16:11:19.633" XDES="0x27385bfd080" lockMode="X" schedulerid="1" kpid="8752" status="suspended" spid="53" sbid="0" ecid="0" priority="0" trancount="2" lastbatchstarted="2021-11-26T16:11:19.633" lastbatchcompleted="2021-11-26T16:11:19.630" lastattention="1900-01-01T00:00:00.630" clientapp="Microsoft SQL Server Management Studio - Query" hostname="SV00415" hostpid="21276" loginname="VIECURI\mhoogeveen" isolationlevel="read committed (2)" xactid="2255393256" currentdb="42" currentdbname="Test20211126KanDaarnaWeg" lockTimeout="4294967295" clientoption1="671090784" clientoption2="390200">
   <executionStack>
    <frame procname="Test20211126KanDaarnaWeg.dbo.usp" line="29" stmtstart="1050" stmtend="1626" sqlhandle="0x03002a00aaa1534ecba70a01ecad000001000000000000000000000000000000000000000000000000000000">
MERGE [dbo].[myTable] WITH (TABLOCKX) AS T
USING #t AS S
ON T.[Dataset key] = @DatasetKey
    AND T.[Key] = S.[Key]
WHEN NOT MATCHED BY TARGET THEN
    INSERT ([Dataset key], [Key]) VALUES (@DatasetKey, S.[Key])
WHEN NOT MATCHED BY SOURCE AND T.[Dataset key] = @DatasetKey THEN
    DELETE    </frame>
    <frame procname="adhoc" line="4" stmtstart="72" stmtend="106" sqlhandle="0x020000002457720d4bb1099d3682fee9760829cab4bbc2be0000000000000000000000000000000000000000">
unknown    </frame>
   </executionStack>
   <inputbuf>
BEGIN TRY;
    BEGIN TRANSACTION;

    exec [dbo].[usp] 1;

    COMMIT TRANSACTION;
END TRY
BEGIN CATCH
    DECLARE @XactState INT = XACT_STATE();

    IF @XactState &lt;&gt; 0
        ROLLBACK TRANSACTION;

    THROW;
END CATCH;   </inputbuf>
  </process>
 </process-list>
 <resource-list>
  <objectlock lockPartition="0" objid="1282103608" subresource="FULL" dbid="42" objectname="Test20211126KanDaarnaWeg.dbo.myReference" id="lock29a7a3f4780" mode="IX" associatedObjectId="1282103608">
   <owner-list>
    <owner id="process273c6c4b088" mode="IX" />
   </owner-list>
   <waiter-list>
    <waiter id="process273cd96d468" mode="X" requestType="convert" />
   </waiter-list>
  </objectlock>
  <objectlock lockPartition="0" objid="1250103494" subresource="FULL" dbid="42" objectname="Test20211126KanDaarnaWeg.dbo.myTable" id="lock28a11c39800" mode="X" associatedObjectId="1250103494">
   <owner-list>
    <owner id="process273cd96d468" mode="X" />
    <owner id="process273cd96d468" mode="X" />
    <owner id="process273cd96d468" mode="X" />
    <owner id="process273cd96d468" mode="X" />
    <owner id="process273cd96d468" mode="X" />
    <owner id="process273cd96d468" mode="X" />
   </owner-list>
   <waiter-list>
    <waiter id="process273c6c4b088" mode="X" requestType="wait" />
   </waiter-list>
  </objectlock>
 </resource-list>
</deadlock>

【问题讨论】：

嗨，门诺。请阅读：Use Caution with SQL Server's MERGE Statement，特别是 SQL Server Merge Concurrency Issues 部分。
它们的行为应该相同 w.r.t. myTable 的锁定。你能发布死锁xml吗？
HOLDLOCK, UPDLOCK 应该能解决第一个版本中的大部分问题，你可能不需要TABLOCKX。见weblogs.sqlteam.com/dang/2009/01/31/…
@TT 感谢分享，不知道！但是，在事务中运行，甚至按照@Charlieface 的建议使用HOLDLOCK，我似乎无法直接在 MERGE 语句中使用锁定提示。
@DavidBrowne-Microsoft 更新了我的问题！

标签： sql-server tsql deadlock sql-server-2017

【解决方案1】：

看起来不同之处在于 MERGE with TABLOCKX 最初确实使用 IX 锁，而 SELECT ... WITH TABLOCKX 没有。

我在 SQL Server 2019 CU 14 上验证了此分析 lock:acquired 事件，并且使用较小的表能够重现死锁。这是一个极短的窗口，可能会发生这种情况，并且较大的表不允许我的系统上有足够的并发性。

这会创建一个小窗口，其中两个会话可以获取 IX 表锁，但都不能升级为 X 锁。

如果要序列化一段代码，sp_getapplock是最简单的方法。

【讨论】：

将其添加到与 MERGE 相关的问题列表中。