SQLAlchemy - 批量插入忽略：“重复条目”

Question

我有一个名为的表user_data，列id和user_id作为唯一键。我想将一些历史数据导入到这个表中。我使用bulk_insert_mappings方法批量插入数据。但是有如下错误：

IntegrityError: (pymysql.err.IntegrityError) (1062, u"Duplicate entry '1-1234' for key 'idx_on_id_and_user_id'")

批量插入时如何忽略此错误并丢弃重复数据？

Answer 1

您应该处理每个错误。但如果您确实想忽略所有错误，则无法真正执行批量插入。有时您导入的实际数据会出现完整性错误。你必须一一插入并忽略。我只会在一次性脚本中使用它。

for item in dict_list:
    try:
        session.merge(orm(**item))
        session.commit()
    except Exception as e:
        session.rollback()