diff options
Diffstat (limited to 'lib/sqlalchemy')
| -rw-r--r-- | lib/sqlalchemy/databases/sqlite.py | 11 | ||||
| -rw-r--r-- | lib/sqlalchemy/ext/activemapper.py | 1 | ||||
| -rw-r--r-- | lib/sqlalchemy/mods/threadlocal.py | 3 | ||||
| -rw-r--r-- | lib/sqlalchemy/orm/mapper.py | 3 |
4 files changed, 17 insertions, 1 deletions
diff --git a/lib/sqlalchemy/databases/sqlite.py b/lib/sqlalchemy/databases/sqlite.py index d96c0eda1..da43ad1ea 100644 --- a/lib/sqlalchemy/databases/sqlite.py +++ b/lib/sqlalchemy/databases/sqlite.py @@ -126,6 +126,9 @@ class SQLiteExecutionContext(default.DefaultExecutionContext): self._last_inserted_ids = [proxy().lastrowid] class SQLiteDialect(ansisql.ANSIDialect): + def __init__(self, **kwargs): + self.supports_cast = (sqlite.sqlite_version >= "3.2.3") + ansisql.ANSIDialect.__init__(self, **kwargs) def compiler(self, statement, bindparams, **kwargs): return SQLiteCompiler(self, statement, bindparams, **kwargs) def schemagenerator(self, *args, **kwargs): @@ -222,6 +225,14 @@ class SQLiteDialect(ansisql.ANSIDialect): table.columns[col]._set_primary_key() class SQLiteCompiler(ansisql.ANSICompiler): + def visit_cast(self, cast): + if self.dialect.supports_cast: + super(SQLiteCompiler, self).visit_cast(cast) + else: + if len(self.select_stack): + # not sure if we want to set the typemap here... + self.typemap.setdefault("CAST", cast.type) + self.strings[cast] = self.strings[cast.clause] def limit_clause(self, select): text = "" if select.limit is not None: diff --git a/lib/sqlalchemy/ext/activemapper.py b/lib/sqlalchemy/ext/activemapper.py index d21332e3a..957496e8e 100644 --- a/lib/sqlalchemy/ext/activemapper.py +++ b/lib/sqlalchemy/ext/activemapper.py @@ -25,6 +25,7 @@ except AttributeError: self.context = SessionContext(*args, **kwargs) def __getattr__(self, name): return getattr(self.context.current, name) + session = property(lambda s:s.context.current) objectstore = Objectstore(create_session) diff --git a/lib/sqlalchemy/mods/threadlocal.py b/lib/sqlalchemy/mods/threadlocal.py index 760a37e81..87d7f271c 100644 --- a/lib/sqlalchemy/mods/threadlocal.py +++ b/lib/sqlalchemy/mods/threadlocal.py @@ -27,7 +27,8 @@ class Objectstore(object): 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) diff --git a/lib/sqlalchemy/orm/mapper.py b/lib/sqlalchemy/orm/mapper.py index 92d10ad10..beccb16af 100644 --- a/lib/sqlalchemy/orm/mapper.py +++ b/lib/sqlalchemy/orm/mapper.py @@ -201,6 +201,7 @@ class Mapper(object): self.extension = None previous = None for ext in extlist: + ext.unchain() if self.extension is None: self.extension = ext if previous is not None: @@ -1164,6 +1165,8 @@ class MapperExtension(object): def chain(self, ext): self.next = ext return self + def unchain(self): + self.next = None def get_session(self): """called to retrieve a contextual Session instance with which to register a new object. Note: this is not called if a session is |