db.js 397 B

123456789101112
  1. const MongoClient = require('mongodb').MongoClient;
  2. const pjson = require('./package.json');
  3. function mongo(callback) {
  4. MongoClient.connect(pjson.mongoUrl, async function (err, db) {
  5. if (err) throw err;
  6. var dbo = db.db(pjson.name);
  7. await callback(dbo, db); // db 必须传入数据操作完毕后才能关闭,nodejs时异步执行的
  8. });
  9. }
  10. exports.mongo = mongo