ax-node/mysql.js

import * as mysql from 'mysql'
const db_config = {
    host: '8.140.240.182',
    user: 'root',
    password: 'Taiji@2023#data',
    port: "18080",
    database: 'ax_seat_show'
}
// 进行数据库交互
const conMysql = (sql) => {
    let connect = mysql.createConnection(db_config)
    // 开始链接数据库
    connect.connect(function (err) {
        if (err) {
            console.log(`mysql连接失败: ${err}!`)
        } else {
            console.log('mysql连接成功!')
        }
    })
    // 返回一个Promise承诺对象
    return new Promise((resolve, reject) => {
        connect.query(sql, (err, result) => {
            if (err) {
                reject(err)
            } else {
                // 此处需要将返回数据转为JSON再转回来,否则原数据不为任何数据类型
                let res = JSON.parse(JSON.stringify(result))
                closeMysql(connect)
                resolve(res)
            }
        });
    })
}
// 查询成功后关闭mysql
const closeMysql = (connect) => {
    connect.end((err) => {
        if (err) {
            console.log(`mysql关闭失败:${err}!`)
        } else {
            console.log('mysql关闭成功!')
        }
    })
}
// 导出方法
export {
    conMysql
}