AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • 主页
  • 系统&网络
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • 主页
  • 系统&网络
    • 最新
    • 热门
    • 标签
  • Ubuntu
    • 最新
    • 热门
    • 标签
  • Unix
    • 最新
    • 标签
  • DBA
    • 最新
    • 标签
  • Computer
    • 最新
    • 标签
  • Coding
    • 最新
    • 标签
主页 / dba / 问题 / 346132
Accepted
J. Mini
J. Mini
Asked: 2025-04-12 07:15:22 +0800 CST2025-04-12 07:15:22 +0800 CST 2025-04-12 07:15:22 +0800 CST

如果禁止 MERGE,哪种并发安全插入方法最适合表值输入?

  • 772

这篇经典的并发安全文章显然是为一次只更新一行而设计的。在我的例子中,我有一个表值输入,并且希望以并发安全的方式更新每一行。我知道这并不总是可行的,但我希望尽可能地接近这一点。MERGE这似乎是一个自然的解决方案,但我并不信任它,而且它确实很容易出现 bug。Michael J. Swart 文章中剩下的两种方法是:

  1. 事务内部的锁提示(更新更常见)
CREATE PROCEDURE s_AccountDetails_Upsert ( @Email nvarchar(4000), @Etc nvarchar(max) )
AS 
SET XACT_ABORT ON;
BEGIN TRAN
 
  UPDATE TOP (1) dbo.AccountDetails WITH (UPDLOCK, SERIALIZABLE)
     SET Etc = @Etc
   WHERE Email = @Email;
 
  IF (@@ROWCOUNT = 0)
  BEGIN      
      INSERT dbo.AccountDetails ( Email, Etc )
      VALUES ( @Email, @Etc );
  END 
COMMIT
  1. 事务内部的锁提示(插入更常见的)
CREATE PROCEDURE s_AccountDetails_Upsert ( @Email nvarchar(4000), @Etc nvarchar(max) )
AS 
SET XACT_ABORT ON;
BEGIN TRAN
 
  INSERT dbo.AccountDetails ( Email, Etc )
  SELECT @Email, @Etc
  WHERE NOT EXISTS (
      SELECT *
      FROM dbo.AccountDetails WITH (UPDLOCK, SERIALIZABLE)
      WHERE Email = @Email
  )
 
  IF (@@ROWCOUNT = 0)
  BEGIN      
      UPDATE TOP (1) dbo.AccountDetails
      SET Etc = @Etc
      WHERE Email = @Email;
  END 
COMMIT 

我可以调整其中任何一个以使用表变量(例如,我怀疑IF (@@ROWCOUNT = 0)需要完全删除表变量),但是使用表值输入是否明显表明我们应该选择第一个或第二个解决方案?如果不是,那么应该基于什么做出决定?

sql-server
  • 2 2 个回答
  • 424 Views

