GridFS文件无法回传：MongoDB图片检索报错求助

问题描述 #

在MongoDB中使用GridFS存储图片，上传功能正常，但检索时存在两类问题：

• 提示 gfs变量未定义
• 找到文件后报错 grid.mongo.objectid is not a constructor

错误原因及修复方案 #

1. gfs变量未定义 #

原因：数据库连接是异步操作，请求可能在conn.once('open')回调执行前触发，此时gfs还未完成初始化。

修复方案：
所有依赖gfs的路由先判断连接状态，未初始化则返回错误；同时推荐使用MongoDB官方维护的GridFSBucket替代已停止更新的gridfs-stream。

代码修改：

// 移除gridfs-stream导入
// import Grid from "gridfs-stream"

// 初始化GridFSBucket替代原gfs
let gfsBucket;
conn.once("open", () => {
  gfsBucket = new mongoose.mongo.GridFSBucket(conn.db, {
    bucketName: "uploads"
  });
});

// 修改/files路由，增加连接状态判断
app.get("/files", async (req, res) => {
  if (!gfsBucket) {
    return res.status(500).json({ err: "数据库连接未完成" });
  }
  try {
    const files = await conn.db.collection("uploads.files").find().toArray();
    if (!files || files.length === 0) {
      return res.status(404).json({ err: "No files exist" });
    }
    return res.json(files);
  } catch (err) {
    res.status(500).json({ err: err.message });
  }
});

2. grid.mongo.objectid is not a constructor #

原因：gridfs-stream与新版本mongoose的MongoDB驱动不兼容，Grid.mongo.ObjectID写法过时。

修复方案：使用mongoose.Types.ObjectId替代过时写法，同时配合GridFSBucket实现删除功能。

代码修改：

// 修改删除文件路由
app.delete("/files/:id", async (req, res) => {
  if (!gfsBucket) {
    return res.status(500).json({ err: "数据库连接未完成" });
  }
  try {
    const objectId = new mongoose.Types.ObjectId(req.params.id);
    await gfsBucket.delete(objectId);
    res.redirect("/");
  } catch (err) {
    res.status(404).json({ error: err.message });
  }
});

完整替换为GridFSBucket的核心路由示例 #

// 获取图片路由
app.get("/image/:filename", async (req, res) => {
  if (!gfsBucket) {
    return res.status(500).json({ err: "数据库连接未完成" });
  }
  try {
    const file = await conn.db.collection("uploads.files").findOne({ filename: req.params.filename });
    if (!file) {
      return res.status(404).json({ err: "No file exists" });
    }
    if (file.contentType === "image/jpeg" || file.contentType === "image/png") {
      res.set("Content-Type", file.contentType);
      gfsBucket.openDownloadStreamByName(req.params.filename).pipe(res);
    } else {
      res.status(404).json({ error: "Not an Image" });
    }
  } catch (err) {
    res.status(500).json({ err: err.message });
  }
});

// 获取单个文件路由
app.get("/file/:filename", async (req, res) => {
  if (!gfsBucket) {
    return res.status(500).json({ err: "数据库连接未完成" });
  }
  try {
    const file = await conn.db.collection("uploads.files").findOne({ filename: req.params.filename });
    if (!file) {
      return res.status(404).json({ err: "No file exists" });
    }
    res.set("Content-Type", file.contentType);
    gfsBucket.openDownloadStreamByName(req.params.filename).pipe(res);
  } catch (err) {
    res.status(500).json({ err: err.message });
  }
});

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