使用Python通过SQL Server表值参数批量导入数据遇错求助

问题根源 #

你直接把二维列表values作为参数传入execute方法，驱动会把列表里的每一行都当成独立参数，而非将整个数据集作为**单个表值参数（TVP）**传递，这就导致了参数数量不匹配的错误。

针对pyodbc的修正方案 #

pyodbc需要用SQLServerTableValuedParameter类封装整个数据集，明确告诉驱动这是一个TVP：

# 读取电子表格代码保持不变...

# 建立pyodbc连接
conn = db.odbc()
# 指定SQL中定义的自定义表类型名称
tvp_type_name = "dbo.apr_house_part_row"
# 用SQLServerTableValuedParameter包装数据
tvp = pyodbc.SQLServerTableValuedParameter(tvp_type_name, values)
# 执行存储过程（注意存储过程名称要和SQL中创建的一致，你代码里写的usp_apr_house_part是笔误）
conn.execute("exec usp_load_apr_house_part ?", tvp)
# 提交事务
conn.commit()

关键注意事项：

• 确保values中每一行的数据类型与SQL自定义表类型的列严格匹配（比如整数列必须是int类型，不能是字符串）
• 存储过程名称要和你SQL里创建的usp_load_apr_house_part完全一致，你之前的pyodbc代码里写的usp_apr_house_part是错误的，这也可能引发问题

针对pytds的修正方案 #

pytds需要用TableValuedParam类，并且必须显式声明列的名称、数据类型：

# 读取电子表格代码保持不变...

# 建立pytds连接
tds = db.tds()
cur = tds.cursor()
# 定义TVP的列元信息，与SQL自定义表类型一一对应
tvp = pytds.TableValuedParam(
    "dbo.apr_house_part_row",
    [
        ("abc_id", pytds.INT),
        ("def_id", pytds.INT),
        ("ghi_nm", pytds.NVARCHAR, 50),
        ("jkl_nm", pytds.NVARCHAR, 50)
    ],
    values
)
# 执行存储过程，将TVP包装成元组传入
cur.execute("exec usp_load_apr_house_part @TVP = ?", (tvp,))
# 提交事务
tds.commit()

关键注意事项：

• 字符串类型的列必须指定长度，要和SQL自定义表类型中的长度一致
• 传递参数时必须把TVP放在元组里，避免驱动解析参数时出错

额外检查项 #

1. 数据类型校验：检查Excel读取的整数列是否被转换成了字符串，若有需要手动转为int类型，否则TVP会因类型不匹配报错
2. 连接配置：pyodbc连接字符串建议添加TDS_Version=7.3或更高版本，确保支持TVP特性
3. 权限确认：执行存储过程的账号需要有自定义表类型的访问权限

内容的提问来源于stack exchange，提问作者Daniel 'Dang' Griffith