python - Mongo 嵌入式文档查询

Question

我有 2 个动态文档:

class Tasks(db.DynamicDocument):
    task_id = db.UUIDField(primary_key=True,default=uuid.uuid4)
    name = db.StringField()
    flag = db.IntField()

class UserTasks(db.DynamicDocument):
    user_id = db.ReferenceField('User')
    tasks = db.ListField(db.ReferenceField('Tasks'),default=list)

我想过滤 UserTasks 文档，方法是检查给定 task_id 的 flag 值(来自任务文档)是 0 还是 1，给定 task_id 和 user_id。所以我通过以下方式查询:-

obj = UserTasks.objects.get(user_id=user_id,tasks=task_id)

这为我获取了一个 UserTask 对象。

现在我循环任务列表，首先我得到等效的任务，然后按以下方式检查其标志值。

task_list = obj.tasks
for t in task_list:
    if t['task_id'] == task_id:
        print t['flag']

有没有更好/直接的查询 UserTasks 文档以获取任务文档的标志值的方法。

PS:我可以直接从 Tasks 文档中获取标志值，但我还需要检查任务是否与用户相关联。于是我直接查询了USerTasks文档。

Answer 1

我们可以直接过滤带有 ReferenceField's 的文档吗？单个查询中的字段？

不，不可能直接过滤带有 ReferenceField 字段的文档，因为这样做需要连接，而 mongodb 不支持连接。

根据 database references: 上的 MongoDB 文档

MongoDB does not support joins. In MongoDB some data is denormalized, or stored with related data in documents to remove the need for joins.

来自另一个 page在官方网站上:

If we were using a relational database, we could perform a join on users and stores, and get all our objects in a single query. But MongoDB does not support joins and so, at times, requires bit of denormalization.

Relational purists may be feeling uneasy already, as if we were violating some universal law. But let’s bear in mind that MongoDB collections are not equivalent to relational tables; each serves a unique design objective. A normalized table provides an atomic, isolated chunk of data. A document, however, more closely represents an object as a whole.

所以在 1 个查询中，我们不能同时使用特定标志值和给定的 user_id 和 task_id 过滤 tasks UserTasks 模型。

那么如何进行过滤呢？

要根据所需条件执行过滤，我们需要执行 2 次查询。

在第一个查询中，我们将尝试使用给定的 task_id 和 flag 过滤 Tasks 模型。然后，在第二个查询中，我们将使用给定的 user_id 和从第一个查询中检索到的 task 过滤 UserTasks 模型。

示例:

假设我们有一个 user_id，task_id，我们需要检查相关任务是否有 flag 值为 0。

第一次查询

我们将首先使用给定的 task_id 和 flag 作为 0 检索 my_task。

my_task = Tasks.objects.get(task_id=task_id, flag=0) # 1st query

第二次查询

然后在第二个查询中，您需要使用给定的 user_id 和 my_task 对象过滤 UserTask 模型。

my_user_task = UserTasks.objects.get(user_id=user_id, tasks=my_task) # 2nd query

只有在获得具有给定 task_id 和 flag 值的 my_task 对象时，才应该执行第二次查询。此外，如果没有匹配的对象，您将需要添加错误处理。

如果我们将 EmbeddedDocument 用于 Tasks 模型会怎样？

假设我们已将 Tasks 文档定义为 EmbeddedDocument 并将 UserTasks 模型中的 tasks 字段定义为一个 EmbeddedDocumentField，然后为了进行所需的过滤，我们可以执行如下操作:

my_user_task = UserTasks.objects.get(user_id=user_id, tasks__task_id=task_id, tasks__flag=0)

从任务列表中获取特定的my_task

上述查询将返回一个 UserTask 文档，其中包含所有 tasks。然后我们需要执行某种迭代来获得所需的任务。

为此，我们可以使用 enumerate() 执行列表解析。那么所需的索引将是返回的 1 元素列表的第一个元素。

my_task_index = [i for i,v in enumerate(my_user_task.tasks) if v.flag==0][0]