mongoose 为什么我的数据库对象的集合是空的?

h22fl7wq  于 11个月前  发布在  Go
关注(0)|答案(2)|浏览(123)

第三方节点模块,在localhost上创建并填充mongoDB数据库。我正在尝试使用该数据库并从自定义模块中检索数据。即使我可以成功连接到数据库,它也没有显示数据库中的集合或文档。
我对Mongoose文档的印象是,首先我必须为我想要使用的每个集合创建schema,然后为mongoDB创建模型。这些模型是在第三方模块中创建的,我想要使用的集合已经存在于数据库中。
正如你所看到的,我对这个mongodb+mongoose+nodejs堆栈是新手。我在新模块中创建模式和模型是正确的吗-这是很多代码重复?或者我错过了什么?
在mongo shell中,我先执行use gtfs,然后执行show collections,以确认gtfs数据库不为空。

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

字符串
然后确认DB中也有文档,

> 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对象时,它显示collections属性为空:

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 } }

eh57zj3b

eh57zj3b1#

在我看来,使用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();
  });

});

字符串
此处记录了插入文档的过程。
对于几乎所有的Node代码,需要考虑的一件事是,所有的I/O操作(网络/数据库/文件系统/等)都是异步的,这意味着你传递了一个函数,当I/O操作完成(或发生错误)时,这个函数将被调用。
这些呼叫不会阻塞;换句话说,你只是告诉Node调度一个I/O操作,并在它完成时返回给你。然而,你告诉Node执行操作的代码后面的任何代码都将在操作完成后立即执行,而不仅仅是在操作完成后执行。
这就是为什么上面的代码将函数嵌套在函数中。

tyky79it

tyky79it2#

获取特定数据库中的集合列表。

如果你想在浏览器中看到它,你可以使用Express将其作为响应发送。

const mongoose = require('mongoose');
require('dotenv').config()

// MongoDB connection string (DATABASE NAME IS NOT PRESENT IN URI STRING)(For MongoDb Atlas)
const mongoURI = process.env.DATABASE_URI;

// Connect to MongoDB
mongoose.connect(mongoURI);

// Get the default connection
const db = mongoose.connection;

db.once('open', async ()=>{
  //Connect to database whose collections you want to see
  const userdb = await db.useDb('NAME OF DATABSE WHOSE COLLECTION YOU WANT TO SEE');  
  // Use listCollections method to get all Collection and toArray to display collections in Array
  const  data = await userdb.db.listCollections().toArray()
  console.log(data);
})

字符串

相关问题