node环境操作数据库

安装 mysql 模块

npm i mysql

1.导入 mysql 模块

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

2.建立 mysql 数据库的连接关系

// 2.建立 mysql 数据库的连接关系
const db = mysql.createPool({
  host: '127.0.0.1', // 数据库地址
  port: 3306, // 数据库端口号
  user: 'root', // 数据库用户名
  password: '123456', // 数据库密码
  database: 'my_db_01' // 数据库名称
})

3.测试 mysql 模块能否正常工作

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

查询表中数据

// 查询 users 表中的所有数据
const sqlStr = 'select * from users'
db.query(sqlStr, (err, results) => {
  // 查询数据失败
  if(err) return console.log(err.message)
  // 查询数据成功
  console.log(results)
})

向表中添加数据

// 向 users 表中，新增一条数据，其中 username 值为 Spider-Man ，password 值为 pcc123
const user = { username: 'Spider-Woman', password: 'pcc123456' }
// 定义待执行 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)
  // 执行成功
  if(results.affectedRows === 1) {
    console.log('添加成功！')
  }
})

添加数据的便捷方式

const user = { username: 'Spider-Woman2', password: 'pcc123456' }
// 定义待执行的 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('添加成功！')
  }
})

更新表中数据

// 更新用户信息
const user = { id: 8, 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) => {
  // 执行 sql 语句失败
  if(err) return console.log(err.message)
  // 执行成功
  if(results.affectedRows === 1) {
    console.log('更改成功！')
  }
})

更新表中数据的便捷方式

const user = { id: 8, username: 'aaa1', password: '0001' }
// 定义 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('更新成功！')
  }
})

删除数据

// 定义 SQL 语句
const sqlStr = 'delete from users where id=?'
// 执行 SQL 语句
db.query(sqlStr, 8, (err, results) => {
  if(err) return console.log(err.message)
  if(results.affectedRows === 1) {
    console.log('删除数据成功！')
  }
})

标记删除（避免真实的删除数据）

// 标记删除（避免真实的删除数据）
const sqlStr ='update users set status=? where id=?'
// 执行 SQL 语句
db.query(sqlStr, [1, 11], (err, results) => {
  // 执行失败
  if(err) return console.log(err.message)
  // 执行成功
  if(results.affectedRows === 1) {
    console.log('删除成功！')
  }
})