express操作mysql数据库实现增删改查

1. 引入mysql模块并连接数据库

// 引入mysql模块
const mysql = require("mysql")
// 连接数据库
const db = mysql.createPool({
    host:'127.0.0.1',
    user:'root',
    password:'root',
    database:'test'
})

2.测试连接

// 测试连接
db.query("select 1",(err,result)=>{
     if(err) return console.log(err.message)
     console.log(result);
 })

3.查询所有数据

// 查询所有数据
 let sql = "select * from stu "
 db.query(sql,(err,result)=>{
     if(err) return console.log(err.message)
     console.log(result);
 })

4. 根据条件查询数据

// 根据条件查询数据
 let sql = "select * from stu where id = ? "
 let params = {id:1}
 db.query(sql,[params.id],(err,result)=>{
     if(err) return console.log(err.message)
     console.log(result);
 })

5. 添加数据 （添加指定字段）根据受影响的行数来判断是否添加成功

// 添加数据
 let sql = "insert into stu (username,age) values(?,?) "
 let params = {username:"老李",age:21}
 db.query(sql,[params.username,params.age],(err,result)=>{
     if(err) return console.log(err.message)
     if (result.affectedRows === 1) console.log("添加成功");
 })

6. 添加的便捷方式（如果添加的是所有字段）

let sql = "insert into stu set ? "
let params = {id:null,username:"老白",age:22}
db.query(sql,params,(err,result)=>{
    if(err) return console.log(err.message)
    if (result.affectedRows === 1) console.log("添加成功");
 })

7. 修改

let sql = "update stu set username = '大明' where id = ? "
let params = {id:1}
db.query(sql,[params.id],(err,result)=>{
     if(err) return console.log(err.message)
     if (result.affectedRows === 1) console.log("修改成功");
 })

8.修改的便捷方式 多个条件可以放到一个对象中

let sql = "update stu set ? where id = ? "
let params = {username:'小王'}
db.query(sql,[params,2],(err,result)=>{
    if(err) return console.log(err.message)
    if (result.affectedRows === 1) console.log("修改成功");
})

9. 删除

let sql = "delete from  stu  where id = ? "
let params = {id:1}
db.query(sql,[params.id],(err,result)=>{
     if(err) return console.log(err.message)
     if (result.affectedRows === 1) console.log("删除成功");
 })