连接MySQL数据库
// 引入 mysql
const mysql =require('mysql');
// 连接数据库的方法
// 配置数据库。暴露出来
module.exports={
// 数据库配置
config:{
host:'localhost',
port:'3306',
user:'exapp',
password:'123456',
database:'exapp'
},
// 连接数据库,选择连接池的方式
// 连接池的对象
//sql 语句 ，sqlArr数组， calkback回调函数
sqlConnect:function(sql,sqlArr,calklback){
//连接数据库
var pool=mysql.createPool(this.config);
pool.getConnection((err,conn)=>{
console.log('连接成功');
if(err){
console.log('连接失败');
return;
}
// 事件驱动回调
conn.query(sql,sqlArr,calklback);
// 释放链接
conn.release();
})
}
}
添加数据
var express = require('express');
var router = express.Router();
//引入连接数据库
var dbConfig=require('../util/dbconfig')
/* GET home page. */
router.get('/', function(req, res, next) {
//sql语句
var sql="INSERT INTO cate(name,status,create_time) VALUES(?,?,?)";
//数据
var sqlArr=['菜鸟工具', '啥子','23453', '2020-08-31T04:21:33.000Z'];
var callback=function(err,data){
if(err){
console.log("失败");
return;
}
else{
res.send(data);
}
};
// 调用函数
dbConfig.sqlConnect(sql,sqlArr,callback);
// res.render('index', { title: 'Express' });
});
module.exports = router;
