我正在將對(duì)象列表添加entries到數(shù)據(jù)庫(kù)中。有時(shí)可能會(huì)發(fā)生此對(duì)象之一已經(jīng)在數(shù)據(jù)庫(kù)中（我對(duì)此沒有任何控制權(quán)）。只有一個(gè)IntegrityError所有的事務(wù)都會(huì)失敗，即所有的對(duì)象都entries不會(huì)被插入到數(shù)據(jù)庫(kù)中。try:? ? session.add_all(entries)? ? session.commit()except:? ? logger.error(f"Error! Rolling back")? ? session.rollback()? ? raisefinally:? ? session.close()我想要的行為是：如果IntegrityError其中一個(gè)有 a entries，捕獲它并且不將該對(duì)象添加到數(shù)據(jù)庫(kù)中，否則正常繼續(xù)（不要失敗）我使用 MySQL 作為后端。
2 回答
慕尼黑5688855
TA貢獻(xiàn)1848條經(jīng)驗(yàn) 獲得超2個(gè)贊
我取決于你使用的后端。
PostgreSQL有一個(gè)很棒的INSERT() ON CONFLICT DO NOTHING子句，您可以將其與 SQLAlchemy 一起使用：
from?sqlalchemy.dialects.postgresql?import?insert session.execute(insert(MyTable) ????????????????.values(my_entries) ????????????????.on_conflict_do_nothing())
MySQL有類似的INSERT IGNORE條款，但 SQLAlchemy 對(duì)它的支持較少。
session.execute(MyTable.__table__
????????????????.insert()
????????????????.prefix_with('IGNORE')
????????????????.values(my_entries))唯一的事情是my_entries需要一個(gè)列到值映射的列表。這意味著[{ 'id': 1, 'name': 'Ringo' }, { 'id': 2, 'name': 'Paul' }, ...]等等。
楊__羊羊
TA貢獻(xiàn)1943條經(jīng)驗(yàn) 獲得超7個(gè)贊
我找到的解決方案是在添加之前查詢數(shù)據(jù)庫(kù)
try:
instance = session.query(InstancesTable).filter_by(id=entry.id).first()
if instance:
return
session.add(entry)
session.commit()
except:
logger.error(f"Error! Rolling back")
session.rollback()
raise
添加回答
舉報(bào)
0/150
提交
取消