Node.js学习笔记（四）——NodeJS访问MongoDB与MySQL数据库

庹三姐 發表於 2022-9-16 08:55:00

Node.js学习笔记（四）——NodeJS访问MongoDB与MySQL数据库

<div style="font-size: 20px; font-family: microsoft yahei">
<h1>一、MongoDB</h1>
MongoDB是开源，高性能的NoSQL数据库；支持索引、集群、复制和故障转移、各种语言的驱动程序丰富；高伸缩性； MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。 MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。
官网地址：http://www.mongodb.org/
github:https://github.com/mongodb/
API Docs：https://www.mongodb.com/docs/
nodejs驱动：https://github.com/mongodb/node-mongodb-native
文档：https://www.mongodb.com/zh-cn/docs/manual/
<h2>1.1、安装MongoDB</h2>
下载地址：https://www.mongodb.com/try/download/community
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915111345440-2133656392.png" alt="" loading="lazy">
下载成功后点击msi文件直接安装，这里以win7_64位的操作系统为例。
<h3>1.1.1、配置运行环境</h3>
新版本的MongoDB不需要复杂的配置，不需要单独安装客户端，安装完成后在桌面会找到客户端：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915113141837-413845240.png" alt="" loading="lazy">
 点击连接即可登录成功。
1)、创建存放数据的文件夹
在任意没有中文的目录下新建文件夹，如c:\data，在文件夹下存放MongoDB数据库文件与日志文件，如：
c:\data\db用于存放mongodb的数据文件
c:\data\log用于存放mongodb的日志文件
2）、创建配置文件
打开MongoDB的安装目录如“C:\Program Files\MongoDB\Server\3.4\bin”，并在此目录下新建一个mongo.config文件，文件内容如下：
<div class="cnblogs_code">
<pre>##数据库目录##
dbpath=C:\data\db

