使用不同的返回唯一的mongodb文档不起作用

Question

每个消息文档都有一个 messageTrackingId。我想返回所有消息，但排除具有相同 messageTrackingId 的文档。例如，如果我的表中有 4 个文档，其中 3 个具有相同的 messageTrackingId 值，那么 Messages.find() 应该只返回 2 个文档。

我正在尝试使用 distinct 来仅返回唯一文档，这样我就不会得到具有相同 messageTrackingId 的重复文档。目前邮递员没有退回任何文件。

如果我改变了 Messages.find({query}).distinct('messageTrackingId') 至 Messages.find(query) 然后它返回所有接收者 ID 的文档。但是当我添加 distinct 时，我没有得到任何结果。

app.get('/api/messages',(req, res, next)=>{
  query = {};
  inbox = false;
  messageId = false;
  if(req.query.recipientId){
    query = { recipientId: req.query.recipientId }
    inbox = true;

Messages.aggregate(// Pipeline
  [
      // Stage 1
      {
          $group: {
              _id: "$messageTrackingId",
              message : { $addToSet: '$message' },
              recipientId : { $addToSet: '$recipientId' },
              creator : { $addToSet: '$creator' },
              messageTrackingId : { $addToSet: '$messageTrackingId' },

          }
      },

      // Stage 2
      {
          $project: {
              _id: 1,
              message: { $arrayElemAt: ["$message", 0 ] },
              recipientId: { $arrayElemAt: ["$recipientId", 0 ] },
              creator: { $arrayElemAt: ["$creator", 0 ] },
              messageTrackingId: { $arrayElemAt: ["$messageTrackingId", 0 ] }
          }
      }

  ])

消息模型

const mongoose = require("mongoose");
const uniqueValidator = require("mongoose-unique-validator");

const messagingSchema = mongoose.Schema({
  creator: { type: mongoose.Schema.Types.ObjectId, ref: "User" },
  recipient: { type: String, required: true },
  recipientId: { type: String, required: true },
  message: { type: String, required: true },
  subject: { type: String, required: true },
  creationDate: { type: Date, required: true },
  messageTrackingId: { type: String }
  // readDate: { type: Date, required: true }
});


module.exports = mongoose.model("Messages", messagingSchema);

Answer 1

distinct 将返回不同的 fields，这不是您想要的。

您需要使用 aggregation 并按 messageTrackingId 分组，然后项目抓取您想要的第一条消息内容等：

给定示例数据，例如：

{ "messageTrackingId" : 1, "message" : "hello" }
{ "messageTrackingId" : 1, "message" : "hello" }
{ "messageTrackingId" : 1, "message" : "bye" }
{ "messageTrackingId" : 2, "message" : "bye" }
{ "messageTrackingId" : 2, "message" : "bye" }
{ "messageTrackingId" : 1, "message" : "hello" }

在 MongoDB 中：

db.getCollection("messages").aggregate(

// Pipeline
[
    // Stage 1
    {
        $group: {
            _id: "$messageTrackingId",
            message : { $addToSet: '$message' }
        }
    },

    // Stage 2
    {
        $project: {
            _id: 1,
            message: { $arrayElemAt: ["$message", 0 ] }
        }
    },

]);

要在猫鼬中使用，只需在模型上使用 aggregate 函数：

使用猫鼬

const result = await Message.aggregate(// Pipeline
        [
            // Stage 1
            {
                $group: {
                    _id: "$messageTrackingId",
                    message : { $addToSet: '$message' }
                }
            },

            // Stage 2
            {
                $project: {
                    _id: 1,
                    message: { $arrayElemAt: ["$message", 0 ] }
                }
            },

        ]);

评论后更新

如果您需要查询给定的messageTrackingId，则添加$match 作为管道的第一阶段：

const result = await Message.aggregate(
        [
            {
                $match: {
                    messageTrackingId: {$eq: 2}
                }
            },
            {
                $group: {
                    _id: "$messageTrackingId",
                    message : { $addToSet: '$message' }
                }
            },
            {
                $project: {
                    _id: 1,
                    message: { $arrayElemAt: ["$message", 0 ] }
                }
            },

        ]);