節點分頁和過濾未按預期作業

我正在嘗試在后端實作分頁和過濾。

該控制器的輸入是頁碼和過濾條件。

控制器：-

const getPosts = asyncHandler(async (req, res) => {
    const {
      page,
      statusFilter,
      typeFilter,
      sourceFilter,
    } = JSON.parse(req.query.filterData);
  
    
  
    var query = [
      {
        $addFields: {

          paramType: typeFilter,
          paramSource: sourceFilter,
          paramStatus: statusFilter,
        },
      },
      {
        $match: {
          $expr: {
            $and: [
              { user: req.user.id },
              {
                $or: [
                  {
                    $eq: ["$paramType", "All"],
                  },
                  {
                    $eq: ["$paramType", "$type"],
                  },
                ],
              },
              {
                $or: [
                  {
                    $eq: ["$paramSource", "All"],
                  },
                  {
                    $eq: ["$paramSource", "$source"],
                  },
                ],
              },
              {
                $or: [
                  {
                    $eq: ["$paramStatus", "All"],
                  },
                  {
                    $eq: ["$paramStatus", "$status"],
                  },
                ],
              },
            ],
          },
        },
      },
      {
        $project: {
          paramSource: false,
          paramType: false,
          paramStatus: false,
        },
      },
    ];
  
    //pagination
    const PAGE_SIZE = 5;
    const PAGE = parseInt(page) || 0;
  
    // aggregate query
    const aggregateQuery = await Post.aggregate([query]);

  
    const total = aggregateQuery.length;
  
  
    const Allposts = await Post.aggregate([query])
      .limit(PAGE_SIZE)
      .skip(PAGE_SIZE * PAGE)
      .sort({ createdAt: -1 });
  
    const totalPages = Math.ceil(total / PAGE_SIZE);
  
  
    res.status(200).json({ totalPages, Allposts });
  });

問題：-

分頁和過濾部分按預期作業，但僅適用于第一頁，當我轉到第二頁時，Allposts物件為空。

為什么 Allposts 物件在第一頁之后是空的？

編輯：-

樣本資料：-

{
    "_id" : 1,
    "type" : "Type A",
    "source" : "Source A",
    "status" : "Status A",
    "createdAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "updatedAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "__v" : 0
},
{
    "_id" : 2,
    "type" : "Type B",
    "source" : "Source C",
    "status" : "Status B",
    "createdAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "updatedAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "__v" : 0
},

{
    "_id" : 3,
    "type" : "Type A",
    "source" : "Source A",
    "status" : "Status A",
    "createdAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "updatedAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "__v" : 0
},

{
    "_id" : 4,
    "type" : "Type A",
    "source" : "Source C",
    "status" : "Status B",
    "createdAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "updatedAt" : ISODate("2022-04-13T17:12:28.096Z"),
    "__v" : 0
}

更新的聚合查詢：-

var query = [
    
    {
      $addFields: {
        paramType: typeFilter,
        paramSource: sourceFilter,
        paramStatus: statusFilter,
      },
    },
    {
      $match: {
        $expr: {
          $and: [
            { user: req.user.id },
            {
              $or: [
                {
                  $eq: ["$paramType", "All"],
                },
                {
                  $eq: ["$paramType", "$type"],
                },
              ],
            },
            {
              $or: [
                {
                  $eq: ["$paramSource", "All"],
                },
                {
                  $eq: ["$paramSource", "$source"],
                },
              ],
            },
            {
              $or: [
                {
                  $eq: ["$paramStatus", "All"],
                },
                {
                  $eq: ["$paramStatus", "$status"],
                },
              ],
            },
            
          ],
        },
      },
    },{ $sort : { createdAt : -1 } },
    {
      $project: {
        paramSource: false,
        paramType: false,
        paramStatus: false,
        createdAt : 1,
      },
    }
  ];

uj5u.com熱心網友回復：

如果您想要一個查詢的分頁 總計數，您可以執行以下操作：

db.collection.aggregate([
  {
    $addFields: {
      paramType: "typeFilter",
      paramSource: "sourceFilter",
      paramStatus: "statusFilter"
    }
  },
  {
    "$match": {
      // complete here
    }
  },
  {
    $setWindowFields: {
      output: {totalCount: {$count: {}}}}
  },
  {$sort: {createdAt: -1}},
  {$skip: PAGE_SIZE * PAGE},
  {$limit: PAGE_SIZE},
  {
    $facet: {
      results: [
        {
          $project: {
            // here put whatever you want to send to FE
            type: 1,
            source: 1,
          }
        }
      ],
      totalCount: [
        {$limit: 1},
        {$project: {totalCount: 1, _id: 0}}
      ]
    }
  }
])

正如你在操場上看到的

允許您將$setWindowFields總數添加到所有檔案。$sort，$skip并$limit允許分頁。$facet允許您從相同的檔案中獲得不同的輸出。

標籤：javascript 节点.js mongodb 表示 mongodb查询

上一篇：兩次呼叫express()有什么區別

下一篇：使用帶有Express和JSON格式的swaggerOpenAPI3.0進行多重授權