1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
"""This plugin installs thread-local behavior at the ``Engine`` and ``Session`` level.
The default ``Engine`` strategy will be *threadlocal*, producing
``TLocalEngine`` instances for create_engine by default.
With this engine, ``connect()`` method will return the same connection
on the same thread, if it is already checked out from the pool. This
greatly helps functions that call multiple statements to be able to
easily use just one connection without explicit ``close`` statements
on result handles.
On the ``Session`` side, module-level methods will be installed within
the objectstore module, such as ``flush()``, ``delete()``, etc. which
call this method on the thread-local session.
Note: this mod creates a global, thread-local session context named
``sqlalchemy.objectstore``. All mappers created while this mod is
installed will reference this global context when creating new mapped
object instances.
"""
from sqlalchemy import util, engine, mapper
from sqlalchemy.ext.sessioncontext import SessionContext
import sqlalchemy.ext.assignmapper as assignmapper
from sqlalchemy.orm.mapper import global_extensions
from sqlalchemy.orm.session import Session
import sqlalchemy
import sys, types
__all__ = ['Objectstore', 'assign_mapper']
class Objectstore(object):
def __init__(self, *args, **kwargs):
self.context = SessionContext(*args, **kwargs)
def __getattr__(self, name):
return getattr(self.context.current, name)
session = property(lambda s:s.context.current)
def assign_mapper(class_, *args, **kwargs):
assignmapper.assign_mapper(objectstore.context, class_, *args, **kwargs)
objectstore = Objectstore(Session)
def install_plugin():
sqlalchemy.objectstore = objectstore
global_extensions.append(objectstore.context.mapper_extension)
engine.default_strategy = 'threadlocal'
sqlalchemy.assign_mapper = assign_mapper
def uninstall_plugin():
engine.default_strategy = 'plain'
global_extensions.remove(objectstore.context.mapper_extension)
install_plugin()
|
