onlypersevere 2020-06-16
let mysql=require(`mysql`) //引入相应依赖module.exports={ //导出对象 // config:{host:`localhost`, //主机名 user:‘root‘, //用户名 password:`123`, //密码 port:3306, //端口号 database:`userinfo`, //数据库 multipleStatements:true //使允许用多条sql }, connection:function (sql,params,cb) { //普通封装 let db=mysql.createConnection(this.config) //创建连接 db.connect() //打开连接 db.query(sql,params,cb) db.end() }, connectionPool: function (sql,params,cb) { //连接池封装,封装用函数 let pool=mysql.createPool(this.config) pool.getConnection(function (err,conn) { //获取连接对象,后续方法 //conn,就是链接mysql的对象 //写在连接对象的回调函数, //回调函数有两个参数(err,conn) if(err){ console.log(err) } conn.query(sql,params,cb) pool.releaseConnection(conn) //释放连接,要有参数 //conn.release() 关闭连接 }) }}