如何在SQLAlchemy for PostgreSQL中設置事務隔離級別？

Question

我們正在使用SQLAlchemy聲明基礎，並且我有一個方法要隔離事務級別。爲了解釋，有兩個進程同時寫入數據庫，我必須讓他們在事務中執行邏輯。默認事務隔離級別是READ COMMITTED，但我需要能夠使用SERIALIZABLE隔離級別執行一段代碼。

這是如何使用SQLAlchemy完成的？現在，我基本上在我們的模型中有一個方法，它繼承自SQLAlchemy的聲明基礎，本質上需要事務性調用。

from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT 
from psycopg2.extensions import ISOLATION_LEVEL_READ_COMMITTED 
from psycopg2.extensions import ISOLATION_LEVEL_SERIALIZABLE 

class OurClass(SQLAlchemyBaseModel): 

    @classmethod 
    def set_isolation_level(cls, level=ISOLATION_LEVEL_SERIALIZABLE): 
     cls.get_engine().connect().connection.set_isolation_level(level) 

    @classmethod 
    def find_or_create(cls, **kwargs): 
     try: 
      return cls.query().filter_by(**kwargs).one() 
     except NoResultFound: 
      x = cls(**kwargs) 
      x.save() 
      return x 

我這樣做此使用事務隔離級別調用，但它不是做我的期望。隔離級別仍然是從我在postgres日誌中看到的READ COMMITTED。有人可以幫助確定我在做什麼錯嗎？

我使用的SQLAlchemy 0.5.5

class Foo(OurClass): 

    def insert_this(self, kwarg1=value1): 
     # I am trying to set the isolation level to SERIALIZABLE 
     try: 
      self.set_isolation_level() 
      with Session.begin(): 
       self.find_or_create(kwarg1=value1) 
     except Exception: # if any exception is thrown... 
      print "I caught an expection." 
      print sys.exc_info() 
     finally: 
      # Make the isolation level back to READ COMMITTED 
      self.set_isolation_level(ISOLATION_LEVEL_READ_COMMITTED) 

Answer 1

從邁克爾·拜爾的SQLAlchemy的維護者：

請使用 「ISOLATION_LEVEL」 參數create_engine() 和使用latest tip of SQLAlchemy 直到0.6.4被釋放，因爲有一個 psycopg2 - 關於隔離級別最近修復的特定錯誤 。

你有下面的方法不 影響是 後來用於查詢相同的連接 - 你會 改用PoolListener，設置所有連接 高達 作爲set_isolation_level創建它們。

Answer 2

隔離級別被設置在一個事務中，例如

try: 
    Session.begin() 
    Session.execute('set transaction isolation level serializable') 
    self.find_or_create(kwarg1=value1) 
except: 
    ... 

從PostgreSQL doc：

如果SET交易沒有啓動之前事務執行或BEGIN，它會出現沒有任何效果，因爲該交易將立即結束。