1. 首先导入mysql模块 建立与自己的数据库的连接关系

// 1. 导入 mysql 模块
const mysql = require('mysql')
// 2. 建立与 MySQL 数据库的连接关系

//数据库信息以明文的方式展示是很危险的 我们可以通过dotenv来实现全局隐式管理
//安装读取环境变量的插件 npm install dotenv
//有两种方式来配置
//1.在系统环境变量中配置
//变量名：DBPWD   //一般都大写
//变量值：root

//2.在文件目录中新建一个.env的文件
//DB_HOST=127.0.0.1
//DB_USER=root
//DB_NAME=zq_db_01
//require("dotenv").config();
const db = mysql.createPool({
  host: process.env.DB_HOST, // 数据库的 IP 地址
  user: process.env.DB_USER, // 登录数据库的账号
  password: process.env.DBPWD, // 登录数据库的密码
  database: process.env.DB_NAME, // 指定要操作哪个数据库
})

2. 测试mysql是否能正常工作

db.query('select 1', (err, results) => {
  // mysql 模块工作期间报错了
  if(err) return console.log(err.message)
  // 能够成功的执行 SQL 语句
  console.log(results)
})

3. 查询

// 查询 users 表中所有的数据  如果要查询特有的字段 可以它替代* 
const sqlStr = 'select * from users' 
db.query(sqlStr, (err, results) => {
  // 查询数据失败
  if (err) return console.log(err.message)
  // 查询数据成功
  // 注意：如果执行的是 select 查询语句，则执行的结果是数组
  console.log(results)
})

4. 插入

//向 users 表中，新增一条数据，其中 username 的值为 Spider-Man，password 的值为 pcc123
const user = { username: 'Spider-Man', password: 'pcc123' }
// 定义待执行的 SQL 语句
const sqlStr = 'insert into users (username, password) values (?, ?)'
// 执行 SQL 语句
db.query(sqlStr, [user.username, user.password], (err, results) => {
  // 执行 SQL 语句失败了
  if (err) return console.log(err.message)
  // 成功了
  // 注意：如果执行的是 insert into 插入语句，则 results 是一个对象
  // 可以通过 affectedRows 属性，来判断是否插入数据成功
  if (results.affectedRows === 1) {
    console.log('插入数据成功!')
  }
})

// 演示插入数据的便捷方式
const user = { username: 'Supperman', password: 'pcc4321' }
// 定义待执行的 SQL 语句
const sqlStr = 'insert into users set ?'
// 执行 SQL 语句
db.query(sqlStr, user, (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('插入数据成功')
  }
})

5. 更新

// 演示如何更新用户的信息
const user = { id: 6, username: 'aaa', password: '000' }
// 定义 SQL 语句
const sqlStr = 'update users set username=?, password=? where id=?'
// 执行 SQL 语句
db.query(sqlStr, [user.username, user.password, user.id], (err, results) => {
  if (err) return console.log(err.message)
  // 注意：执行了 update 语句之后，执行的结果，也是一个对象，可以通过 affectedRows 判断是否更新成功
  if (results.affectedRows === 1) {
    console.log('更新成功')
  }
})

// 演示更新数据的便捷方式
const user = { id: 6, username: 'aaaa', password: '0000' }
// 定义 SQL 语句
const sqlStr = 'update 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('更新数据成功')
  }
})

6. 删除

// 删除 id 为 6 的用户
const sqlStr = 'delete from users where id=?'
db.query(sqlStr, 6, (err, results) => {
  if (err) return console.log(err.message)
  // 注意：执行 delete 语句之后，结果也是一个对象，也会包含 affectedRows 属性
  if (results.affectedRows === 1) {
    console.log('删除数据成功')
  }
})

// 标记删除  真正把数据删除是非常危险的 我们可以用一个字段来表示0表示正常 1表示删除 通常用status表示
const sqlStr = 'update users set status=? where id=?'
db.query(sqlStr, [1, 7], (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('标记删除成功')
  }
})