2 个回答

  • Voted
  1. Best Answer
    Rob Farley
    2025-04-12T11:17:41+08:002025-04-12T11:17:41+08:00

    先执行更新,然后使用where not exists子句执行插入。无法测试,@@rowcount因为某些行可能已被更新。

    如果您先进行插入,那么您也会更新刚刚插入的行。

    • 6
  2. Paul White
    2025-04-13T18:35:32+08:002025-04-13T18:35:32+08:00

    问题MERGE通常体现在功能组合(尤其是相对较新的功能)上,这会导致数据更改计划极其复杂。这很遗憾,因为MERGE毫无疑问,这是一种表达“upsert”之类的便捷方式。

    解决方法

    您可以考虑以下事项:

    1. 在目标表上创建视图。
    2. 为视图和操作创建INSTEAD OF触发器。INSERTUPDATE
    3. 将您的“upsert”写为MERGE反对该观点。

    优点:

    1. 由于MERGE目标简单,所以数据变更计划并不复杂。
    2. SQL Server 为插入和删除的数据填充单独的内部工作表*。
    3. 触发器代码分别处理简单的插入和更新。
    4. 您不再需要围绕单独的插入和更新语句进行显式事务。

    缺点:

    1. 触发器会增加一些开销。
    2. 您必须记住将“upserts”定位到视图中。
    3. 该OUTPUT子句不适用于插入的引用。

    这种解决方法允许您编写一个方便的MERGE,但将生成的操作作为单独的简单插入和更新执行。

    MERGE仍然需要采取通常的并发预防措施。

    我使用了一个视图,假设您不希望INSTEAD OF在基表上使用触发器。

    *INSTEAD OF触发器不使用行版本控制。请参阅我的文章“关于 INSTEAD OF 触发器的有趣之处”。

    演示

    还有一些需要改进的地方(比如可以合并触发器)。以下代码优先考虑清晰度:

    db<>小提琴

    表格和示例行

    CREATE TABLE dbo.AccountDetails
    (
        Email nvarchar(400) NOT NULL 
            CONSTRAINT PK_AccountDetails 
            PRIMARY KEY CLUSTERED,
        Created datetime NOT NULL 
            DEFAULT GETUTCDATE(),
        Etc nvarchar(max) NULL
    );
    
    INSERT dbo.AccountDetails
        (Email, Etc)
    VALUES
        (N'[email protected]', N'Original 2792'),
        (N'[email protected]', N'Original 3129'),
        (N'[email protected]', N'Original 4726'),
        (N'[email protected]', N'Original 5766');
    

    看法

    CREATE VIEW 
        dbo.AccountDetails_Upsert
    WITH SCHEMABINDING
    AS
    SELECT 
        Email, 
        Etc 
    FROM dbo.AccountDetails;
    

    INSTEAD OF INSERT查看触发器

    CREATE TRIGGER 
        AccountDetails_Upsert_InsteadOfInsert
    ON dbo.AccountDetails_Upsert
    INSTEAD OF INSERT 
    AS
    IF  ROWCOUNT_BIG() = 0 RETURN;
    
    SET NOCOUNT, XACT_ABORT ON;
    SET ROWCOUNT 0;
    
    IF NOT EXISTS (SELECT * FROM Inserted) RETURN;
    
    -- Simple insert
    INSERT dbo.AccountDetails 
        (Email, Etc)
    SELECT 
        Email, Etc
    FROM Inserted;
    

    INSTEAD OF UPDATE查看触发器

    CREATE TRIGGER 
        AccountDetails_Upsert_InsteadOfUpdate
    ON dbo.AccountDetails_Upsert
    INSTEAD OF UPDATE 
    AS
    IF  ROWCOUNT_BIG() = 0 RETURN;
    
    SET NOCOUNT, XACT_ABORT ON;
    SET ROWCOUNT 0;
    
    IF NOT EXISTS (SELECT * FROM Inserted) RETURN;
    
    -- Simple update
    UPDATE AD
    SET Etc = I.Etc
    FROM Inserted AS I
    JOIN dbo.AccountDetails AS AD
        ON AD.Email = I.Email;
    

    表值MERGE

    DECLARE @Changes AS table
    (
        Email nvarchar(400) NOT NULL PRIMARY KEY,
        Etc nvarchar(max) NULL
    );
    
    INSERT @Changes
        (Email, Etc)
    VALUES
        -- Update some rows
        (N'[email protected]', N'Updated 2792'),
        (N'[email protected]', N'Updated 3129'),
        (N'[email protected]', N'Updated 4726'),
        (N'[email protected]', N'Updated 5766'),
        -- Insert some rows
        (N'[email protected]', N'Inserted a'),
        (N'[email protected]', N'Inserted b');
    
    MERGE dbo.AccountDetails_Upsert
    WITH 
    (
        UPDLOCK, 
        SERIALIZABLE,
        FORCESEEK
    ) AS V
    USING @Changes AS C
        ON C.Email = V.Email
    WHEN MATCHED THEN 
        UPDATE
        SET Etc = C.Etc
    WHEN NOT MATCHED BY TARGET THEN 
        INSERT (Email, Etc) 
        VALUES (C.Email, C.Etc);
    

    结果

    电子邮件 创建 ETC
    [电子邮件保护] 2025年4月13日 09:48:39.687 已更新 2792
    [电子邮件保护] 2025年4月13日 09:48:39.687 已更新 3129
    [电子邮件保护] 2025年4月13日 09:48:39.687 已更新 4726
    [电子邮件保护] 2025年4月13日 09:48:39.687 已更新 5766
    [电子邮件保护] 2025年4月13日 09:48:39.960 插入一个
    [电子邮件保护] 2025年4月13日 09:48:39.960 插入 b

    MERGE计划

    合并计划

    整理

    DROP VIEW IF EXISTS 
        dbo.AccountDetails_Upsert;
    
    DROP TABLE IF EXISTS 
        dbo.AccountDetails;
    
    • 2