##日志输出文件##
logpath=C:\data\log\db.log</pre>
</div>
3) 、安装Windows服务
安装时添加服务：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915112121639-505023753.png" alt="" loading="lazy">
使用cmd进入命令行
使用cd切换目录到安装目录下，如：cd  C:\Program Files\MongoDB\Server\3.4\bin
安装MongoDB服务且指定配置文件，如：
mongod --config "C:\Program Files\MongoDB\Server\3.4\bin\mongo.config" --install
4)、错误处理
如果运行过程中提示“无法定位程序输入点ucrtbase.terminate于动态链接库api-ms-win-crt-runtime-|1-1-0.dll”错误，请下载安装“vc_redist.x64”，如果vc redis.x64安装失败请先下载补丁(KB2999226)再安装。
5)、添加环境变量 在计算机->右键->高级->在环境变量PATH中加入"C:\Program Files\MongoDB\Server\3.4\bin"路径。
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223135913729-1912072794.png" alt="">
6)、启动服务 在cmd窗口中运行如下命令开始服务，也可以在可以在“控制面板\所有控制面板项\管理工具\服务”手动开启，注意默认是开机就自动启动服务的，可以设置成手动启动。
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223140313932-1919444716.png" alt="">
net start mongodb
停止服务
net stop mongodb
在cmd中运行如下命令
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223140514901-1813768129.png" alt="">
这样安装就成功了！
<h3>1.1.2、运行MongoDB</h3>
1)、直接运行
如果安装完成后不想做任何配置，可以直接运行，其中mongod.exe是服务，应该先启动，如：
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223142606386-13917145.png" alt="">
启动客户端mongo.exe文件，如：
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223142658339-392177038.png" alt="">
2)、启动服务后运行
使用net start mongodb或手动启动服务器运行客户端mongo.exe文件。
3)、可视化工具
当服务启动成功后，如果认为命令行操作不方便，可以使用robomongo等GUI工具。
官网：https://robomongo.org/
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223143034901-1710922317.png" alt="">
 第二项是一个绿色版的，解压后在文件夹中找到exe文件直接运行即可。
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223144729307-73341438.png" alt="">
<h2>1.2、数据库操作</h2>
<h3>1.2.1、创建数据库与查看数据库</h3>
以下实例我们创建了数据库gomall
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915113352963-773399259.png" alt="" loading="lazy">
启动shell:
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915120458393-869352838.png" alt="" loading="lazy">
use 数据库名，如果数据库不存在则创建，使用show dbs可查看所有数据库
> use gomall   switched to db gomall > db gomall
>db.gomall.insertOne({name:"gomall"});
如果使用GUI工具在连接名称上右键create database也可以创建数据库：
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223145117698-2022423470.png" alt="">
 创建成功后如下所示：
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223145151542-639264237.png" alt="">
Collections表示集合，类似关系数据库中的表。
Functions表示函数，类似关系数据库中的存储过程与函数。
Users表示用户。
document表示记录，类似关系数据为中的记录或行。
如果你想查看所有数据库，可以使用 show dbs 命令： > show dbs
MongoDB 中默认的数据库为 test，如果你没有创建新的数据库，集合将存放在 test 数据库中。
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223145435276-514677717.png" alt="">
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915113541978-1047521.png" alt="" loading="lazy">
创建集合
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915113637388-419824623.png" alt="" loading="lazy">
使用命令行创建：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916104405770-12934492.png" alt="" loading="lazy">
<h3>1.2.2、删除数据库</h3>
> use gomall switched to db gomall > db.dropDatabase() { "dropped" : "gomall", "ok" : 1 }
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223145642948-166498178.png" alt="">
<h3>1.2.3、插入数据</h3>
a)、db.集合.insertOne(数据)
这里的数据可以是JSON
先打开shell脚本编写的界面，操作如下：
<div class="cnblogs_code">
<pre>db.movies.insertOne(
{
title: "The Favourite",
genres: [ "Drama", "History" ],
runtime: 121,
rated: "R",
year: 2018,
directors: [ "Yorgos Lanthimos" ],
cast: [ "Olivia Colman", "Emma Stone", "Rachel Weisz" ],
type: "movie"
}
)</pre>
</div>
db.products.insertOne({name:"iphone",price:1988});
从上图操作可以看出，没有去创建“products”集合，其实通过插入操作也会自动创建 _id，是mongodb自已生成的，每行数据都会存在，默认是ObjectId，可以在插入数据时插入这个键的值(支持mongodb支持的所有数据类型)　
查看数据：db.products.find({})
b)、db.表名.insertMany(数据);
<div class="cnblogs_code">
<pre>use sample_mflix
db.movies.insertMany([
{
 title: "Jurassic World: Fallen Kingdom",
 genres: [ "Action", "Sci-Fi" ],
 runtime: 130,
 rated: "PG-13",
 year: 2018,
 directors: [ "J. A. Bayona" ],
 cast: [ "Chris Pratt", "Bryce Dallas Howard", "Rafe Spall" ],
 type: "movie"
},
{
 title: "Tag",
 genres: [ "Comedy", "Action" ],
 runtime: 105,
 rated: "R",
 year: 2018,
 directors: [ "Jeff Tomsic" ],
 cast: [ "Annabelle Wallis", "Jeremy Renner", "Jon Hamm" ],
 type: "movie"
}
])</pre>
</div>
_id可以自已插入、一个表中不一定要字段都相同，虽然insert和save方法都可以插入数据，当默认的“_id”值已存在时，调用insert方法插入会报错；而save方法不会,会更新相同的_id所在行数据的信息。
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916105230089-1293722590.png" alt="" loading="lazy">
<h3>1.2.4、查询数据</h3>
a)、查询集合中所有数据：db.集合.find();
db.students.find({name:"tom"});  查找name属性为tom的数据（document）
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916105553481-601259747.png" alt="" loading="lazy">
无条件时查找所有如：
db.students.find()
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916105450719-123193584.png" alt="" loading="lazy">
b)、按条件查询（支持多条件）：db.集合.find(条件);
db.students.find({name:"tom",age:19});
对象中的条件要求同时成立
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916105714755-1054048636.png" alt="" loading="lazy">
c)、查询第一条（支持条件）：db.集合.findOne(条件);
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916110040118-942933301.png" alt="" loading="lazy">
d)、限制数量：db.集合.find().limit(数量);
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916110331252-933167568.png" alt="" loading="lazy">
e)、跳过指定数量：db.表名.find().skip(数量);
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916110427315-1080200210.png" alt="" loading="lazy">
f)、比较查询 大于：﹩gt 小于：﹩lt 大于等于：﹩gte 小于等于：﹩lte 非等于：﹩ne
db.users.find({age:{'﹩gt':9}});
查找年龄大于9且小于11岁的
db.users.find({age:{'﹩gt':9,'﹩lt':11}});
查询年龄大于17岁的学生：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916105954885-2022538617.png" alt="" loading="lazy">
g)、查询数量：db.表名.find().count();
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916110503719-1645898757.png" alt="" loading="lazy">
h)、排序：db.表名.find().sort({"字段名":1});
1：表示升序，-1：表示降序
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916110554334-1428848775.png" alt="" loading="lazy">
i)、指定字段返回： db.表名.find({},{"字段名":0});  参数1：返回 0：不返回
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916110654456-1974699310.png" alt="" loading="lazy">
更多：https://www.mongodb.com/docs/mongodb-shell/crud/read/#std-label-mongosh-read
<h3>1.2.5、修改</h3>
前面save在_id字段已存在是就是修改操作，按指定条件修改语法如下：
db.集合.update({"条件字段名":"字段值"},{﹩set:{"要修改的字段名":"修改后的字段值"}});
db.users.updateOne({age:{'﹩eq':9}},{﹩set:{age:100}});
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916145007728-672136900.png" alt="" loading="lazy">
修改多条：
db.users.updateMany({age:{"﹩gte":10}},{﹩set:{age:30}});
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916145844196-1213190208.png" alt="" loading="lazy"><img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916150512201-449618779.png" alt="" loading="lazy">
更多
<h3>1.2.6、删除</h3>
db.集合.deleteOne(条件);
db.users.deleteOne({age:{'﹩gte':10}});  删除年龄>=10岁的数据
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916150100565-2059066722.png" alt="" loading="lazy">
删除多条
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916150319752-28069085.png" alt="" loading="lazy">
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220916150520684-1300511256.png" alt="" loading="lazy">
<h1>二、NodeJS访问MongoDB</h1>
MongoDB对许多平台都提供驱动可以访问数据库，如C#、Java、Node.js等。这里以Node.js为例。
<h2>2.1、安装MongoDB访问驱动</h2>
使用包管理器，在命令行执行如下指令：
全局安装驱动
npm install mongodb -g
在当前项目中引入mongodb
npm install mongodb --save
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223155230807-1724719163.png" alt="">
这样添加驱动就成功了。
连接数据库
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");//导入依赖对象mongo客户端

