使用node的mysql模块操作MySQL数据库

配置mysql模块
1、打开根目录，打开终端，初始化执行npm init -y；
2、下载mysql: npm i mysql;

操作数据库
1、导入mysql模块；
2、建立和MySQL数据库的联系
3、测试mysql模块是否正常工作
4、查询 users 表中所有数据
5、插入数据到 users 表中
6、修改用户信息
7、删除用户信息

// 1.导入mysql模块
const mysql = require('mysql')

// 2.建立和MySQL数据库的联系
const db = mysql.createPool({
    host: '127.0.0.1', //数据库的ip地址
    user: 'root', //登录数据库的账号
    password: 'hoshi1234', //登录数据库的密码
    datebase: 'my_dv_01' //指定要操作那个数据库
})

// 3.测试mysql模块是否正常工作
db.query('select 1',(err, results) => {
    // mysql工作期间报错了
    if(err) return console.log(err.message);

    // 能够正常执行SQL语句
    console.log(results);
    // 返回 [ RowDataPacket { '1': 1 } ]
})


// 4.查询 users 表中所有数据
const sqlStr = 'select * from my_dv_01.users'
db.query(sqlStr ,(err, results) => {
    // mysql工作期间报错了
    if(err) return console.log(err.message);

    // 能够正常执行SQL语句
    console.log(results);
    // 返回 users表的字段
})


// 5.插入数据到 users 表中

// 要插入到表中的数据
const user = { usersname: 'benben', password:'886886' }

// 待执行的 SQL语句 ，英文问号 ? 代表占位符(SQL语法)
const sqlStr2 = 'insert into users (usersname, password) VALUES (?,?)'

// 使用数组的形式，依次为 ? 占位符指定具体的位置
db.query(sqlStr2, [user.usersname , user.password],(err, results) => {
        // mysql工作期间报错了
        if(err) return console.log(err.message);

        // 如果执行的是insert into这个插入语句，则results是一个对象
        // 可以通过results.affectedRows判断是否成功
        if(results.affectedRows === 1) {
            console.log('插入数据成功');
            // 打开MySQL的users表格也能看到新数据
            // 当前数据只有4条，本条数据id为什么是5？
            // 因为之前有过4的数据，但是被删除了，id具有唯一性，删除了也不能被其他数据使用
        }
})


// 插入数据的便捷方式
const user = { usersname: 'niuniu', password:'000000' }

// 定义待执行的 SQL 语句
const sqlStr = 'insert into my_dv_01.users set ?'

// 执行 SQL 语句
db.query(sqlStr, user,(err, results) => {
        
        if(err) return console.log(err.message);
        if(results.affectedRows === 1) {
            console.log('插入数据成功');
        }
})


// 如何更新用户的信息（UPDATE 语句用于更新表中已存在的记录）

// 要插入到表中的数据
const user = { id: 6, usersname: '犇犇', password:'000111' }

// 定义SQL语句
const sqlStr = 'update my_dv_01.users set usersname=?, password=? where id=?'

// 执行SQL语句
db.query(sqlStr,[user.usersname, user.password, user.id], (err, results) => {
    if(err) return console.log(err.message);
    if(results.affectedRows === 1) {
        console.log('插入数据成功');
    }
})

// 更新用户信息的便捷方式（数据对象的每个属性和字段一一对应的情况下可使用）
const user = { id: 6, usersname: '夸夸牛', password:'000111' }

// 定义SQL语句
const sqlStr = 'update my_dv_01.users set ? where id=?'

// 执行SQL语句
db.query(sqlStr,[user, user.id], (err, results) => {
    if(err) return console.log(err.message);
    if(results.affectedRows === 1) {
        console.log('插入数据成功');
    }
})


// 删除数据
// 定义SQL语句
const sqlStr = 'delete from my_dv_01.users where id=?'

// 执行SQL语句
// SQL语句中有多个占位符，则必须使用数组为每个占位符指定具体的值
// 如果只有一个占位符，则可以省略数组
db.query(sqlStr,5,(err,results) => {
    if(err) return console.log(err.message);
        if(results.affectedRows === 1) {
            console.log('删除数据成功');
        }
})


// 标记删除
// 使用delete语句会把数据真正删除掉，非常危险，一般情况下推荐使用标记删除，类似于修改status字段的状态，比如更新成1表示删除；

// 定义SQL语句
const sqlStr = 'update my_dv_01.users set status=? where id=?'

// 执行SQL语句
db.query(sqlStr,[1, 3],(err, results) => {
    if(err) return console.log(err.message);
            if(results.affectedRows === 1) {
                console.log('标记删除成功');
            }
})