Could someone please explain, Howto sqlalchemy creating new Session and connection inside the thread. Please check the attached programme and output.
I went through the doc http://docs.sqlalchemy.org/en/latest/orm/session.html#thread-local-scope and find that sqlalchemy using "threading.local()" to do this magic, but I could not seen any thing in "threading.local()" (see output of the programme) *####### Test Code and Output #######* from sqlalchemy import * from sqlalchemy.orm import * from sqlalchemy.ext.declarative import declarative_base Base = declarative_base() e = create_engine("mysql://root: xxxxx@localhost/xxxxx") Session = scoped_session(sessionmaker(e)) import threading from functools import wraps def find_connection_id_deco(func): """ """ @wraps(func) def wrap1(*args, **kwargs): """ """ gls = func.__globals__ _DBSession = gls.get("Session") if _DBSession: res1 = _DBSession.connection().execute("SELECT connection_id()") if res1: conn_id = res1.fetchone()[0] print "@@@@%s===%s()===conn_id_1===%s===%s===%s===%s===" \ %(func.func_code.co_filename, func.__name__, conn_id, vars(threading.local()),\ threading.currentThread().getName(), threading.currentThread().ident) return func(*args, **kwargs) return wrap1 @find_connection_id_deco def test1(): """ """ print "test1" @find_connection_id_deco def test2(): """ """ print "test2" from threading import Thread test1() thread = Thread(target=test2) thread.start() *OUTPUT #######* @@@@cvt_test_script.py===test1()===conn_id_1===661==={}===MainThread===139917239523072=== test1 @@@@cvt_test_script.py===test2()===conn_id_1===662==={}===Thread-1===139917193123584=== test2 -- You received this message because you are subscribed to the Google Groups "sqlalchemy" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/sqlalchemy. For more options, visit https://groups.google.com/groups/opt_out.
