如何在Node.js中使用Mongoose查询MongoDB多集合并返回数据到前端

步骤1：修改搜索控制器逻辑 #

首先你需要在搜索控制器中导入所有三个集合对应的模型，使用Promise.all并行查询三个集合，合并结果后返回即可，修改后的代码如下：

// controllers/movies.js 顶部新增另外两个模型的导入，路径替换成你项目实际的文件路径
import MoviePost from "../../models/movies/moviesSchema.js";
import TrendingPost from "../../models/trendingSchema.js"; 
import WebShowPost from "../../models/webshowSchema.js";
import mongoose from 'mongoose'

// 新增全局搜索方法，也可以直接修改原有getDataBySearch方法
export const getGlobalSearch = async(req,res)=>{
    const {searchQuery} = req.query
    // 空关键词校验
    if(!searchQuery?.trim()) return res.status(400).json({message:"搜索关键词不能为空"})
    try {
        const regex = new RegExp(searchQuery.trim(),'i')
        // 并行查询三个集合，比串行查询效率更高
        const [movieResult, trendingResult, webshowResult] = await Promise.all([
            // 可按需扩展搜索字段，比如同时匹配标题、导演、简介
            MoviePost.find({
                $or: [
                    {title: regex},
                    {director: regex},
                    {description: regex}
                ]
            }),
            TrendingPost.find({
                $or: [
                    {title: regex},
                    {director: regex},
                    {description: regex}
                ]
            }),
            WebShowPost.find({
                $or: [
                    {title: regex},
                    {director: regex},
                    {description: regex}
                ]
            })
        ])
        // 给不同类型的结果添加类型标记，方便前端区分展示
        const formattedMovies = movieResult.map(item => ({...item.toObject(), type: 'movie'}))
        const formattedTrending = trendingResult.map(item => ({...item.toObject(), type: 'trending'}))
        const formattedWebshows = webshowResult.map(item => ({...item.toObject(), type: 'webshow'}))
        // 合并所有结果，可按需新增排序、分页逻辑
        const allResult = [...formattedMovies, ...formattedTrending, ...formattedWebshows]
        // 注意查询成功使用200状态码，你之前用的201是资源创建成功的状态码，不适用于查询场景
        res.status(200).json(allResult)
    } catch (error) {
        res.status(500).json({message: error.message})
    }
}

步骤2：配置搜索路由 #

你可以直接在server.js中新增全局搜索路由，或者单独创建搜索路由模块：

// server.js 路由配置区域新增代码，替换成你实际的控制器导入路径
import { getGlobalSearch } from './controllers/movies/movies.js'
app.get('/api/search', getGlobalSearch)

如果你不想修改现有结构，也可以保留三个模块各自的搜索接口，前端并行请求三个接口再合并结果，不过服务端统一处理的方案性能更好，前端调用更简单。

步骤3：前端接收数据示例 #

前端直接携带搜索关键词发起GET请求即可拿到结果，React示例代码如下：

const fetchSearchResult = async (keyword) => {
    try {
        const res = await axios.get('http://localhost:5000/api/search', {
            params: {
                searchQuery: keyword
            }
        })
        // res.data就是所有匹配的搜索结果，直接赋值给状态变量渲染即可
        setSearchList(res.data)
    } catch (err) {
        console.error('搜索失败：', err)
    }
}

可选优化方向 #

• 如果数据量较大，可以新增分页参数，对合并后的结果做分页返回
• 给MongoDB的常用搜索字段加索引，大幅提升查询速度
• 可根据匹配度对结果排序，比如标题匹配的结果排在简介匹配的结果前面
• 支持分类搜索，前端可传类型参数，只搜索指定集合的内容

内容的提问来源于stack exchange，提问作者NILESH JAISWAR