SQLAlchemy和显式锁定

Question

我有多个进程，可能会在数据库中插入重复的行。这些插入不会很频繁地发生（每小时几次），因此它对性能并不重要。

在进行插入之前，我已经尝试过存在检查，如下所示：

#Assume we're inserting a camera object, that's a valid SQLAlchemy ORM object that inherits from declarative_base...
try:
  stmt = exists().where(Camera.id == camera_id)
  exists_result = session.query(Camera).with_lockmode("update").filter(stmt).first()

  if exists_result is None:
    session.add(Camera(...)) #Lots of parameters, just assume it works
    session.commit()
except IntegrityError as e:
  session.rollback()

我exist()遇到的问题是检查不会锁定表，因此，多个进程可能会尝试同时插入同一对象。在这种情况下，一个过程通过插入成功，而其他过程则由于IntegrityError异常而失败。虽然这样做有效，但对我来说感觉并不“干净”。

我真的很想在进行exists()检查之前锁定Camera表。

Answer 1

也许这可能是您感兴趣的：

https://groups.google.com/forum/?fromgroups=#!topic/sqlalchemy/8WLhbsp2nls

您可以通过直接执行SQL来锁定表。我不确定在Elixir中是什么样，但是在普通SA中会是这样：

 conn = engine.connect（）
 conn.execute（“锁定表指针写入”）
 ＃用conn做东西
 conn.execute（“解锁表”）