Node.js学习笔记（四）——NodeJS访问MongoDB与MySQL数据库
作者：互联网
一、MongoDB
MongoDB是开源，高性能的NoSQL数据库；支持索引、集群、复制和故障转移、各种语言的驱动程序丰富；高伸缩性；
MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。
MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。
github:https://github.com/mongodb/
API Docs：https://www.mongodb.com/docs/
nodejs驱动：https://github.com/mongodb/node-mongodb-native
1.1、安装MongoDB
下载地址：https://www.mongodb.com/try/download/community
下载成功后点击msi文件直接安装，这里以win7_64位的操作系统为例。
1.1.1、配置运行环境
新版本的MongoDB不需要复杂的配置，不需要单独安装客户端，安装完成后在桌面会找到客户端：
点击连接即可登录成功。
1)、创建存放数据的文件夹
在任意没有中文的目录下新建文件夹，如c:\data，在文件夹下存放MongoDB数据库文件与日志文件，如：
c:\data\db用于存放mongodb的数据文件
c:\data\log用于存放mongodb的日志文件
2）、创建配置文件
打开MongoDB的安装目录如“C:\Program Files\MongoDB\Server\3.4\bin”，并在此目录下新建一个mongo.config文件，文件内容如下：
##数据库目录## dbpath=C:\data\db ##日志输出文件## logpath=C:\data\log\db.log
3) 、安装Windows服务
安装时添加服务：
使用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"路径。
6)、启动服务
在cmd窗口中运行如下命令开始服务，也可以在可以在“控制面板\所有控制面板项\管理工具\服务”手动开启，注意默认是开机就自动启动服务的，可以设置成手动启动。
net start mongodb
停止服务
net stop mongodb
在cmd中运行如下命令
这样安装就成功了！
1.1.2、运行MongoDB
1)、直接运行
如果安装完成后不想做任何配置，可以直接运行，其中mongod.exe是服务，应该先启动，如：
启动客户端mongo.exe文件，如：
2)、启动服务后运行
使用net start mongodb或手动启动服务器运行客户端mongo.exe文件。
3)、可视化工具
当服务启动成功后，如果认为命令行操作不方便，可以使用robomongo等GUI工具。
第二项是一个绿色版的，解压后在文件夹中找到exe文件直接运行即可。
1.2、数据库操作
1.2.1、创建数据库与查看数据库
以下实例我们创建了数据库gomall
启动shell:
> use gomall
switched to db gomall
> db
gomall
如果使用GUI工具在连接名称上右键create database也可以创建数据库：
创建成功后如下所示：
Collections表示集合，类似关系数据库中的表。
Functions表示函数，类似关系数据库中的存储过程与函数。
Users表示用户。
document表示记录，类似关系数据为中的记录或行。
如果你想查看所有数据库，可以使用 show dbs 命令：
> show dbs
MongoDB 中默认的数据库为 test，如果你没有创建新的数据库，集合将存放在 test 数据库中。
创建集合
1.2.2、删除数据库
> use gomall
switched to db gomall
> db.dropDatabase()
{ "dropped" : "gomall", "ok" : 1 }
1.2.3、插入数据
a)、db.集合.insertOne(数据)
这里的数据可以是JSON
先打开shell脚本编写的界面，操作如下：
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"
}
)
db.products.insertOne({name:"iphone",price:1988});
从上图操作可以看出，没有去创建“products”集合，其实通过插入操作也会自动创建
_id，是mongodb自已生成的，每行数据都会存在，默认是ObjectId，可以在插入数据时插入这个键的值(支持mongodb支持的所有数据类型)
查看数据：db.products.find({})
b)、db.表名.insertMany(数据);
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"
}
])
_id可以自已插入、一个表中不一定要字段都相同，虽然insert和save方法都可以插入数据，当默认的“_id”值已存在时，调用insert方法插入会报错；而save方法不会,会更新相同的_id所在行数据的信息。
1.2.4、查询数据
a)、查询集合中所有数据：db.集合.find();
db.users.find({name:'zhangguo0'});
b)、按条件查询（支持多条件）：db.集合.find(条件);
db.users.find({name:'zhangguo0',age:9});
对象中的条件要求同时成立
c)、查询第一条（支持条件）：db.集合.findOne(条件);
d)、限制数量：db.集合.find().limit(数量);
e)、跳过指定数量：db.表名.find().skip(数量);
f)、比较查询
大于：gt
小于：﹩lt
大于等于：﹩gte
小于等于：﹩lte
非等于：﹩ne
db.users.find({age:{'﹩gt':9}});
查找年龄大于9且小于11岁的
db.users.find({age:{'﹩gt':9,'﹩lt':11}});
g)、查询数量：db.表名.find().count();
h)、排序：db.表名.find().sort({"字段名":1});
1：表示升序，-1：表示降序
i)、指定字段返回： db.表名.find({},{"字段名":0}); 参数1：返回 0：不返回
更多：https://www.mongodb.com/docs/mongodb-shell/crud/read/#std-label-mongosh-read
1.2.5、修改
前面save在_id字段已存在是就是修改操作，按指定条件修改语法如下：
db.集合.update({"条件字段名":"字段值"},{﹩set:{"要修改的字段名":"修改后的字段值"}});
db.users.update({age:{'﹩eq':9}},{﹩set:{age:100}});
修改多条：
db.users.updateMany({age:{"﹩gte":10}},{﹩set:{age:30}});
1.2.6、删除
db.集合.remove(条件);
db.users.remove({age:{'﹩gte':10}}); 删除年龄>=10岁的数据
二、NodeJS访问MongoDB
MongoDB对许多平台都提供驱动可以访问数据库，如C#、Java、Node.js等。这里以Node.js为例。
2.1、安装MongoDB访问驱动
使用包管理器，在命令行执行如下指令：
全局安装驱动
npm install mongodb -g
在当前项目中引入mongodb
npm install mongodb --save
这样添加驱动就成功了。
连接数据库
const { MongoClient } = require("mongodb");
let url="mongodb://127.0.0.1:27017";
let client=new MongoClient(url);
async function run()
{
try{
await client.connect();
await client.db("gomall").command({ping:1});
console.log("连接服务器成功！");
}finally{
await client.close();
}
}
run().catch(console.dir);
2.2、添加数据
在项目的根目录下新建一个db.js文件，使用Node.js操作MongoDB。
示例代码：
const { MongoClient } = require("mongodb");
let url="mongodb://127.0.0.1:27017";
let client=new MongoClient(url);
async function run()
{
try{
let db=await client.db("gomall");
let students=db.collection("students");
let doc={id:202204,name:"lili"};
const result=await students.insertOne(doc);
console.log(result);
}finally{
await client.close();
}
}
run().catch(console.dir);
运行结果：
查看数据库：
2.3、修改数据
示例代码：
const { MongoClient } = require("mongodb");
let url="mongodb://127.0.0.1:27017";
let client=new MongoClient(url);
async function run()
{
try{
let db=await client.db("gomall");
let students=db.collection("students");
let filter={id:202204,name:"lili"};
const result=await students.updateOne(filter,{$set:{name:"mali"}});
console.log(result);
}finally{
await client.close();
}
}
run().catch(console.dir);
运行结果：
2.4、查询数据
2.4.1、查询单条记录
示例代码：
const { MongoClient } = require("mongodb");
let url="mongodb://127.0.0.1:27017";
let client=new MongoClient(url);
async function run()
{
try{
let db=await client.db("gomall");
let students=db.collection("students");
let query={id:202204};
let result=await students.findOne(query);
console.log(result);
}finally{
await client.close();
}
}
run().catch(console.dir);
运行结果：
2.4.2、查询多条记录
const { MongoClient } = require("mongodb");
let url="mongodb://127.0.0.1:27017";
let client=new MongoClient(url);
async function run()
{
try{
let db=await client.db("gomall");
let students=db.collection("students");
let query={id:{$gte:202203}};
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.dir);
2.5、删除数据
示例代码：
const { MongoClient } = require("mongodb");
let url="mongodb://127.0.0.1:27017";
let client=new MongoClient(url);
async function run()
{
try{
let db=await client.db("gomall");
let students=db.collection("students");
let query={id:202204};
let result= await students.deleteOne(query);
console.log(result);
}finally{
await client.close();
}
}
run().catch(console.dir);
运行结果：
四、Nodejs访问MySQL
4.1、导入mysql模块
1、打开根目录，打开终端，初始化执行npm init -y；
2、导入mysql模块: npm i mysql;
4.2、访问数据库
示例以gomall数据库中的student数据库为例
访问数据库脚本如下：
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,[student,26],(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("删除成功！");
}
});
参考脚本
// 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, [user.usersname , user.password],(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,[user.usersname, user.password, user.id], (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,[user, user.id], (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,[1, 3],(err, results) => {
if(err) return console.log(err.message);
if(results.affectedRows === 1) {
console.log('标记删除成功');
}
})
五、示例下载
git：https://coding.net/u/zhangguo5/p/NodeJS002/git
六、作业
6.1、完成一个图书管理的功能，图书包含（编号，名称，作者，图片，价格），实现：
a)、使用Node.js+Express+Axios+RESTful+MongoDB+Vue技术实现
c)、使用Node.js+Express+Axios+Rest+MySQL+Vue技术实现
页面不一定要完全一样，可以使用UI框架。
标签：Node,console,log,err,NodeJS,MongoDB,db,results,let 来源： https://www.cnblogs.com/best/p/16422421.html