#
##############################################################################
-import msgpack
class Cursor(object):
def __init__(self, collection, spec=None, fields=None, **kwargs):
self.Constraint = collection.database.connection.Constraint
self.Literal = collection.database.connection.Literal
+ self.serializer = collection.database.connection.serializer
+
self.collection = collection
self.spec = spec
if self.collection.exists():
field_type = 'number'
else:
field_type = 'value'
- field_value = msgpack.dumps(field_value)
+ field_value = self.serializer.dumps(field_value)
fields = [self.Field(table_field, 'id')]
tables = [table_field]
else:
document = {}
if '_id' in self.fields:
- document['_id'] = msgpack.loads(res[0])
+ document['_id'] = self.serializer.loads(res[0])
fields_without_id = filter(lambda x: x != '_id', self.fields)
for i in xrange(len(fields_without_id)):
if not res[i + 1] is None:
- document[fields_without_id[i]] = msgpack.loads(res[i + 1])
+ document[fields_without_id[i]] = self.serializer.loads(res[i + 1])
return document
else:
return None