как использовать функцию connection.db.collection? - PullRequest
Новая
       8

как использовать функцию connection.db.collection?

0 голосов
/ 21 октября 2018

Я реализовал следующий код по этой ссылке:

Каков наилучший способ обработки глобального подключения Mongodb в NodeJs

, чтобы создать класс для подключенияMongoDB.Но когда я пытаюсь вызвать синглтон-класс в маршрутизаторе, я получаю следующую ошибку:

TypeError: Connection.db.collection не является функцией

mongodb.js 

const MongoClient = require('mongodb').MongoClient
const url = '...';

class Connection {
    static connectToDB() {
        if ( this.database ) return Promise.resolve(this.database)
        return MongoClient.connect(this.url, {useNewUrlParser: true}, (err, db) => {
            if (err) console.log(err);
            else {
                this.db = db;
                console.log('MongoDB connected');
            }
        })
    }
}

Connection.db = null
Connection.url = url
Connection.options = {
    bufferMaxEntries:   0,
    reconnectTries:     5000,
}

module.exports = Connection;

app.js 

const express = require('express');
const app = express();
let bodyParser = require('body-parser')

// mongodb config
const Connection = require('../config/mongodb');

const server = app.listen(3000, () => {
    Connection.connectToDB(); // output: MongoDB connected
    console.log(`listening to port: ${port} on http://127.0.0.1:3000}/`); // output: listening to port: 3000 on http://127.0.0.1:3000/
});

router.js 

const router = require('express').Router();
let Connection = require('../config/mongodb');

router.post('/data', (req, res) => {
    Connection.db.collection('tweets').find({}) // output: TypeError: Connection.db.collection is not a function
        .then(tweets => console.log(tweets))
        .catch(err => console.log(err));
});

Ответы [ 2 ]

0 голосов
/ 22 октября 2018

Попробуйте один раз в package.json, измените строку mongodb на "mongodb": "^ 2.2.33".Вам нужно будет удалить npm mongodb;затем npm install для установки этой версии.

0 голосов
/ 21 октября 2018

Вопрос, который вы связали, использует обещания повсюду, в то время как вы используете версию обратного вызова connect.

return MongoClient.connect(this.url, {useNewUrlParser: true}, (err, db) => ...

Затем вы вызываете его, не возвращаясь на свой сервер: 

Connection.connectToDB();
console.log(`listening to port: ${port} on http://127.0.0.1:3000}/`);

Таким образом, нет никакой гарантии, что ваше соединение будет установлено к тому времени, как поступит ваш первый запрос API. Фактически, если вы это сделали: 

Connection.connectToDB();
console.log(`listening to port: ${port} on http://127.0.0.1:3000}/`);
Connection.db.collection('tweets').find({});

Оно будет прерываться каждый раз, так какConnection.db по-прежнему будет нулевым.

В приведенном вами примере использование Promises защищает от этого.В частности, обратите внимание на метод подключения: 

static connectToDB() {
    if ( this.database ) return Promise.resolve(this.database)
    // ** USING THE PROMISE VERSION OF CONNECT **
    return MongoClient.connect(this.url, this.options)
        .then(db => this.db = db)
}

и ваш код использования также должен использовать обещания: 

return Connection.connectToDB()
    .then(() => {
        // do something here
    });
...