Ale*_*mas 6 python sql pypyodbc
我正在尝试为 pypyodbc SQL Server 创建一个“upsert”函数。我已经验证建立的查询将在 SSMS 中运行并获得所需的结果,但是当尝试使用 pypyodbc 执行和提交时,我收到以下错误:'HY007','[HY007] [Microsoft][ODBC SQL Server Driver]Associated声明未准备好”。
这是 upsert 函数:
def sql_upsert(sql_connection, table, key_field, key_value, **kwargs):
keys = ["{key}".format(key=k) for k in kwargs]
values = ["'{value}'".format(value=v) for v in kwargs.values()]
update_columns = ["{key} = '{value}'".format(key=k, value=v) for k, v in kwargs.items()]
sql = list()
#update
sql.append("UPDATE {table} SET ".format(table=table))
sql.append(", ".join(update_columns))
sql.append(" WHERE {} = '{}'".format(key_field, key_value))
sql.append(" IF @@ROWCOUNT=0 BEGIN ")
# insert
sql.append("INSERT INTO {table} (".format(table=table))
sql.append(", ".join(keys))
sql.append(") VALUES (")
sql.append(", ".join(values))
sql.append(")")
sql.append(" END")
query = "".join(sql)
print(query)
Run Code Online (Sandbox Code Playgroud)
该函数以基于另一个线程的格式构建查询字符串如何使用单个查询插入或更新?
以下是输出的示例:
更新测试集 name='john' WHERE id=3012
IF @@ROWCOUNT=0 开始
插入测试(名称)值('约翰')
结尾
您引用的错误消息是由作为 Windows 一部分提供的古老的“SQL Server”ODBC 驱动程序生成的。更新的驱动程序版本(例如“ODBC Driver 17 for SQL Server”)应该会生成有意义的错误消息。