const DB_MYSQL = require('mysql');
const DB_CONFIG = require('./DBConfig');
/**
- 数据库连接池
- @type {Pool}
*/
const pool = DB_MYSQL.createPool({undefined
host: DB_CONFIG.database.HOST,
user: DB_CONFIG.database.USERNAME,
password: DB_CONFIG.database.PASSWORD,
database: DB_CONFIG.database.DATABASE,
port: DB_CONFIG.database.PORT
});
/**
- 通用方法
- @param sql
- @param options
*/
const DB = (sql, options) =>{undefined
options= (options) ? options:{}
return new Promise((resolve, reject) => {undefined
pool.getConnection((error, connection) => {undefined
if (error) {undefined
reject(error);
} else {undefined
connection.query(sql, options, (error, results, fields) => {undefined
//事件驱动回调
if (results){undefined
resolve(results);
}
if (error) {undefined
reject(error)
}
});
}
//释放连接
pool.releaseConnection(connection);
});
})
};
module.exports = DB;