let url="mongodb://127.0.0.1:27017";//数据库连接字符串

let client=new MongoClient(url);//实例化一个mongo客户端

async function run(){
try{
 await client.connect();//连接
 await client.db("nfit").command({ping:1});//向数据库nfit发送命令
 console.log("连接数据库成功！");
}
finally{
 await client.close();
}
}

run().catch(console.log);</pre>
</div>
运行结果：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220915151709643-835260045.png" alt="" loading="lazy">
注意连接关键字不允许使用localhost
<h2>2.2、添加数据</h2>
在项目的根目录下新建一个db.js文件，使用Node.js操作MongoDB。
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161223155442214-697244536.png" alt="">
示例代码：
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");//依赖MongoClient

let client=new MongoClient("mongodb://127.0.0.1:27017");//实例化一个客户端

async function run(){
try{
 let db=await client.db("nfit");//获取数据库
 let students=await db.collection("students");//获取集合，表
 let doc={id:202201,name:"tom",age:19};//将添加的数据对象
 let result=await students.insertOne(doc);//执行向数据库中添加数据并等待响应结果
 console.log(result);
}
finally{
 await client.close();//关闭数据库
 }
}

run().catch(console.log);</pre>
</div>
运行结果：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919093835709-2027709061.png" alt="" width="590" height="154" loading="lazy">
查看数据库：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919093855421-1264027293.png" alt="" width="614" height="424" loading="lazy">
添加多条数据
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");//依赖MongoClient

