其实你有参考。您可以在建立连接后随时mongoose.connection返回当前连接。
您也可以简单地从任何模型实例中获取db。因此,如果您不想在集合不存在时出现错误try..catch,则可以使用一种方法,基本上是使用底层驱动程序中的.listCollections() 方法,以查看您是否要实际访问的集合首先存在于命名空间中:
const mongoose = require('mongoose'),
Schema = mongoose.Schema;
mongoose.Promise = global.Promise;
mongoose.set('debug',true);
const uri = 'mongodb://localhost/blank',
options = { useMongoClient: true };
const testSchema = new Schema({},{ strict: false });
const ModelA = mongoose.model('ModelA', testSchema);
const ModelB = mongoose.model('ModelB', testSchema);
(async function() {
try {
const conn = await mongoose.connect(uri,options);
await ModelB.create({ a: 1 });
for ( let model of [ModelA,ModelB] ) {
let list = await model.db.db.listCollections({
name: model.collection.name
}).toArray()
//console.log(JSON.stringify(list,undefined,2));
if ( list.length !== 0 ) {
await model.collection.drop();
} else {
console.log('collection %s does not exist',model.collection.name);
}
}
} catch(e) {
console.error(e);
} finally {
mongoose.disconnect();
}
将证明第一次尝试的收集丢弃不存在,不会引发错误:
Mongoose: modelbs.insert({ a: 1, _id: ObjectId("59aa9cfe581cca7afac55181"), __v: 0 })
collection modelas does not exist
Mongoose: modelbs.drop()
您还可以执行其他操作,例如使用底层驱动程序中的.collection() 和{ strict: true } 来首先获取集合对象。但同样,这实际上只是“引发错误”。因此,虽然您在发出 .drop() 之前“知道”该集合不存在,但它仍然需要处理相同的 try..catch。
因此,如果没有错误,请先检查集合是否存在。当然,只要没有其他东西可以将其删除。但您可能应该始终处理错误以防万一。
就我个人而言,我确实发现允许发生异常然后简单地检查细节以查看引发的异常是我所期望的:
for ( let model of [ModelA,ModelB] ) {
try {
await model.collection.drop();
} catch (e) {
if (e.code === 26) {
console.log('namespace %s not found',model.collection.name)
} else {
throw e;
}
}
}
在这种情况下,code: 26 用于 "Namespace not found",在这种情况下或在使用本机 .collection() 方法和 { strict: true } 的情况下也会引发。但是使用集合对象的现有句柄的.drop() 要短得多。
要点是没有什么需要您实际记录异常,并且“检查异常”(即批量插入中的预期重复键错误)是一种常见做法。只需测试预期的错误代码,然后“如果”返回其他内容,那么您将在更高级别引发异常。
如前所述,虽然您“可以”假设如果您要求数据库按名称列出集合并且它在结果中那么它存在,但最安全的方法是仍然从 I/O 中捕获任何异常以防“查询”和“操作”之间有一些其他修改要删除。