sql >> Database teknologi >  >> NoSQL >> MongoDB

Opsætning af singleton-forbindelse med node.js og mongo

Her er, hvad der bruger async await på singleton. I min db.js

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

var DbConnection = function () {

    var db = null;
    var instance = 0;

    async function DbConnect() {
        try {
            let url = 'mongodb://myurl.blablabla';
            let _db = await MongoClient.connect(url);

            return _db
        } catch (e) {
            return e;
        }
    }

   async function Get() {
        try {
            instance++;     // this is just to count how many times our singleton is called.
            console.log(`DbConnection called ${instance} times`);

            if (db != null) {
                console.log(`db connection is already alive`);
                return db;
            } else {
                console.log(`getting new db connection`);
                db = await DbConnect();
                return db; 
            }
        } catch (e) {
            return e;
        }
    }

    return {
        Get: Get
    }
}


module.exports = DbConnection();

Og i alle moduler, der vil bruge den samme forbindelse

var DbConnection = require('./db');

async function insert(data) {
    try {
        let db = await DbConnection.Get();
        let result = await db.collection('mycollection').insert(data);

        return result;
    } catch (e) {
        return e;
    }
}


  1. MongoDB Aggregation Framework Stadier og Pipelining

  2. Scrapy-redis-programmet lukker ikke automatisk

  3. Mac(os x):Er der en måde at installere KUN redis-cli på?

  4. Hvordan får man opdateret dokument tilbage fra findOneAndUpdate-metoden?