let client=new MongoClient("mongodb://127.0.0.1:27017");//实例化一个客户端

async function run(){
try{
 let db=await client.db("nfit");//获取数据库
 let students=await db.collection("students");//获取集合，表
 let docs=[{id:202202,name:"rose",age:17},{id:202203,name:"mark",age:18}];//将添加的数据对象
 let result=await students.insertMany(docs);//执行向数据库中添加数据并等待响应结果
 console.log(result);
}
finally{
 await client.close();//关闭数据库
 }
}

run().catch(console.log);</pre>
</div>
运行结果：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919094142362-1315595234.png" alt="" width="605" height="202" loading="lazy">
 
 <img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919094200941-1488982422.png" alt="" loading="lazy">
更多
<h2>2.3、修改数据</h2>
示例代码：
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");
let client=new MongoClient("mongodb://127.0.0.1:27017");

async function run(){
try{
 let db=await client.db("nfit"); //获取数据库
 let students=await db.collection("students");//获取集合
 let filter={id:202201};//要更新的数据的过滤条件
 let result=await students.updateOne(filter,{$set:{name:"汤姆"}});//执行更新单条数据
 console.log(result);
}
finally{
 await client.close();//关闭
 }
}

run().catch(console.log);</pre>
</div>
运行结果：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919095258119-230537965.png" alt="" loading="lazy">
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919095310701-159021645.png" alt="" loading="lazy">
 更多
<h2>2.4、查询数据</h2>
<h3>2.4.1、查询单条记录</h3>
示例代码：
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");
let client=new MongoClient("mongodb://127.0.0.1:27017");

async function run(){
try{
 let db=await client.db("nfit"); //获取数据库
 let students=await db.collection("students");//获取集合

 let filter={id:202201};//过滤条件
 let obj=await students.findOne(filter);//根据过滤条件查找单条数据
 console.log(obj);
}
finally{
 await client.close();//关闭
 }
}

run().catch(console.log);</pre>
</div>
运行结果：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919095731065-1775743838.png" alt="" width="552" height="189" loading="lazy">
<h3>2.4.2、查询多条记录</h3>
直接输出
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");
let client=new MongoClient("mongodb://127.0.0.1:27017");

async function run(){
try{
 let db=await client.db("nfit"); //获取数据库
 let students=await db.collection("students");//获取集合

 let query={id:{$gte:202201}};//查询条件是id大于等于202201
 let cursor=await students.find(query);//执行查询并返回游标对象

 let result=[];//学生数组，返回包装用

 await cursor.forEach(data=>result.push(data));//遍历游标，取出数据

 console.log(result);
}
finally{
 await client.close();//关闭
 }
}

run().catch(console.log);</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919100514052-72896382.png" alt="" width="755" height="705" loading="lazy">
返回结果
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");
let client=new MongoClient("mongodb://127.0.0.1:27017");

async function run(){
try{
 let db=await client.db("nfit"); //获取数据库
 let students=await db.collection("students");//获取集合

 let query={id:{$gte:202201}};//查询条件是id大于等于202201
 let cursor=await students.find(query);//执行查询并返回游标对象

 let result=[];//学生数组，返回包装用

 await cursor.forEach(data=>result.push(data));//遍历游标，取出数据

 return result;
}
finally{
 await client.close();//关闭
 }
}

run().then(console.log).catch(console.log);</pre>
</div>
更多
<h2>2.5、删除数据</h2>
 示例代码：
<div class="cnblogs_code">
<pre>const { MongoClient } = require("mongodb");
let client=new MongoClient("mongodb://127.0.0.1:27017");

async function run(){
try{
 let db=await client.db("nfit"); //获取数据库
 let students=await db.collection("students");//获取集合
 let filter={id:202201};//要删除的数据的过滤条件
 let result= await students.deleteOne(filter);//执行删除
 console.log(result);
}
finally{
 await client.close();//关闭
 }
}

