connect.js 1.3 KB

12345678910111213141516171819202122232425262728293031323334
  1. let mongoose = require('mongoose');
  2. let dbConfig = require('../config/dbConfig');
  3. let log = require('../util/log');
  4. // 启动数据库
  5. module.exports = function () {
  6. return new Promise(function (resolve) {
  7. let dbUrl = `mongodb://${dbConfig.username}:${dbConfig.password}@${dbConfig.host}:${dbConfig.port}/${dbConfig.dbName}`;
  8. // let dbUrl = `mongodb://${dbConfig.host}:${dbConfig.port}/${dbConfig.dbName}`;
  9. // if (!dbConfig.username) {
  10. // dbUrl = `mongodb://${dbConfig.host}:${dbConfig.port}/${dbConfig.dbName}`;
  11. // }
  12. log.debug(`dbUrl: ${dbUrl}`);
  13. mongoose.connect(dbUrl, {
  14. poolSize: 20,
  15. useMongoClient: true,
  16. authSource: dbConfig.authSource
  17. });
  18. mongoose.connection.on('connected', function () {
  19. log.debug(`connect to mongodb success, dbUrl: ${dbUrl}`);
  20. resolve();
  21. });
  22. mongoose.connection.on('error', function (err) {
  23. log.error(`connect to mongodb error, err: ${err} dbUrl: ${dbUrl}`);
  24. process.exit(1);
  25. });
  26. mongoose.connection.on('disconnected', function (err) {
  27. log.debug(`disconnect mongodb, dbUrl: ${dbUrl}, reason: ${err}`);
  28. process.exit(1);
  29. });
  30. })
  31. };