javascript - 为什么我的数据库对象的集合是空的？

Question

第 3 方 Node 模块，在本地主机上创建并填充 mongoDB 数据库。我正在尝试使用数据库并从我的自定义模块中检索数据。即使我可以成功连接到数据库，它也没有显示数据库中的集合或文档。

我对 Mongoose 文档的印象是，首先我必须创建模式，然后为我想使用的每个集合创建 mongoDB 模型。这些模型是在第 3 方模块中创建的，我想要使用的集合已经存在于数据库中。

如您所知，我是这个 mongodb+mongoose+nodejs 堆栈的新手。我在新模块中创建模式和模型是否正确 - 这是大量的代码重复？还是我遗漏了什么？

我从 mongo shell 使用 gtfs 然后 show collections 确认 gtfs 数据库不为空。

> use gtfs
switched to db gtfs
> show collections
agencies
routes
...

然后确认数据库中也有文件，

> db.routes.find({'route_id':'6182'}).pretty()
{
    "_id" : ObjectId("562fcf97090e937d06a34e67"),
    "route_id" : "6182",
    "agency_id" : "DDOT",
     ...
}

我从我的自定义模块连接到数据库:

var mongoose = require('mongoose');
var mongo_url = 'mongodb://127.0.0.1:27017/gtfs';
//Each connection instance maps to a single database
var db = mongoose.createConnection(mongo_url);
  console.log('db -> ', db);

我在 mongoose 文档中读到，当您创建连接时，mongoose 会将您的连接对象定向到 open 或 openSet 方法。所以，我知道我的问题不是创建数据库连接对象而是没有打开它。

当我打印出 db 对象时，它显示集合属性为空:

db ->  { connections: 
   [ { base: [Circular],
       collections: {},
       models: {},
       config: [Object],
       replica: false,
       hosts: null,
       host: 'localhost',
       port: 27017,
       user: undefined,
       pass: undefined,
       name: 'gtfs',
       options: [Object],
       otherDbs: [],
       _readyState: 2,
       _closeCalled: false,
       _hasOpened: false,
       _listening: false,
       _events: {},
       db: [Object] } ],
  plugins: [],
  models: {},
  modelSchemas: {},
  options: { pluralization: true } }

Answer 1

在我看来，使用 mongodb 可能更容易驱动程序而不是 Mongoose(后者在 MongoDB 文档之上实现了一个额外的层，这很好，但通常在数据库也由 Mongoose 填充时效果更好)。

关于如何使用 mongodb 查询数据的示例(确保在运行脚本之前运行 npm install mongodb):

var MongoClient = require('mongodb').MongoClient;

var url = 'mongodb://localhost:27017/gtfs';

// Connect to the database.
MongoClient.connect(url, function(err, db) {

  // If an error occurred during connect, exit the script by
  // throwing an exception.
  if (err) throw err;

  // Get a reference to the collection.
  var routes = db.collection('routes');

  // Run a query against the `routes` collection.
  var cursor = routes.find({ route_id : '6182' });

  // Read all the results from the cursor and turn them into a JS array.
  cursor.toArray(function(err, documents) {
    if (err) throw err;

    // Output the results as JSON.
    console.log('%j', documents);

    // Close the connection.
    db.close();
  });

});

插入文档 is documented here .

几乎所有 Node 代码都需要考虑的一件事是所有 I/O 操作(网络/数据库/文件系统/等)都是异步的，这意味着您传递一个函数，该函数将在 I/O 操作时调用已完成(或发生错误)。

这些调用不会阻塞；换句话说，您只是告诉 Node 安排一个 I/O 操作并在它完成时返回给您。但是，在您告诉 Node 执行操作的代码之后的任何代码都将在之后立即执行，而不仅仅是在操作完成时执行。

这就是上面代码将函数嵌套在函数中的原因。