Node.js如何在项目中操作MySQL

npm install mysql

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

//测试mysql能否正常工作
db.query('SELECT 1',(err,results)=>{
    if(err) return console.log(err.message)
    //能够成功的执行SQL语句
    console.log(results)
})

db.query('SELECT * FROM STUDENT',(err,results)=>{
    //查询失败
    if(err) return console.log(err.message)
    //查询成功
    console.log(results)
})

//要插入到student表中的数据对象
const student = {cname:'小延',age:16}
//待执行的SQL语句，其中英文的？表示占位符
const sqlStr = 'INSERT INTO student(cname,age)VALUES(?,?)'
//使用数组的形式，依次为占位符指定具体的值
db.query(sqlStr,[student.cname,student.age],(err,results)=>{
    if(err) return console.log(err.message) //失败
    if(results.affectedRows === 1){
        console.log('插入成功') //成功
    }
})

//要插入到student表中的数据对象
const student = {cid:9,cname:'小杨',age:18,class_id:1002}
//待执行的SQL语句，其中英文的？表示占位符
const sqlStr = 'INSERT INTO student SET ?'
//直接将数据对象当做占位符的值
db.query(sqlStr,student,(err,results)=>{
    if(err) return console.log(err.message) //失败
    if(results.affectedRows === 1) console.log('插入数据成功！')
})

//要更新的数据对象
const student = {cid: 8, cname: '小欣', age: 18, class_id: 1002}
//要执行的SQL语句
const sqlStr = 'UPDATE student SET cname=?,age=?,class_id=? WHERE cid=?'
//调用db.query()执行SQL语句的同时，使用数组依次为占位符指定具体的值
db.query(sqlStr,[student.cname,student.age,student.class_id],(err,results)=>{
    if(err) return console.log(err.message) //失败
    if(results.affectedRows === 1) {
        console.log('更新数据成功！')
    }
})

const student = {cid:1,cname:'小钰',age:17,class_id:1003}
//要执行的SQL语句
const sqlStr = 'UPDATE student SET ? WHERE cid=?'
调用db.query()执行SQL语句的同时，使用数组依次为占位符指定具体的值
db.query(sqlStr,[student,student.cid],(err,results)=>{
    if(err) return console.log(err.message) //失败
    if(results.affectedRows === 1){
        console.log('数据更新成功！')  //成功
    }
})

//要执行的SQL语句
const sqlStr = 'DELETE FROM student WHERE cid=?'
//调用db.query()执行sql语句的同时，为占位符指定确定的值
db.query(sqlStr,3,(err,results)=>{
    if(err) return console.log(err.message)
    if(results.affectedRows === 1){  // 失败
        console.log('删除数据成功！') //成功
    }
})

//标记删除:使用UPDATE语句代替DELETE语句；只更新数据的状态，并没有真正删除。
db.query('UPDATE student SET class_id=? WHERE cid=?',[1000,6],(err,results)=>{
    if(err) return console.log(err.message)
    if(results.affectedRows === 1){  // 失败
        console.log('标记删除成功！') //成功
    }
})