SSMS适配API调用的UPSERT存储过程编写问题咨询

你现在写的测试代码已经完成了「id存在则更新」的基础判断，只要补全id不存在时的插入逻辑、以及更新前的状态校验即可，下面是可以直接复用的实现：

纯SQL逻辑实现（完全匹配你的需求规则） #

这个写法逻辑拆分清晰，适合入门阶段理解，每一步操作都和你提的规则一一对应：

-- 以下两个是待写入的动态参数，实际调用时替换成接口拿到的真实数据即可
DECLARE @InputId VARCHAR(32) = 'DS24960882'; -- 字段类型、长度和你表中id字段保持一致
DECLARE @InputCleared BIT = 0; -- 字段类型和cleared字段对齐，SSMS里布尔值一般用BIT类型

-- 规则1：校验id是否已存在
IF EXISTS (SELECT 1 FROM critical_alerts WHERE id = @InputId)
BEGIN
    -- 规则2：仅当cleared状态和传入值不一致时才执行更新，避免无意义的写操作
    UPDATE critical_alerts 
    SET cleared = @InputCleared
    WHERE id = @InputId AND cleared <> @InputCleared;
END
ELSE
BEGIN
    -- 规则3：id不存在，插入全新记录，记得把表中其他需要写入的字段补全
    INSERT INTO critical_alerts (id, cleared /* 其他字段名写在这里 */)
    VALUES (@InputId, @InputCleared /* 对应其他字段的参数值写在这里 */);
END

如果后续你对SQL更熟悉，也可以用SQL Server原生支持的MERGE语法实现同样的逻辑，代码更简洁，执行性能也更好：

DECLARE @InputId VARCHAR(32) = 'DS24960882';
DECLARE @InputCleared BIT = 0;

MERGE critical_alerts AS target
USING (SELECT @InputId AS id, @InputCleared AS cleared) AS source
ON target.id = source.id
-- 匹配到id且cleared状态不一致时更新
WHEN MATCHED AND target.cleared <> source.cleared THEN
    UPDATE SET target.cleared = source.cleared
-- 未匹配到id时插入新记录
WHEN NOT MATCHED THEN
    INSERT (id, cleared /* 其他字段名 */) 
    VALUES (source.id, source.cleared /* 其他字段值 */);

小提示：如果你的cleared字段允许存NULL值，判断状态变化的条件要改成 cleared <> @InputCleared OR cleared IS NULL OR @InputCleared IS NULL，避免NULL值比较失效；如果字段设置了NOT NULL约束可以忽略这个点。

Python对接注意事项 #

你用Python开发API对接的时候，注意两个关键点即可：

• 不要在Python代码里先单独发一条SELECT语句判断id是否存在，多一次数据库请求不说，高并发场景下还容易出现数据冲突，直接把上面的整段SQL交给数据库执行，所有判断逻辑在数据库侧完成，更稳定高效。
• 一定要用参数化查询传值，不要把接口拿到的数据直接拼接到SQL字符串里，避免SQL注入风险，也不用手动处理特殊字符转义。以常用的pyodbc驱动为例，调用代码参考：

import pyodbc

# 替换成你自己的数据库连接信息
conn = pyodbc.connect(
    'DRIVER={ODBC Driver 17 for SQL Server};SERVER=你的数据库服务器地址;DATABASE=你的库名;UID=账号;PWD=密码'
)
cursor = conn.cursor()

# 接口返回的待写入告警数据
alert_info = {"id": "DS24960882", "cleared": 0}

# SQL语句里用?做参数占位符
write_sql = """
IF EXISTS (SELECT 1 FROM critical_alerts WHERE id = ?)
BEGIN
    UPDATE critical_alerts 
    SET cleared = ?
    WHERE id = ? AND cleared <> ?;
END
ELSE
BEGIN
    INSERT INTO critical_alerts (id, cleared)
    VALUES (?, ?);
END
"""

# 按占位符的顺序传入参数
params = (
    alert_info["id"],
    alert_info["cleared"],
    alert_info["id"],
    alert_info["cleared"],
    alert_info["id"],
    alert_info["cleared"]
)

cursor.execute(write_sql, params)
conn.commit() # 必须提交事务，否则写入不会生效
cursor.close()
conn.close()

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