nodejs操作MySQL数据库

阿里云国内75折 回扣 微信号：monov8
阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6

1、操作数据库的步骤

  • 安装操作 MySQL 数据库的第三方模块mysql
  • 通过 mysql 模块连接到 MySQL 数据库
  • 通过 mysql 模块执行 SQL 语句

 

2、安装与配置 mysql 模块

2.1、安装 mysql 模块

  • mysql 模块是托管于 npm 上的第三方模块。它提供了在 Node.js 项目中连接和操作 MySQL 数据库的能力。
  • 想要在项目中使用它需要先运行如下命令将 mysql 安装为项目的依赖包
npm install mysql

2.2、配置 mysql 模块

        在使用 mysql 模块操作 MySQL 数据库之前必须先对 mysql 模块进行必要的配置主要的配置步骤如下

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

2.3、测试 mysql 模块能否正常工作

调用 db.query() 函数指定要执行的 SQL 语句通过回调函数拿到执行的结果

// 测试 mysql 模块能否正常工作
 db.query('select 1', (err, results) => {
  // mysql 模块工作期间报错了就进入这个if判断语句打印这个错误信息
  if(err) return console.log(err.message)
  // 只要能打印出 [ RowDataPacket { '1' : 1} ]的结果就证明数据库连接正常
  console.log(results)
})

3、使用 mysql 模块操作 MySQL 数据库

3.1、查询数据

查询 users 表中所有的数据

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

3.2、插入数据

向 users 表中新增数据 其中 username 为 Spider-Manpassword 为 pcc321。示例代码如下

// 向 users 表中新增一条数据其中 username 的值为 Spider-Manpassword 的值为 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('插入数据成功!')
  }
})

3.3、插入数据的便捷方式

        向表中新增数据时如果数据对象的每个属性和数据表的字段一一对应则可以通过如下方式快速插入数据

// 演示插入数据的便捷方式
 const user = { username: 'Spider-Man2', 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('插入数据成功')    // 成功
  }
})

3.4、更新数据

可以通过如下方式更新表中的数据

// 演示如何更新用户的信息
 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('更新成功')
  }
})

3.5、更新数据的便捷方式

        更新表数据时如果数据对象的每个属性和数据表的字段一一对应则可以通过如下方式快速更新表数据

// 演示更新数据的便捷方式
 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('更新数据成功')
  }
})

3.6、删除数据

在删除数据时推荐根据 id 这样的唯一标识来删除对应的数据。示例如下

// 删除 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('删除数据成功')
  }
})

3.7、标记删除

  • 使用 DELETE 语句会把真正的把数据从表中删除掉。为了保险起见推荐使用标记删除的形式来模拟删除的动作。
  • 所谓的标记删除就是在表中设置类似于 status 这样的状态字段来标记当前这条数据是否被删除。
  • 当用户执行了删除的动作时我们并没有执行 DELETE 语句把数据删除掉而是执行了 UPDATE 语句将这条数据对应的 status 字段标记为删除即可。
// 标记删除使用update 语句代替 delete 语句只更新数据的状态并没有真正删除
const sqlStr = 'update users set status=? where id=?'
db.query(sqlStr, [1, 6], (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('标记删除成功')
  }
})

3.8、完整示例代码

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

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

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

// 向 users 表中新增一条数据其中 username 的值为 Spider-Manpassword 的值为 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: 'Spider-Man2', 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('插入数据成功')
  }
}) */

// 演示如何更新用户的信息
/* 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('更新数据成功')
  }
}) */

// 删除 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('删除数据成功')
  }
}) */

// 标记删除
const sqlStr = 'update users set status=? where id=?'
db.query(sqlStr, [1, 6], (err, results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows === 1) {
    console.log('标记删除成功')
  }
})
阿里云国内75折 回扣 微信号：monov8
阿里云国际，腾讯云国际，低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号：monov8 飞机：@monov6
标签: mysqlNodeJS数据库
返回列表

上一篇：Vue3【项目中引入Pinia、组合式API风格、核心概念（State、修改状态、Getters、Actions） 】(十四)-全面详解（学习总结---从入门到深化）

下一篇：npm 设置淘宝镜像、nrm、nodemon-CSDN博客

“nodejs操作MySQL数据库” 的相关文章

图书管理系统 数据库课程实验设计1年前 (2023-02-02)
头歌MySQL数据库实训答案 有目录1年前 (2023-02-02)
MySQL面试题整理-四年经验1年前 (2023-02-02)
Oracle数据库系统安全加固1年前 (2023-02-02)
MySQL的锁机制：MyISAM 表锁、InnoDB行锁1年前 (2023-02-02)
jsp文化活动系统Myeclipse开发mysql数据库web结构java编程计算机网页项目1年前 (2023-02-02)
用真实业务场景告诉你，高并发下如何设计数据库架构？1年前 (2023-02-02)
数据库面试题1年前 (2023-02-02)
达梦数据库导入dmp文件1年前 (2023-02-02)
命令行客户端MySQL的使用Python解释器详解实现代理池的API模块1年前 (2023-02-02)

阿里云国际版