node操作MySQL数据库

前言

本文介绍如何在node.js中使用MySQL

安装

mysql模块是托管于npm上的第三方模块，提供Node.js中操作数据库
npm i mysql

配置Mysql

注意这里需要在MySQL中提前建好库和表，建库建表方式自行搜索

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

测试mysql模块

// 测试 mysql 模块能否正常工作
db.query('select 1', (err, results) =>{
  // mysql 模块工作期间报错了
  if(err) returnconsole.log(err.message)
  // 能够成功的执行 SQL 语句
  console.log(results)  //[ RowDataPacket { '1': 1 } ] 输出这个表示正常
})

查询表中的数据

// 查询 users 表中所有的数据
constsqlStr= 'select * from users'
db.query(sqlStr, (err, results) =>{
  // 查询数据失败
  if(err) returnconsole.log(err.message)
  // 查询数据成功
  // 注意：如果执行的是 select 查询语句，则执行的结果是数组
  console.log(results)
})

查询返回的数据是一个数组

向表中插入数据

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

便捷写法

 constuser= { username:'Spider-Man2', password:'pcc4321'}
// 定义待执行的 SQL 语句
constsqlStr= 'insert into users set ?'
// 执行 SQL 语句
db.query(sqlStr, user, (err, results) =>{
  if(err) returnconsole.log(err.message)
  if(results.affectedRows=== 1) {
    console.log('插入数据成功')
  }
})

改数据

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

便捷写法

constuser= { id:6, username:'aaaa', password:'0000'}
// 定义 SQL 语句
constsqlStr= 'update users set ? where id=?'
// 执行 SQL 语句
db.query(sqlStr, [user, user.id], (err, results) =>{
  if(err) returnconsole.log(err.message)
  if(results.affectedRows=== 1) {
    console.log('更新数据成功')
  }
})

删除

删除id为5的数据，这里传参可以不用[] ,因为只有一个参数

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

标记删除(没有真删)

使用DELETE语句，会把真正的把数据从表中剧除掉。为了保险起见，推荐使用标记删除形式，所谓的标记删除，就是在表中设置类似于status这样的状态字段，来标记当前这条数据是否被删除，当用户执行了别除的动作时，我们并没有执行DELETE语句把数据别除掉，而是执行了UPDATE语句，将这条数据对应的status字段标记为删除即可。

constsqlStr= 'update users set status=? where id=?'
db.query(sqlStr, [1, 6], (err, results) =>{
  if(err) returnconsole.log(err.message)
  if(results.affectedRows=== 1) {
    console.log('标记删除成功')
  }
})