run().catch(console.log);</pre>
</div>
运行结果：
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919103341553-850906461.png" alt="" loading="lazy">
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220919103409141-981773200.png" alt="" width="655" height="364" loading="lazy">
<h1>三、Nodejs访问MySQL</h1>
<h2>3.1、导入mysql模块</h2>
 1、打开根目录，打开终端，初始化执行npm init -y； 
2、导入mysql模块: npm i mysql;
<h2>3.2、访问数据库</h2>
示例以gomall数据库中的student数据库为例
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220914141953458-35257013.png" alt="" width="876" height="731" loading="lazy">
<h3>3.2.1、连接并查询</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query("select id,name,sex from student",(err,results)=>{//执行查询
 if(err) throw err;//如果有错误，则抛出异常
 console.log(JSON.parse(JSON.stringify(results)));//转换并输出查询结果
 conn.release();//释放连接
 });
});</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920090814945-522868261.png" alt="" width="635" height="232" loading="lazy">
<h3>3.2.2、带参数查询</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query("select id,name,sex from student where sex=?",['boy'],(err,results)=>{//执行查询
 if(err) throw err;//如果有错误，则抛出异常
 console.log(JSON.parse(JSON.stringify(results)));//转换并输出查询结果
 conn.release();//释放连接
 });
});</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920091127767-1637690373.png" alt="" width="492" height="172" loading="lazy">
<h3>3.2.3、新增数据</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

let sql="insert into student(name,sex) values(?,?)";
pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query(sql,['tom','boy'],(err,results)=>{//执行添加，指定参数
 if(err) throw err;//如果有错误，则抛出异常
 console.log(results);//输出结果
 conn.release();//释放连接
 });
});</pre>
</div>
结果
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920092635617-252600636.png" alt="" width="591" height="309" loading="lazy">
<h3>3.2.4、便捷增加</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

let sql="insert into student set ?";
let student={name:"rose",sex:"girl"};
pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query(sql,student,(err,results)=>{//执行添加，指定参数对象
 if(err) throw err;//如果有错误，则抛出异常
 console.log(results);//输出结果
 conn.release();//释放连接
 //process.exit(1);//关闭应用
 });
});</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920093149170-1210089110.png" alt="" width="540" height="262" loading="lazy">
<h3>3.2.5、更新数据</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

let sql="update student set name=?,sex=? where id=?";
pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query(sql,['mark','boy',34],(err,results)=>{//执行更新，指定参数
 if(err) throw err;//如果有错误，则抛出异常
 console.log(results);//输出结果
 conn.release();//释放连接
 });
});</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920093534537-1788637486.png" alt="" width="549" height="205" loading="lazy">
<h3>3.2.6、便捷更新数据</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

let sql="update student set ? where id=?";
let student={name:"jone",sex:'boy'};
pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query(sql,,(err,results)=>{//执行更新，指定参数
 if(err) throw err;//如果有错误，则抛出异常
 console.log(results);//输出结果
 conn.release();//释放连接
 });
});</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920094007368-383809394.png" alt="" width="683" height="305" loading="lazy">
<h3>3.2.7、删除数据</h3>
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

let sql="delete from student where id=?";
pool.getConnection((connErr,conn)=>{//获取连接对象
pool.query(sql,,(err,results)=>{//执行查询
 if(err) throw err;//如果有错误，则抛出异常
 if(results.affectedRows===1){//如果影响行数为1
 console.log("删除成功");
 }
 else{
 console.log("删除失败");
 }
 conn.release();//释放连接
 });
});</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920094332918-1135662243.png" alt="" width="553" height="101" loading="lazy">
 访问数据库脚本如下：
<div class="cnblogs_code">
<pre>const mysql=require("mysql");

const pool=mysql.createPool({
host:"localhost",
user:"root",
password:"123456",
database:"gomall",
port:3306
});

//查询
pool.query("select * from student",(err,results)=>{
results=JSON.parse(JSON.stringify(results));
results.forEach((stu,index)=>{
 console.log(stu.id,stu.name,stu.sex);
});
});

//增加
let sql="insert into student(name,sex) values(?,?)";
pool.query(sql,['rose','girl'],(err,results)=>{
if(err) throw err;
if(results.affectedRows===1){
 console.log("增加成功！");
}
});

