如何防止通过pyodbc将多条记录插入sql server？

Question

如何防止插入重复数据和处理程序创建表错误。这是我的代码：

insert_query = '''INSERT INTO dbo.Tp_tabkeu(report_number,condition,power_error,status,Specification_dBM,CW_frequency) VALUES (?,?,?,?,?,?) 
    WHERE report_number!=values(a), condition!=values(b), power_error!=values(c), status!=values(d), Specification_dBM!=values(e), CW_frequency!=values(f);'''

    for index, row in df.iterrows():
        values = (row['report_num'], row['condition'], row[0], row[1], row[2], row[3])

Answer 1

INSERT INTO ... VALUES ... WHERE ... 不是有效的语法。但是，您可以使用INSERT INTO ... SELECT ... WHERE ...。

您已经确认您使用的是 SQL Server，并且df.iterrows() 表明您使用的是 pandas，因此您确实应该也使用SQLAlchemy。 （pandas 在使用 SQLite 以外的数据库时依赖于 SQLAlchemy。）

此示例对名为 [team] 的表执行条件 INSERT ...

prov  city     team_name  
----  -------  -----------
ON    Toronto  Maple Leafs

... 以 (prov, city) 作为主键。

import sqlalchemy as sa

# ...

engine = sa.create_engine(connection_url)

# ...

sql = sa.text("""\
INSERT INTO team (prov, city, team_name)
SELECT :prov AS prov, :city AS city, :team_name AS team_name
WHERE NOT EXISTS (
    SELECT * FROM team WHERE prov = :prov AND city = :city)
""")
params = {'prov': 'AB', 'city': 'Calgary', 'team_name': 'Flames'}
with engine.begin() as conn:
    conn.execute(sql, params)