Azure无服务器函数SQL插入竞态条件消除及纯SQL方案咨询

一、纯SQL层面的解决方案（无需大量修改代码） #

这些方案直接在SQL层面实现原子化逻辑，应用层只需替换原有语句或调用存储过程，不用改动核心业务逻辑。

1. MERGE原子化操作 #

用MERGE语句把「判断存在+插入」合并为一个原子操作，数据库引擎会全程保证逻辑一致性：

MERGE INTO 目标表 t
USING (SELECT @主键值 AS 主键列, @其他字段值 AS 其他列) s
ON t.主键列 = s.主键列
WHEN NOT MATCHED THEN
    INSERT (主键列, 其他列) VALUES (s.主键列, s.其他列);

执行后要么插入新行，要么无操作，不会出现竞态导致的唯一键冲突。

2. INSERT ... WHERE NOT EXISTS #

依赖表已有的唯一键约束，将存在性检查和插入放在同一条语句中，同样是原子执行：

INSERT INTO 目标表 (主键列, 其他列)
SELECT @主键值, @其他字段值
WHERE NOT EXISTS (SELECT 1 FROM 目标表 WHERE 主键列 = @主键值);

如果目标行已存在，这条语句会返回0行插入，不会抛出异常；若不存在则正常插入。

3. 封装为存储过程复用逻辑 #

把判断和插入逻辑封装成存储过程，所有Azure函数直接调用即可，统一逻辑且避免重复代码：

CREATE PROCEDURE dbo.UpsertTargetRecord
    @主键值 INT, -- 替换为实际字段类型
    @其他字段值 NVARCHAR(100) -- 替换为实际字段类型
AS
BEGIN
    SET NOCOUNT ON;
    
    INSERT INTO 目标表 (主键列, 其他列)
    SELECT @主键值, @其他字段值
    WHERE NOT EXISTS (SELECT 1 FROM 目标表 WHERE 主键列 = @主键值);
    
    -- 返回执行状态：1=插入成功，0=记录已存在
    RETURN CASE WHEN @@ROWCOUNT > 0 THEN 1 ELSE 0 END;
END;

应用层调用示例：

DECLARE @Result INT;
EXEC @Result = dbo.UpsertTargetRecord @主键值=123, @其他字段值='测试内容';

4. 手动加锁（不推荐，影响并发） #

如果上述方案不适用，可通过事务加锁实现，但会降低数据库并发性能，仅用于特殊场景：

BEGIN TRANSACTION;
-- 锁定目标行范围，防止其他会话插入或修改
SELECT 1 FROM 目标表 WITH (UPDLOCK, HOLDLOCK) WHERE 主键列 = @主键值;

IF NOT EXISTS (SELECT 1 FROM 目标表 WHERE 主键列 = @主键值)
BEGIN
    INSERT INTO 目标表 (主键列, 其他列) VALUES (@主键值, @其他字段值);
END;
COMMIT TRANSACTION;

UPDLOCK获取更新锁，HOLDLOCK保持锁直到事务结束，确保同一时间只有一个会话能处理该行。

二、应用层补充方案 #

如果无法修改SQL逻辑，可在Azure函数层面处理：

• 捕获唯一键冲突异常：当插入抛出唯一键约束错误（如SQL Server错误码2627），直接忽略该异常，因为此时目标行已存在，无需重复插入。
• 分布式锁：借助Azure Redis或Azure Blob存储实现分布式锁，函数执行前先获取锁，执行完成后释放锁。例如用Redis的SETNX命令，只有拿到锁的实例才能执行SELECT+INSERT逻辑，需注意设置锁超时时间，避免死锁。

内容的提问来源于stack exchange，提问作者Ryan