SQLAlchemy中scoped_session

from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session
 
engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/s6", max_overflow=0, pool_size=5)
Session = sessionmaker(bind=engine)
 
# session = Session()
session = scoped_session(Session)

obj1 = Users(name="alex1")
session.add(obj1)

# 提交事務
session.commit()
# 關閉session
session.close()

在上面代碼中，從連接池中拿連接的時候，Session直接實例化，或者scoped_session進行實例化也可以
調用時，方法名都是一樣的，比如session.add(),我們會猜他兩是繼承關系
但實際是class scoped_session(object)，並沒有繼承Session，而且在scoped_session里也沒有找到add方法和commit方法... 那它怎么實現的？

 

 在scoped_session類下面，有個for循環，其中public_methods，在這里面有我們想看到的add，commit方法，上面把每個方法都設置到scoped_session類里，還要看下instrument(meth)到底是個啥玩意？

public_methods = (
    '__contains__', '__iter__', 'add', 'add_all', 'begin', 'begin_nested',
    'close', 'commit', 'connection', 'delete', 'execute', 'expire',
    'expire_all', 'expunge', 'expunge_all', 'flush', 'get_bind',
    'is_modified', 'bulk_save_objects', 'bulk_insert_mappings',
    'bulk_update_mappings',
    'merge', 'query', 'refresh', 'rollback',
    'scalar')

在這個函數最終返回了一個do函數，並把name，也就是函數名傳了進入實現閉包

def instrument(name):
    def do(self, *args, **kwargs):
        return getattr(self.registry(), name)(*args, **kwargs)
    return do

所以當執行session.add時，它會去執行do函數，里面封裝的name就是add

do函數中self.registry是個啥玩意呢？其中self指的是scoped_session對象，所以我們可以去看scoped_session進行實例化是都干了些啥

#session_factory就是傳入的Session = sessionmaker(bind=engine)
self.session_factory = session_factory
 
if scopefunc:
    self.registry = ScopedRegistry(session_factory, scopefunc)
else:#scopefunc此時沒值，所以走這里
    self.registry = ThreadLocalRegistry(session_factory)

我們會看到我們需要的self.registry就在上面代碼中，那現在主要ThreadLocalRegistry實例化后返回個啥？

def __init__(self, createfunc):
    self.createfunc = createfunc
    self.registry = threading.local()

createfunc就是傳入的session_factory，也就是Session，所以scoped_session對象的registry，是一個ThreadLocalRegistry對象，封裝了Session和local對象

所以self.registry()會執行ThreadLocalRegistry里的__call__方法

def __call__(self):
    try:
        return self.registry.value  #剛開始value沒值，會報錯
    except AttributeError:
        val = self.registry.value = self.createfunc()  #走這里Session(),也就是數據庫連接操作句柄，並把句柄放入local中
        return val

self.registry()得到的就是數據庫操作句柄，所以do函數里最終還是獲取到Session里的方法，並執行

當然第一次add操作，會實例化，第二次就直接去local中取，就不走異常分支了

所以這種方式在線程上是更安全的