//便捷增加
sql="insert into student set ?";
let student={name:"mark",sex:"boy"};
pool.query(sql,student,(err,results)=>{
if(err) throw err;
if(results.affectedRows===1){
 console.log("便捷增加成功！");
}
});

//修改
sql="update student set name=? where id=?";
pool.query(sql,['lili',26],(err,results)=>{
if(err) throw err;
if(results.affectedRows===1){
 console.log("修改成功！");
}
});

//便捷修改
sql="update student set ? where id=?";
student={name:"mark1",sex:"girl"};
pool.query(sql,,(err,results)=>{
if(err) throw err;
if(results.affectedRows===1){
 console.log("便捷修改成功！");
}
});

//删除
sql="delete from student where id=?";
pool.query(sql,[25],(err,results)=>{
if(err) throw err;
if(results.affectedRows===1){
 console.log("删除成功！");
}
});</pre>
</div>
释放连接：
<div class="cnblogs_code">
<pre>//查询
pool.getConnection((err,conn)=>{
pool.query("select * from student",(err,results)=>{
 results=JSON.parse(JSON.stringify(results));
 results.forEach((stu,index)=>{
 console.log(stu.id,stu.name,stu.sex);
 });
 conn.release();
 process.exit(1);
});
});</pre>
</div>
参考脚本
<div class="cnblogs_code">
<pre>// 1.导入mysql模块
const mysql = require('mysql')

// 2.建立和MySQL数据库的联系
const db = mysql.createPool({
host: '127.0.0.1', //数据库的ip地址
user: 'root', //登录数据库的账号
password: 'hoshi1234', //登录数据库的密码
datebase: 'my_dv_01' //指定要操作那个数据库
})

// 3.测试mysql模块是否正常工作
db.query('select 1',(err, results) => {
// mysql工作期间报错了
if(err) return console.log(err.message);

// 能够正常执行SQL语句
 console.log(results);
// 返回 [ RowDataPacket { '1': 1 } ]
})

// 4.查询 users 表中所有数据
const sqlStr = 'select * from my_dv_01.users'
db.query(sqlStr ,(err, results) => {
// mysql工作期间报错了
if(err) return console.log(err.message);

// 能够正常执行SQL语句
 console.log(results);
// 返回 users表的字段
})

// 5.插入数据到 users 表中

// 要插入到表中的数据
const user = { usersname: 'benben', password:'886886' }

// 待执行的 SQL语句，英文问号 ? 代表占位符(SQL语法)
const sqlStr2 = 'insert into users (usersname, password) VALUES (?,?)'

// 使用数组的形式，依次为 ? 占位符指定具体的位置
db.query(sqlStr2, ,(err, results) => {
 // mysql工作期间报错了
 if(err) return console.log(err.message);

 // 如果执行的是insert into这个插入语句，则results是一个对象
 // 可以通过results.affectedRows判断是否成功
 if(results.affectedRows === 1) {
 console.log('插入数据成功');
 // 打开MySQL的users表格也能看到新数据
 // 当前数据只有4条，本条数据id为什么是5？
 // 因为之前有过4的数据，但是被删除了，id具有唯一性，删除了也不能被其他数据使用
 }
})

// 插入数据的便捷方式
const user = { usersname: 'niuniu', password:'000000' }

// 定义待执行的 SQL 语句
const sqlStr = 'insert into my_dv_01.users set ?'

// 执行 SQL 语句
db.query(sqlStr, user,(err, results) => {

 if(err) return console.log(err.message);
 if(results.affectedRows === 1) {
 console.log('插入数据成功');
 }
})

// 如何更新用户的信息（UPDATE 语句用于更新表中已存在的记录）

// 要插入到表中的数据
const user = { id: 6, usersname: '犇犇', password:'000111' }

// 定义SQL语句
const sqlStr = 'update my_dv_01.users set usersname=?, password=? where id=?'

// 执行SQL语句
db.query(sqlStr,, (err, results) => {
if(err) return console.log(err.message);
if(results.affectedRows === 1) {
 console.log('插入数据成功');
}
})

