Node中运用Mysql语句进行增改删查

导入Mysql模块

首先安装mysql模块

$ npm i mysql

然后导入mysql模块

// 导入mysql模块
const mysql = require('mysql')
// 建立与mysql数据库的连接
const db = mysql.createPool({
    // 数据库的IP地址
    host:'127.0.0.1',
    // 登录数据库的账号
    user:'root',
    // 登录数据库的密码
    password:'123456',
    // 指定要操作哪一个数据库
    database:'my_db_01',
})

对数据进行四大项操作

1.查询数据

const sql = 'select * from users'
db.query(sql,(err,results)=>{
    // err
    if(err){return console.log('出现问题--->'+err.message)}
    // 成功
    console.log("------查询成功------\n"+results+"\n-------查询结束------")
})

2.插入数据

const user = {username:'Spider-man',password:'123456'}
// 如果数据过多 sqlStr = 'insert into users (username,password) set ?'
const sqlStr = 'insert into users (username,password) values(?,?)'
// db.query(sqlStr,user,(err,results)
db.query(sqlStr,[user.username,user.password],(err,results)=>{
    if(err){return console.log('出现问题--->'+err.message)}
    // 利用affectedRows来判断是否插入数据成功
    if(results.affectedRows === 1){return console.log('------插入成功------\n'+results+'\n-------插入结束-------')}
})

3.更新数据

// 更新数据
const user = {id:1,username:'aaa',password:'000'}
// 简便方式:
// const sqlStr = 'update users set ? where id=?'
const sqlStr = 'update users set username=?,password=? where id=?'
// db.query(sqlStr,user,(err,results)=>{})
db.query(sqlStr,[user.username,user.password,user.id],(err,results)=>{
    if(err){return console.log('出现问题--->\n'+err.message)}
    if(results.affectedRows === 1){
        console.log('更新成功')
    }
})

4.删除数据

// 删除数据
const sqlStrOne = 'delete from users where id=?'
db.query(sqlStrOne,1,(err,results)=>{
    if(err){return console.log('出现问题--->\n'+err.message)}
    if(results.affectedRows === 1){
                console.log('删除成功')
            }
})
// 标记删除
const sqlStrTwo = 'update users set status=1 where id=?'
db.query(sqlStrTwo,3,(err,results)=>{
    if(err){return console.log('出现问题--->\n'+err.message)}
    if(results.affectedRows === 1){
                console.log('标记删除成功')
            }
})