Python调用SQL修改SQL Server表列名未生效问题求助

问题根源 #

你的代码中，列存在时执行sp_RENAME操作成功，但日志里没有COMMIT记录——这是因为SQLAlchemy的连接默认处于事务模式，所有DDL/DML操作都需要显式提交才能生效。当执行出错触发ProgrammingError时，SQLAlchemy会自动回滚事务，但成功的操作不会自动提交，导致修改无法落地。

解决方案 #

方案1：显式提交事务 #

在所有修改操作完成后统一提交事务，减少提交次数的同时确保所有成功的修改生效：

# 返回列表的列表，例如 ((OldColName1, NewColName1), (OldColName2,NewColName2))
oldNewColList = conn.execute("SELECT OldColumnName, NewColumnName FROM ColumnNamesRef").fetchall()
try:
    for colName in oldNewColList:
        try:
            conn.execute("EXEC sp_RENAME '["+str(table[0])+"_New].["+str(colName[0])+"]', '"+str(colName[1])+"', 'COLUMN'")
        except ProgrammingError as e:
            if '42000' in str(e):
                pass
            else:
                raise Exception("Error not accounted for: "+str(e))
    # 所有操作完成后统一提交
    conn.commit()
except Exception as e:
    # 遇到未处理的错误时回滚
    conn.rollback()
    raise

方案2：开启自动提交模式 #

如果你的场景不需要事务保障，可以开启连接的自动提交模式，让每个操作执行后自动生效：

# 在执行操作前开启自动提交
conn.execution_options(autocommit=True)

oldNewColList = conn.execute("SELECT OldColumnName, NewColumnName FROM ColumnNamesRef").fetchall()
for colName in oldNewColList:
    try:
        conn.execute("EXEC sp_RENAME '["+str(table[0])+"_New].["+str(colName[0])+"]', '"+str(colName[1])+"', 'COLUMN'")
    except ProgrammingError as e:
        if '42000' in str(e):
            pass
        else:
            raise Exception("Error not accounted for: "+str(e))

优化建议：先检查列是否存在再修改 #

避免不必要的错误触发和事务回滚，可以先查询目标表是否存在该列，再执行修改操作：

oldNewColList = conn.execute("SELECT OldColumnName, NewColumnName FROM ColumnNamesRef").fetchall()
table_name = f"{table[0]}_New"

for old_col, new_col in oldNewColList:
    # 检查列是否存在
    check_sql = f"""
        SELECT 1 
        FROM INFORMATION_SCHEMA.COLUMNS 
        WHERE TABLE_NAME = '{table_name}' AND COLUMN_NAME = '{old_col}'
    """
    result = conn.execute(check_sql).fetchone()
    if result:
        # 列存在才执行修改
        rename_sql = f"EXEC sp_RENAME '[{table_name}].[{old_col}]', '{new_col}', 'COLUMN'"
        conn.execute(rename_sql)

# 统一提交所有修改
conn.commit()

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