nodejs搭配什么数据库（nodejs操作MySQL数据库）

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-Man 
 
 
 
 
 
 
 
 
 
 
 
 
 ，password 为 pcc321
 


 


 


 


 


 


 

。示例代码如下：

// 向 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(插入数据成功!) } })

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-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: 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(标记删除成功) } })