如何在 Mongo（流星）中执行查找以查找数组匹配的文档？ [复制]

Question

我正在尝试在 Meteor 中返回一个光标（使用 MongoDB）。

我正在寻找参与者字段与我传入的数组完全匹配的文档（MessageThreads 集合）。

下面是一个示例 MessageThread 文档

{
  "_id": "YYSELCguhLurTeyNY",
  "creator": "RLmnidY6GypdqDXZu",
  "participants": [
    "SNhRq4vQpwFBjnTSH",
    "RLmnidY6GypdqDXZu"
  ],
}

当我执行 addMessage 方法时，我首先尝试检查是否存在participants 与我传入的数组完全匹配的线程。该数组将根据新消息表单tofield 制定。

因此，只有当我的所有 participants 数组都在文档 participants 字段内但没有其他字段时，才应返回文档。例如：如果文档中存在不属于新消息to 字段的第三人，则不应返回该文档。

目前这是我的查询，显然太简单了。

existingThread = MessageThreads.findOne(participants: participants)

有什么建议吗？谢谢

编辑：我在使用提供的重复答案时遇到问题（但还不允许评论其他线程）

由于某种原因，如果数组不同，existingThread 仍在查找文档，但 size 为真。

编辑 2：

下面是我的整个方法的代码，它可以帮助破译我哪里出错了。在咖啡脚本中（请原谅标签，无法让它在 SO 中工作，抱歉）。

Meteor.methods

newMessage: (recipientIds, messageContent) ->

if !Meteor.userId()
  return false

userId = Meteor.userId()

check recipientIds, [String]
check messageContent, String

participants = recipientIds
participants.push(userId)
participantCount = _.size(participants)

existingThread = MessageThreads.findOne participants:
  $size: participantCount
  $in: participants

if existingThread?
  console.log "Thread exists: #{existingThread._id}"

  MessageThreads.update existingThread,
    $addToSet: messages: {sender: userId, content: messageContent}
    $set: lastUpdated: new Date()


else
  newThreadId = MessageThreads.insert 
    creator: userId
    participants: participants
    messages: [
      {
        sender: userId
        content: messageContent
        createdAt: new Date()
      }
    ]
    lastUpdated: new Date()

  return newThreadId

Answer 1

您需要在查询中使用 $all 运算符来选择字段值是包含所有指定元素的数组的文档。当你想返回一个游标时，find() 方法更合适，因为它返回一个游标。它不会立即访问数据库或返回文档。要访问游标中的文档，游标提供fetch()返回所有匹配的文档，map()和forEach()遍历所有匹配的文档，observe()和observeChanges()在匹配文档集更改时注册回调.

对于您的情况，示例实现如下所示：

var existingThreadsCursor = MessageThreads.find({ "participants": { "$all": participants} });
var count = 0;
existingThreadsCursor.forEach(function (thread){
    console.log("Thread with participants: " + JSON.stringify(thread.participants));
    count++;
});