const DB_MYSQL = require('mysql');
const DB_CONFIG = require('./DBConfig');
/**
* 数据库连接池
* @type {Pool}
*/
const pool = DB_MYSQL.createPool({
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) =>{
options= (options) ? options:{}
return new Promise((resolve, reject) => {
pool.getConnection((error, connection) => {
if (error) {
reject(error);
} else {
connection.query(sql, options, (error, results, fields) => {
//事件驱动回调
if (results){
resolve(results);
}
if (error) {
reject(error)
}
});
}
//释放连接
pool.releaseConnection(connection);
});
})
};
module.exports = DB;