// 更新用户信息的便捷方式（数据对象的每个属性和字段一一对应的情况下可使用）
const user = { id: 6, usersname: '夸夸牛', password:'000111' }

// 定义SQL语句
const sqlStr = 'update my_dv_01.users set ? where id=?'

// 执行SQL语句
db.query(sqlStr,, (err, results) => {
if(err) return console.log(err.message);
if(results.affectedRows === 1) {
 console.log('插入数据成功');
}
})

// 删除数据
// 定义SQL语句
const sqlStr = 'delete from my_dv_01.users where id=?'

// 执行SQL语句
// SQL语句中有多个占位符，则必须使用数组为每个占位符指定具体的值
// 如果只有一个占位符，则可以省略数组
db.query(sqlStr,5,(err,results) => {
if(err) return console.log(err.message);
 if(results.affectedRows === 1) {
 console.log('删除数据成功');
 }
})

// 标记删除
// 使用delete语句会把数据真正删除掉，非常危险，一般情况下推荐使用标记删除，类似于修改status字段的状态，比如更新成1表示删除；

// 定义SQL语句
const sqlStr = 'update my_dv_01.users set status=? where id=?'

// 执行SQL语句
db.query(sqlStr,,(err, results) => {
if(err) return console.log(err.message);
 if(results.affectedRows === 1) {
 console.log('标记删除成功');
 }
})</pre>
</div>
</div>
<h2>3.3、封装代码</h2>
从上面的示例中可以看出，访问数据库的代码存在许多的重复，为了便于维护与扩展可以将数据库访问代码封装起来。
mysqlutil.js
<div class="cnblogs_code">
<pre>const mysql=require("mysql");//依赖mysql模块

//创建连接池对象
let pool=mysql.createPool({
host:"localhost",//主机
user:"root",//用户名
password:"123456",//密码
database:"gomall"//数据库,port可以省去
});

function query(sql,param){
return new Promise((resolve,reject)=>{
 pool.getConnection((connErr,conn)=>{//获取连接对象
 pool.query(sql,param||[],(err,results)=>{//执行sql
 try{
 if(err) reject(err);
 resolve(JSON.parse(JSON.stringify(results)));
 }
 finally{
 conn.release();//释放连接
 }
 });
 });
});
}

module.exports={query};</pre>
</div>
测试代码：
<div class="cnblogs_code">
<pre>const mysqlutil=require("./mysqlutil");//导入mysql工具模块

//查询所有
//mysqlutil.query("select * from student").then(console.log).catch(console.log);
//查询并带参数
//mysqlutil.query("select * from student where id=?",).then(console.log).catch(console.log);

//执行更新
let sql="update student set ? where id=?";
let student={name:"张二",sex:"girl"};
//mysqlutil.query(sql,).then(console.log).catch(console.log);

async function findAll(){
try{
 let result= await mysqlutil.query("select * from student");
 return result;
 }
catch(err){
 throw err;
}
}

findAll().then(console.log);</pre>
</div>
<img src="https://img2022.cnblogs.com/blog/63651/202209/63651-20220920103812313-1131628340.png" alt="" width="713" height="397" loading="lazy">
<h1>四、视频</h1>
【Node.js学习总结_张果】 https://www.bilibili.com/video/BV1WW411B78S?share_source=copy_web&vd_source=475a31f3c5d6353a782007cd4c638a8a
<h1>五、作业</h1>
6.1、完成一个图书管理的功能，图书包含（编号，名称，作者，图片，价格），实现：
a)、使用Node.js+Express+Axios+RESTful+MongoDB+Vue技术实现
c)、使用Node.js+Express+Axios+Rest+MySQL+Vue技术实现
页面不一定要完全一样，可以使用UI框架。
<img src="https://images2015.cnblogs.com/blog/63651/201612/63651-20161230140932101-1105720214.png" alt="" class="medium-zoom-image"> 
来源：https://www.cnblogs.com/best/p/16422421.html

頁: [1]

琼殿技术论坛's Archiver

Node.js学习笔记（四）——NodeJS访问MongoDB与MySQL数据库