相关问题

  • SQL Server - 使用聚集索引时如何存储数据页

  • 我需要为每种类型的查询使用单独的索引,还是一个多列索引可以工作?

  • 什么时候应该使用唯一约束而不是唯一索引?

  • 死锁的主要原因是什么,可以预防吗?

  • 如何确定是否需要或需要索引

Sidebar

Stats

  • 问题 205573
  • 回答 270741
  • 最佳答案 135370
  • 用户 68524
  • 热门
  • 回答
  • Marko Smith

    连接到 PostgreSQL 服务器:致命:主机没有 pg_hba.conf 条目

    • 12 个回答
  • Marko Smith

    如何让sqlplus的输出出现在一行中?

    • 3 个回答
  • Marko Smith

    选择具有最大日期或最晚日期的日期

    • 3 个回答
  • Marko Smith

    如何列出 PostgreSQL 中的所有模式?

    • 4 个回答
  • Marko Smith

    列出指定表的所有列

    • 5 个回答
  • Marko Smith

    如何在不修改我自己的 tnsnames.ora 的情况下使用 sqlplus 连接到位于另一台主机上的 Oracle 数据库

    • 4 个回答
  • Marko Smith

    你如何mysqldump特定的表?

    • 4 个回答
  • Marko Smith

    使用 psql 列出数据库权限

    • 10 个回答
  • Marko Smith

    如何从 PostgreSQL 中的选择查询中将值插入表中?

    • 4 个回答
  • Marko Smith

    如何使用 psql 列出所有数据库和表?

    • 7 个回答
  • Martin Hope
    Jin 连接到 PostgreSQL 服务器:致命:主机没有 pg_hba.conf 条目 2014-12-02 02:54:58 +0800 CST
  • Martin Hope
    Stéphane 如何列出 PostgreSQL 中的所有模式? 2013-04-16 11:19:16 +0800 CST
  • Martin Hope
    Mike Walsh 为什么事务日志不断增长或空间不足? 2012-12-05 18:11:22 +0800 CST
  • Martin Hope
    Stephane Rolland 列出指定表的所有列 2012-08-14 04:44:44 +0800 CST
  • Martin Hope
    haxney MySQL 能否合理地对数十亿行执行查询? 2012-07-03 11:36:13 +0800 CST
  • Martin Hope
    qazwsx 如何监控大型 .sql 文件的导入进度? 2012-05-03 08:54:41 +0800 CST
  • Martin Hope
    markdorison 你如何mysqldump特定的表? 2011-12-17 12:39:37 +0800 CST
  • Martin Hope
    Jonas 如何使用 psql 对 SQL 查询进行计时? 2011-06-04 02:22:54 +0800 CST
  • Martin Hope
    Jonas 如何从 PostgreSQL 中的选择查询中将值插入表中? 2011-05-28 00:33:05 +0800 CST
  • Martin Hope
    Jonas 如何使用 psql 列出所有数据库和表? 2011-02-18 00:45:49 +0800 CST

热门标签

sql-server mysql postgresql sql-server-2014 sql-server-2016 oracle sql-server-2008 database-design query-performance sql-server-2017

Explore

  • 主页
  • 问题
    • 最新
    • 热门
  • 标签
  • 帮助

Footer

AskOverflow.Dev

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve