为什么我不能使用相关mongo文档中的id在GridFS上设置id

Question

我的应用使用node 0.10.1，express 3.1.1，mongoose 3.6.4，mongo 2.4.1和gridfs-stream 0.4.0。

我已经使用共享连接设置了mongoose和gridfs-stream，如下所示：

/************* app.js ***************/
//Added this in edit to show setup of mongoose and gridfs-stream
var mongoose = require("mongoose");
var Grid = require('gridfs-stream');
Grid.mongo = mongoose.mongo;
global.conn = mongoose.createConnection(dbUri);
conn.once('open', function(){
    global.gfs = Grid(conn.db);
});

我正在尝试使用gridfs-stream上传/下载文件。我上传的内容如下所示：

exports.uploadFile = function(req, res){
    var file = req.files.upload;
    var docId = mongoose.Types.ObjectId(req.query.docId);
    var filename = req.query.ileName;
    var contentType = file.type;

    if(!file) return res.send({result: 'NO_FILE_UPLOADED'});

    var writestream = gfs.createWriteStream({
        _id: docId,
        filename: filename,
        mode: 'w',
        root: 'documents'
    });
 // more here but ommitted
 };

docId来自mongo文档的ObjectId。

上载似乎正常工作。我可以使用mongo控制台查看上传的文件：

db.documents.files.findOne()
{
   "_id" : ObjectId("5167604d1b63f2541400003d"),
   "filename" : "borrower1.fnm",
   "contentType" : "binary/octet-stream",
   "length" : 3473,
   "chunkSize" : 262144,
   "uploadDate" : ISODate("2013-04-12T15:43:06.723Z"),
   "aliases" : null,
   "metadata" : null,
   "md5" : "04c85fe5e9ba0e798fd5eb90f1cb62be"
}

当我尝试下载该文件时，使用以下命令：

exports.downloadFile = function(req, res){
    var docId = mongoose.Types.ObjectId(req.query.docId);
    var readstream = gfs.createReadStream({_id: docId});
    readstream.pipe(res);
};

抛出以下错误：

Error: 5167604d1b63f2541400003d does not exist

当我尝试使用似乎存储在gridfs数据库中的_id直接从mongo控制台检索文件时，它返回null。但是，如果我尝试使用文件名检索文件，mongo控制台将检索该文件。

可以不使用相关mongo文档的_id在gridfs中设置上传文件的_id吗？如果是这样，我的代码怎么会不正确呢？如果不是，有没有办法让grid生成id并取回分配的id，这样我就可以将其存储在相关的mongo文档中？

谢谢你的帮忙!

抢夺

Answer 1

我将回答我自己的问题，因为我在浏览mongoose server.js和gridfs-stream的源代码时找到了答案。

您可以使用相关文档的ObjectId作为存储文件的ObjectId。

但是，如果您在上传时提供了"root“选项，则还需要在下载代码中使用它。否则，mongoose会假设该集合是基集合。

所以这是可行的：

exports.uploadFile = function(req, res){
    var file = req.files.upload;
    var docId = mongoose.Types.ObjectId(req.query.docId);
    var filename = req.query.ileName;
    var contentType = file.type;

    if(!file) return res.send({result: 'NO_FILE_UPLOADED'});

    var writestream = gfs.createWriteStream({
        _id: docId,
        filename: filename,
        mode: 'w',
        root: 'documents'
    });
 // more here but ommitted
 };

exports.downloadFile = function(req, res){
    var id = gfs.tryParseObjectId(req.query.docId);
    //note that options now includes 'root'
    var options = {_id: id, root: 'documents'};
    try{
        gfs.createReadStream(options).pipe(res);
    } catch(err){
        console.log(err);

    }
};

Answer 2

你有没有试过把req.query.docId转换成ObjectId？如果从查询中接收的值是字符串，那么如果在上传过程中使用了这种类型的_id，则需要将其转换为ObjectId。

exports.downloadFile = function(req, res){
    console.log(req.query.docId);
    var readstream = gfs.createReadStream({_id: mongoose.Types.ObjectId(req.query.docId)});
    readstream.pipe(res);
};

Answer 3

我查看了gridfs-stream页面，您是否为其分配了mongoose驱动程序。

var conn = mongoose.createConnection(..);
conn.once('open', function () {
  var gfs = Grid(conn.db, mongoose.mongo); //missing parameter

  // all set!
})

或

Grid.mongo = mongoose.mongo;  //missing 

var conn = mongoose.createConnection(..);
conn.once('open', function () {
  var gfs = Grid(conn.db);

  // all set!
});