2022-03-29 15:04:07 +08:00
|
|
|
const mysql = require("mysql");
|
|
|
|
|
const dbConfig = require("../config/db");
|
|
|
|
|
module.exports = {
|
|
|
|
|
pool: null,
|
|
|
|
|
init: () => {
|
|
|
|
|
this.pool = mysql.createPool(dbConfig)
|
|
|
|
|
},
|
2022-03-30 19:19:56 +08:00
|
|
|
query: sql => new Promise((resolve, reject) => {
|
2022-03-29 15:04:07 +08:00
|
|
|
this.pool?.getConnection((err, conn) => {
|
|
|
|
|
if (err) {
|
|
|
|
|
console.log(err)
|
|
|
|
|
} else {
|
|
|
|
|
conn.query(sql, (err, result) => {
|
|
|
|
|
if (err) {
|
|
|
|
|
console.log(err)
|
2022-03-30 19:19:56 +08:00
|
|
|
reject(err)
|
2022-03-29 15:04:07 +08:00
|
|
|
} else {
|
|
|
|
|
conn.release()
|
|
|
|
|
resolve(result)
|
|
|
|
|
}
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
})
|
|
|
|
|
}),
|
|
|
|
|
}
|