const mysql = require('mysql')

 const pool = mysql.createPool({

   connectionLimit: 20, //连接池连接数

   host: 'localhost', //数据库地址，这里用的是本地

   database: 'xxxx', //数据库名称

   user: 'xxxxx',  // username

   password: '*****' // password

 })

 //返回一个Promise链接

 const connectHandle = () => new Promise((resolve, reject) => {

   pool.getConnection((err, connection) => {

     if(err) {

       console.error('链接错误：' + err.stack + '\n' + '链接ID：' + connection.threadId)

       reject(err)

     } else {

       resolve(connection)

     }

   })

 })

 module.exports = connectHandle

 const connectHandler = require('./db.config') //引入上面所讲的数据库基础配置

 const insertHandler = async (vals) => {

   const connection = await connectHandler() // 得到链接

   const tablename = 'xxxxx' //动态table(表)名称

   //开启事务

   connection.beginTransaction( err => {

     if(err) {

       return '开启事务失败'

     } else {

        //执行INSERT插入操作

       connection.query(`INSERT INTO ${tablename} SET ?`, vals, (e, rows, fields) => {

         if(e) {

           return connection.rollback(() => {

             console.log('插入失败数据回滚')

           })

         } else {

           connection.commit((error) => {

             if(error) {

               console.log('事务提交失败')

             }

           })

           connection.release()  // 释放链接

           return {rows, success: true}  // 返回数据库操作结果这里数据格式可根据个人或团队规范来定制

         }

       })

     }

   })

 }

 module.exports = {

   insertHandler

 }