pub/mongoengine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improved import cache

Browse Source
This commit is contained in:
Ross Lawley 2012-09-24 18:45:02 +00:00
parent 3090adac04
commit adb60ef1ac
1 changed files with 42 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
mongoengine/base.py
View File

@ -235,7 +235,8 @@ class BaseField(object):
pass pass
def _validate(self, value): def _validate(self, value):
from mongoengine import Document, EmbeddedDocument Document = _import_class('Document')
EmbeddedDocument = _import_class('EmbeddedDocument')
# check choices # check choices
if self.choices: if self.choices:
is_cls = isinstance(value, (Document, EmbeddedDocument)) is_cls = isinstance(value, (Document, EmbeddedDocument))
@ -283,7 +284,9 @@ class ComplexBaseField(BaseField):
if instance is None: if instance is None:
# Document class being used rather than a document object # Document class being used rather than a document object
return self return self
from fields import GenericReferenceField, ReferenceField
ReferenceField = _import_class('ReferenceField')
GenericReferenceField = _import_class('GenericReferenceField')
dereference = self.field is None or isinstance(self.field, dereference = self.field is None or isinstance(self.field,
(GenericReferenceField, ReferenceField)) (GenericReferenceField, ReferenceField))
if not self._dereference and instance._initialised and dereference: if not self._dereference and instance._initialised and dereference:
@ -310,6 +313,7 @@ class ComplexBaseField(BaseField):
) )
value._dereferenced = True value._dereferenced = True
instance._data[self.name] = value instance._data[self.name] = value
return value return value
def __set__(self, instance, value): def __set__(self, instance, value):
@ -321,7 +325,7 @@ class ComplexBaseField(BaseField):
def to_python(self, value): def to_python(self, value):
"""Convert a MongoDB-compatible type to a Python type. """Convert a MongoDB-compatible type to a Python type.
""" """
from mongoengine import Document Document = _import_class('Document')
if isinstance(value, basestring): if isinstance(value, basestring):
return value return value
@ -363,7 +367,7 @@ class ComplexBaseField(BaseField):
def to_mongo(self, value): def to_mongo(self, value):
"""Convert a Python type to a MongoDB-compatible type. """Convert a Python type to a MongoDB-compatible type.
""" """
from mongoengine import Document Document = _import_class("Document")
if isinstance(value, basestring): if isinstance(value, basestring):
return value return value
@ -399,7 +403,7 @@ class ComplexBaseField(BaseField):
meta.get('allow_inheritance', ALLOW_INHERITANCE) meta.get('allow_inheritance', ALLOW_INHERITANCE)
== False) == False)
if allow_inheritance and not self.field: if allow_inheritance and not self.field:
from fields import GenericReferenceField GenericReferenceField = _import_class("GenericReferenceField")
value_dict[k] = GenericReferenceField().to_mongo(v) value_dict[k] = GenericReferenceField().to_mongo(v)
else: else:
collection = v._get_collection_name() collection = v._get_collection_name()
@ -460,7 +464,7 @@ class ComplexBaseField(BaseField):
@property @property
def _dereference(self,): def _dereference(self,):
if not self.__dereference: if not self.__dereference:
from dereference import DeReference DeReference = _import_class("DeReference")
self.__dereference = DeReference() # Cached self.__dereference = DeReference() # Cached
return self.__dereference return self.__dereference
@ -943,7 +947,7 @@ class BaseDocument(object):
field = None field = None
if not hasattr(self, name) and not name.startswith('_'): if not hasattr(self, name) and not name.startswith('_'):
from fields import DynamicField DynamicField = _import_class("DynamicField")
field = DynamicField(db_field=name) field = DynamicField(db_field=name)
field.name = name field.name = name
self._dynamic_fields[name] = field self._dynamic_fields[name] = field
@ -1121,7 +1125,8 @@ class BaseDocument(object):
def _get_changed_fields(self, key='', inspected=None): def _get_changed_fields(self, key='', inspected=None):
"""Returns a list of all fields that have explicitly been changed. """Returns a list of all fields that have explicitly been changed.
""" """
from mongoengine import EmbeddedDocument, DynamicEmbeddedDocument EmbeddedDocument = _import_class("EmbeddedDocument")
DynamicEmbeddedDocument = _import_class("DynamicEmbeddedDocument")
_changed_fields = [] _changed_fields = []
_changed_fields += getattr(self, '_changed_fields', []) _changed_fields += getattr(self, '_changed_fields', [])
@ -1252,7 +1257,9 @@ class BaseDocument(object):
geo_indices = [] geo_indices = []
inspected.append(cls) inspected.append(cls)
from fields import EmbeddedDocumentField, GeoPointField EmbeddedDocumentField = _import_class("EmbeddedDocumentField")
GeoPointField = _import_class("GeoPointField")
for field in cls._fields.values(): for field in cls._fields.values():
if not isinstance(field, (EmbeddedDocumentField, GeoPointField)): if not isinstance(field, (EmbeddedDocumentField, GeoPointField)):
continue continue
@ -1486,14 +1493,30 @@ def _import_class(cls_name):
"""Cached mechanism for imports""" """Cached mechanism for imports"""
if cls_name in _class_registry: if cls_name in _class_registry:
return _class_registry.get(cls_name) return _class_registry.get(cls_name)
if cls_name == 'Document':
from mongoengine.document import Document as cls
elif cls_name == 'EmbeddedDocument':
from mongoengine.document import EmbeddedDocument as cls
elif cls_name == 'DictField':
from mongoengine.fields import DictField as cls
elif cls_name == 'OperationError':
from queryset import OperationError as cls
_class_registry[cls_name] = cls doc_classes = ['Document', 'DynamicEmbeddedDocument', 'EmbeddedDocument']
return cls field_classes = ['DictField', 'DynamicField', 'EmbeddedDocumentField',
'GenericReferenceField', 'GeoPointField',
'ReferenceField']
queryset_classes = ['OperationError']
deref_classes = ['DeReference']
if cls_name in doc_classes:
from mongoengine import document as module
import_classes = doc_classes
elif cls_name in field_classes:
from mongoengine import fields as module
import_classes = field_classes
elif cls_name in queryset_classes:
from mongoengine import queryset as module
import_classes = queryset_classes
elif cls_name in deref_classes:
from mongoengine import dereference as module
import_classes = deref_classes
else:
raise ValueError('No import set for: ' % cls_name)
for cls in import_classes:
_class_registry[cls] = getattr(module, cls)
return _class_registry.get(cls_name)