16

我有多个进程可能会在数据库中插入重复的行。这些插入不会经常发生（每小时几次），因此它不是性能关键。

我在插入之前尝试了存在检查，如下所示：

#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()检查之前锁定相机表。

4

1 回答 1

8

也许您可能对此感兴趣：

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

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

conn = engine.connect()
 conn.execute("LOCK TABLES 指针写入")
 #用 conn 做事
 conn.execute("解锁表")

于 2013-01-25T13:08:22.317 回答