Python执行SQL Server更新语句无报错但未生效求助

1. Update语句存在语法错误 #

你的update_sql里set行末尾多了一个冗余逗号，这会导致SQL语法错误：

set B_table.id=b.issuerid,  -- 此处逗号多余，会阻断语句执行

即便你说执行无报错，这个语法问题也会让SQL Server无法正确解析并执行更新逻辑。去掉该逗号即可。

同时，Update语句的写法可以优化：使用表别名简化语句，并且根据你的需求（仅更新匹配临时表的行），应该用INNER JOIN替代LEFT JOIN，避免把不匹配行的id误设为NULL。修正后的update_sql如下：

update a
set id = b.issuerid
from B_table as a
inner join #id as b 
on a.security_isin = b.security_isin 

2. 临时表可能无数据 #

可以在执行prepare_sql后，检查临时表的行数，确认是否有数据被写入：

cursor.execute(prepare_sql)
# 检查临时表数据量
cursor.execute("SELECT COUNT(*) FROM #id")
row_count = cursor.fetchone()[0]
print(f"临时表#id中有{row_count}条数据")

如果行数为0，说明prepare_sql的筛选逻辑没有匹配到数据，需要检查A_table和B_table的关联条件、日期筛选条件是否正确。

3. 合并SQL批处理避免作用域问题 #

虽然你用的是同一个连接，但可以将创建临时表、更新、删表的语句合并为一个批处理执行，避免跨游标执行可能带来的临时表作用域问题：

combined_sql = prepare_sql + "\n" + update_sql + "\nDROP TABLE #id"
cursor.execute(combined_sql)

4. 完整修正后的代码 #

def id_update():
    connection_str = ("Driver={SQL Server Native Client 11.0};"
                      "Server=a;"
                      "Database=b;"
                      "Trusted_Connection=yes;")

    connection = pyodbc.connect(connection_str)
    cursor = connection.cursor()
    
    prepare_sql="""  
    Select * into #id
    from B_table as b 
    inner join 
           (Select distinct isin, issuerid 
            from  A_table
            where issuerid is not null and updatedate>='2022-06-30') as a 
    on a.isin=b.security_isin and b.[as_of_date]='2022-06-30'  
    where b.id is null
    """
    
    update_sql= """  
    update a
    set id = b.issuerid
    from B_table as a
    inner join #id as b 
    on a.security_isin = b.security_isin 
    """
    
    # 执行准备语句并检查临时表数据
    cursor.execute(prepare_sql)
    cursor.execute("SELECT COUNT(*) FROM #id")
    print(f"待更新数据行数: {cursor.fetchone()[0]}")
    
    # 执行更新并打印实际更新行数
    cursor.execute(update_sql)
    print(f"实际更新行数: {cursor.rowcount}")
    
    # 删除临时表
    cursor.execute("drop table #id")
    
    # 提交更改并关闭连接
    connection.commit()
    connection.close()

添加了行数打印，可以直观看到临时表数据量和实际更新行数，方便快速排查问题。

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