const DB_MYSQL = require('mysql');
const DB_CONFIG = require('./DBConfig');
/**
* 數(shù)據(jù)庫(kù)連接池
* @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) => {
? ? ? ? ? ? ? ? ? ? //事件驅(qū)動(dòng)回調(diào)
? ? ? ? ? ? ? ? ? ? if (results){
? ? ? ? ? ? ? ? ? ? ? ? resolve(results);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? if (error) {
? ? ? ? ? ? ? ? ? ? ? ? reject(error)
}
? ? ? ? ? ? ? ? });
? ? ? ? ? ? }
?????????????//釋放連接
? ? ? ? ? ? pool.releaseConnection(connection);
? ? ? ? });
? ? })
};
module.exports = DB;
