mapper = sa.orm.class_mapper(type(obj))
name = _safe_cls_name(type(obj))
msg = ("Class %r is mapped, but this instance lacks "
- "instrumentation. Possible causes: instance created "
- "before sqlalchemy.orm.mapper(%s) was called, or "
- "instance was pickled/depickled without instrumentation"
- "information." % (name, name))
+ "instrumentation. This occurs when the instance is created "
+ "before sqlalchemy.orm.mapper(%s) was called." % (name, name))
except UnmappedClassError:
msg = _default_unmapped(type(obj))
if isinstance(obj, type):
from sqlalchemy.util import EMPTY_SET
import weakref
from sqlalchemy import util
-from sqlalchemy.orm.attributes import PASSIVE_NO_RESULT, PASSIVE_OFF, NEVER_SET, NO_VALUE, manager_of_class, ATTR_WAS_SET
-from sqlalchemy.orm import attributes
-from sqlalchemy.orm import interfaces
+from sqlalchemy.orm.attributes import PASSIVE_NO_RESULT, PASSIVE_OFF, \
+ NEVER_SET, NO_VALUE, manager_of_class, \
+ ATTR_WAS_SET
+from sqlalchemy.orm import attributes, exc as orm_exc, interfaces
class InstanceState(object):
"""tracks state information at the instance level."""
def __setstate__(self, state):
self.obj = weakref.ref(state['instance'], self._cleanup)
self.class_ = state['instance'].__class__
- self.manager = manager_of_class(self.class_)
-
+ self.manager = manager = manager_of_class(self.class_)
+ if manager is None:
+ raise orm_exc.UnmappedInstanceError(
+ state['instance'],
+ "Cannot deserialize object of type %r - no mapper() has"
+ " been configured for this class within the current Python process!" %
+ self.class_)
+
self.committed_state = state.get('committed_state', {})
self.pending = state.get('pending', {})
self.parents = state.get('parents', {})
import pickle
import sqlalchemy as sa
from sqlalchemy.test import testing
-from sqlalchemy import Integer, String, ForeignKey
+from sqlalchemy.test.testing import assert_raises_message
+from sqlalchemy import Integer, String, ForeignKey, exc
from sqlalchemy.test.schema import Table, Column
-from sqlalchemy.orm import mapper, relation, create_session, sessionmaker, attributes, interfaces
+from sqlalchemy.orm import mapper, relation, create_session, \
+ sessionmaker, attributes, interfaces,\
+ clear_mappers, exc as orm_exc
from test.orm import _base, _fixtures
eq_(u1, sess.query(User).get(u2.id))
+ @testing.resolve_artifact_names
+ def test_no_mappers(self):
+
+ umapper = mapper(User, users)
+ u1 = User(name='ed')
+ u1_pickled = pickle.dumps(u1, -1)
+
+ clear_mappers()
+
+ assert_raises_message(
+ orm_exc.UnmappedInstanceError,
+ "Cannot deserialize object of type <class 'test.orm._fixtures.User'> - no mapper()",
+ pickle.loads, u1_pickled)
+
@testing.resolve_artifact_names
def test_serialize_path(self):
umapper = mapper(User, users, properties={