from functools import wraps
def find_connection_id_deco(func):
"""
"""
@wraps(func)
def wrap1(*args, **kwargs):
"""
"""
gls = func.__globals__
_DBSession = gls.get("DBSession")
if _DBSession:
res1 = _DBSession.connection().execute("SELECT connection_id()")
if res1:
conn_id = res1.fetchone()[0]
print "===%s===%s()===conn_id_1===%s" %(func.func_code.co_filename, func.__name__, conn_id)
# ###OR
# res2 = DBSession.execute("SELECT connection_id();")
# if res2:
# conn_id = res2.fetchone()[0]
# print "===%s()===conn_id_2===%s" %(func.__name__, conn_id)
return func(*args, **kwargs)
return wrap1
OutPut
=====
===/bla/bla/file1.py===func1()===conn_id_1===1481
===/bla/bla/file2.py===func2()===conn_id_1===1481
===/bla/bla/file3.py===func3()===conn_id_1===1483
===/bla/bla/file4.py===func4()===conn_id_1===1485
===/bla/bla/file5.py===func5()===conn_id_1===1485
#####################
def find_connection_id(msg=""):
"""
"""
_DBSession = globals().get("DBSession")
if _DBSession:
res1 = _DBSession.connection().execute("SELECT connection_id()")
if res1:
conn_id = res1.fetchone()[0]
print "===%s===conn_id_1===%s" %(msg, conn_id)
Note:
====
1) transaction.commit() will close all existing DBSessions and connection associated with it.
*transaction.commit()
2) DBSession.query() followed by a transaction.commit() will start a new DBSession and connection.
*transaction.commit()
*DBSession.query()
http://gallery.technet.microsoft.com/scriptcenter/Windows-System-Inventory-616e2749