要想在项目中操作数据库, 首先要安装操作 MySQL 数据库的第三方模块(mysql), 借助mysql 模块连接到 MySQL 数据库, 执行 SQL 语句,具体的流程如下图所示。
安装与配置 mysql 模块
- 安装 mysql 模块
mysql 模块是托管于 npm 上的第三方模块。它提供了在 Node.js 项目中连接和操作 MySQL 数据库的能力。 想要在项目中使用它,需要先运行如下命令,将 mysql 安装为项目的依赖包:
npm install mysql
- 配置 mysql 模块
在使用 mysql 模块操作 MySQL 数据库之前,必须先对 mysql 模块进行必要的配置,主要的配置步骤如下:
// 1.导入mysq1模块
const mysql = require('mysql')
// 2.建立与 MySQL数据库的连接
const db = mysql.createPool({
host: '127.0.0.1', //数据库的IP地址
user: 'root', //登录数据库的账号
password:‘admin123', //登录数据库的密码
database:‘my_db_01' //指定要操作哪个数据库
})
- 测试 mysql 模块能否正常工作
调用 db.query() 函数,指定要执行的 SQL 语句,通过回调函数拿到执行的结果:
//检测mysq1模块能否正常工作
db.query('SELECT 1', (err, results) => {
if (err) return console.log(err.message)
//只要能打印出[RowDataPacket{'1':1}]的结果,就证明数据库连接正常
console.log(results)
})
使用 mysql 模块操作 MySQL 数据库
- 查询数据
查询 users 表中所有的数据
//查询users表中所有的用户数据
db.query('SELECT * FROM users', (err, results) => {
//查询失败
if (err) return console.log(err.message)
//查询成功
console.log(results)
})
- 插入数据
向 users 表中新增数据, 其中 username 为 Spider-Man,password 为 pcc321。示例代码如下:
// 1. 要插入到users表中的数据对象
const user = { username: 'Spider-Man', password: 'pcc321' }
// 2. 待执行的 SQL 语句,其中英文的? 表示占位符
const sqlStr = 'INSERT INTO users (username, password) VALUES (?, ?)'
// 3. 使用数组的形式,依次为?占位符指定具体的值
db.query(sqlStr, [user.username, user.password], (err, results) =» {
if(err)return console.log(err.message)//失败
if(results.affectedRows=== 1) { console.log('插入数据成功') } // 成功
})
- 插入数据的便捷方式
向表中新增数据时,如果数据对象的每个属性和数据表的字段一一对应,则可以通过如下方式快速插入数据:
// 1. 要插入到users表中的数据对象
const (vser = { username: 'Spider-Man2', password: 'pcc4321'}
// 2. 待执行的SQL语句,其中英文的?表示占位符
const sqlStr = 'INSERT INTO users SET ?'
// 3. 直接将数据对象当作占位符的值
db.query(sqlStr, user, (err, results) => {
if(err)return console.log(err.message)//失败
if(results.affectedRows===1){console.log('插入数据成功')}//成功
})
- 更新数据
可以通过如下方式,更新表中的数据:
// 1.要更新的数据对象
const user = { id: 7, username: 'aaa', password: '000' }
// 2.要执行的SQL 语句
const sqlStr = 'UPDATE users SET username=?, password=? WHERE id=?'
// 3.调用db.query()执行 SQL 语句的同时,使用数组依次为占位符指定具体的值
db.query(sqlStr, [user.username, user.password, user.id], (err, results) => {
if(err)return console.log(err.message) // 失败
if(results.affectedRows===1){console.log('更新数据成功!')}//成功
})
- 更新数据的便捷方式
更新表数据时,如果数据对象的每个属性和数据表的字段一一对应,则可以通过如下方式快速更新表数据:
// 1. 要更新的数据对象
const user = { id: 7, username: 'aaaa', password: '0000' }
// 2. 要执行的 SQL 语句
const sqlStr = 'UPDATE users SET ? WHERE id=?'
// 3. 调用db.query()执行 SQL 语句的同时,使用数组依次为占位符指定具体的值
db.query(sqlStr,[user,user.id],(err,results) =>{
if(err)return console.log(err.message)//失败
if(results.affectedRows === 1) {console.log('更新数据成功!') } //成功
})
- 删除数据
在删除数据时,推荐根据 id 这样的唯一标识,来删除对应的数据。示例如下:
// 1.要执行的 SQL 语句
const sqlStr = 'DELETE FROM users WHERE id=?'
// 2.调用 db.query()执行 SQL语句的同时,为占位符指定具体的值
// 注意:如果SQL语句中有多个占位符,则必须使用数组为每个占位符指定具体的值
// 如果SQL语句中只有一个占位符,则可以省略数组
db.query(sqlStr, 7, (err, results) => {
if(err)return console.log(err.message)//失败
if(results.affectedRows ===1){console.log('删除数据成功!‘)}//成功
})
- 标记删除
使用 DELETE 语句,会把真正的把数据从表中删除掉。为了保险起见,推荐使用标记删除的形式,来模拟删除的动作。
所谓的标记删除,就是在表中设置类似于 status 这样的状态字段,来标记当前这条数据是否被删除。
当用户执行了删除的动作时,我们并没有执行 DELETE 语句把数据删除掉,而是执行了 UPDATE 语句,将这条数据对应的 status 字段标记为删除即可。
//标记删除:使用 UPDATE 语句替代 DELETE语句;只更新数据的状态,并没有真正删除
db.query('UPDATE USERS SET status=1 WHERE id=?', 6, (err, results) =>(
if(err)return console.log(err.message)//失败
if(results.affectedRows === 1){console.log('删除数据成功!')}//成功
})