12345678910111213141516171819202122232425262728293031323334 |
- let mongoose = require('mongoose');
- let dbConfig = require('../config/dbConfig');
- let log = require('../util/log');
- // 启动数据库
- module.exports = function () {
- return new Promise(function (resolve) {
- let dbUrl = `mongodb://${dbConfig.username}:${dbConfig.password}@${dbConfig.host}:${dbConfig.port}/${dbConfig.dbName}`;
- // let dbUrl = `mongodb://${dbConfig.host}:${dbConfig.port}/${dbConfig.dbName}`;
- // if (!dbConfig.username) {
- // dbUrl = `mongodb://${dbConfig.host}:${dbConfig.port}/${dbConfig.dbName}`;
- // }
- log.debug(`dbUrl: ${dbUrl}`);
- mongoose.connect(dbUrl, {
- poolSize: 20,
- useMongoClient: true,
- authSource: dbConfig.authSource
- });
- mongoose.connection.on('connected', function () {
- log.debug(`connect to mongodb success, dbUrl: ${dbUrl}`);
- resolve();
- });
- mongoose.connection.on('error', function (err) {
- log.error(`connect to mongodb error, err: ${err} dbUrl: ${dbUrl}`);
- process.exit(1);
- });
- mongoose.connection.on('disconnected', function (err) {
- log.debug(`disconnect mongodb, dbUrl: ${dbUrl}, reason: ${err}`);
- process.exit(1);
- });
- })
- };
|