26 lines
755 B
JavaScript
26 lines
755 B
JavaScript
const mysql = require('mysql2')
|
|
const config = require('../config')
|
|
|
|
module.exports = function(sql, params) {
|
|
return new Promise((resolve, reject) => {
|
|
// 一、新建一个连接池
|
|
let pool = mysql.createPool(config.mysql)
|
|
// 二、连接
|
|
pool.getConnection((error, connection) => {
|
|
// 三、使用sql语句操作
|
|
if(error){
|
|
console.log('数据库连接失败',error);
|
|
}
|
|
// eslint-disable-next-line no-unused-vars
|
|
connection.query(sql, params, (err, results, fields) => {
|
|
if (err) {
|
|
reject(err)
|
|
} else {
|
|
resolve(results)
|
|
}
|
|
// 四、释放连接池
|
|
connection.release()
|
|
})
|
|
})
|
|
})
|
|
} |