如何检查一个集合是否存在于Mongodb本地nodejs驱动程序中？

Question

我需要检查一个集合是否存在于某个数据库上，如果没有，就创建它。我知道

db.createCollection(collName, {strict:true}, function(error, collection)) 

检查收集collName的所有脑干创建它之前，并设置error对象。但我需要一个独立的功能来检查。

Answer 1

在MongoDB中3.0和更高版本，你必须运行一个命令列出所有集合在一个数据库：

use test; 
db.runCommand({ listCollections: 1 }); 

虽然查询system.namespaces当您使用默认存储引擎（MMAPv1）仍然有效，它不保证为其他引擎工作，如WiredTiger。

MongoDB的3.0之前，你需要做到以下几点：

您可以查询system.namespaces集合：

use test; 
db.system.namespace.find({ name: 'test.' + collName }); 

像：

db.system.namespaces.find({ name: 'test.testCollection' }); 

将返回：

{ "name" : "test.testCollection", "options" : { "flags" : 1 } } 

或者当然没什么。

参见：https://github.com/mongodb/specifications/blob/master/source/enumerate-collections.rst

Answer 2

本地驱动程序的Db对象的collectionNames方法接受一个可选的集合名称过滤器作为第一个参数来让你检查一个集合的存在：

db.collectionNames(collName, function(err, names) { 
    console.log('Exists: ', names.length > 0); 
}); 

在MongoDB本地驱动程序的2.x版本中，collectionNames已被替换为listCollections，它接受一个过滤器并返回一个光标，因此您可以这样做：

db.listCollections({name: collName}) 
    .next(function(err, collinfo) { 
     if (collinfo) { 
      // The collection exists 
     } 
    }); 

Answer 3

问题涉及本机驱动程序，但我在这里搜索如何在pymongo中执行此操作。通常pymongo的api与JS api相同，但在这种情况下，collection_names没有该集合名称的参数（如JohnnyHK的answer的第一个参数是布尔值） ）。由于字符串评估为True，这可能会造成混淆。所以我希望这可以帮助未来的读者：

import pymongo 

cl = pymongo.MongoClient() 
db = cl['my-db'] 
if 'my-col' in db.collection_names(False): 
    ... 

Answer 4

Node.js本地驱动程序中现在有一个listCollections方法。它返回当前数据库中所有集合的信息。你可以用它来检查给定的集合是否存在：

collectionExists = function(name, cb) { 
    mongoDb.listCollections().toArray(function(err, collections) { 
    if (err) return cb(err); 

    cb(null, collections.some(function(coll) { 
     return coll.name == name; 
    })); 
    }); 
} 

Answer 5

由于MongoDB 3。0您可以简单地运行：

db.getCollectionNames() 

它会返回所有集合的当前数据库名称的数组：

[ "employees", "products", "mylogs"] 

检查Mongo DB Documentation，或者你也可以使用db.getCollectionInfos（），如果你需要了解每个集合

Answer 6

使用mongo-native司机和Node.js 7.6+更多的信息，我使用以下命令：

const collections = await db.collections(); 
if (!collections.map(c => c.s.name).includes(collName)) { 
    await db.createCollection(collName); 
}