如何使用會話，而不必通過它[SqlAlchemy]

Question

我想檢查數據庫中的不同值，並創建一個新的值，所以我需要查詢，我不知道如果我必須在我的創建會話SQLAlchemy類，或者我該怎麼做呢？使用會議像全球？，我沒有在文檔中找到。

事端這樣的：

class MyClass(Base): 

    __tablename__ = 'my_class' 
    __table_args__ = (UniqueConstraint('key', 'key2'), 
        {} 
        ) 
    id = Column(Integer, Sequence('my_class_id'), primary_key=True) 
    key = Column(String(30), nullable= False) #unique together key2 
    key2 = Column(String(30), nullable = False) 
    value = Column(Integer, nullable=False) 

    def __init__(self, key, key2): 
     #check if exist key and key2 
     values = session.query(MyClass.value).filter(MyClass.key == self.key).\ 
      filter(MyClass.key2 == self) 

     if values: 
      raise IntegrityError 

     #get biggest value 
     value = session.query(MyClass.value).filter(MyClass.key = self.key).order_by(asc(MyClass.value)) #I'm not shure if i need 'asc' 
     #no value new key and key2 

     if not value: 
      self.key = key 
      self.key2 = key2 
      self.value = '000' 
      return 

     #i used a single table beacuse is easier to understand 
     #in this example 
     self.key = key 
     self.key2 = key 
     self.value = increment(value.first()) 

我使用SQLAlchemy的6.2和聲明

感謝

Answer 1

你將不得不做你自己的會話管理 - 例如定義一個模塊全局會話對象。

例如，主塔應用程序定義他們的會話是這樣的：

from sqlalchemy.orm import scoped_session, sessionmaker 
Session = scoped_session(sessionmaker()) 

再後來將其綁定到一個發動機

Session.configure(bind=engine) 

使用scoped_session將意味着你的代碼是線程安全的（每個線程將使用自己的會話）。

Answer 2

我發現here，我們可以做Session.object_session（個體經營）：

def new_value(self): 
    #not really DRY 
    #the object has to be binded with some session first. 
    session = Session.object_session(self) # << this is the important stuff 

    #check if exist key and key2 
    values = session.query(MyClass.value).filter(MyClass.key == self.key).\ 
     filter(MyClass.key2 == self) 

    if values: 
     return #None 

    #get biggest value 
    value = session.query(MyClass.value).\ 
       filter(MyClass.key = self.key).\ 
       order_by(desc(MyClass.value)) 

    return increment(value.first())