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

一、MongoDB

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

1.1、安装MongoDB

下载地址：https://www.mongodb.com/try/download/community

下载成功后点击msi文件直接安装，这里以win7_64位的操作系统为例。

1.1.1、配置运行环境

新版本的MongoDB不需要复杂的配置，不需要单独安装客户端，安装完成后在桌面会找到客户端：

 点击连接即可登录成功。

1)、创建存放数据的文件夹

在任意没有中文的目录下新建文件夹，如c:data，在文件夹下存放MongoDB数据库文件与日志文件，如：

c:datadb用于存放mongodb的数据文件

c:datalog用于存放mongodb的日志文件

2）、创建配置文件

打开MongoDB的安装目录如“C:Program FilesMongoDBServer3.4bin”，并在此目录下新建一个mongo.config文件，文件内容如下：

代码语言：javascript复制

##数据库目录##
dbpath=C:datadb

##日志输出文件##
logpath=C:datalogdb.log

3) 、安装Windows服务

安装时添加服务：

使用cmd进入命令行

使用cd切换目录到安装目录下，如：cd  C:Program FilesMongoDBServer3.4bin

安装MongoDB服务且指定配置文件，如：

mongod --config "C:Program FilesMongoDBServer3.4binmongo.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 FilesMongoDBServer3.4bin"路径。

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工具。

官网：https://robomongo.org/

 第二项是一个绿色版的，解压后在文件夹中找到exe文件直接运行即可。

1.2、数据库操作

1.2.1、创建数据库与查看数据库

以下实例我们创建了数据库gomall

启动shell:

use 数据库名，如果数据库不存在则创建，使用show dbs可查看所有数据库

> use gomall   switched to db gomall > db gomall

>db.gomall.insertOne({name:"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脚本编写的界面，操作如下：

代码语言：javascript复制

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(数据);

代码语言：javascript复制

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.students.find({name:"tom"});  查找name属性为tom的数据（document）

无条件时查找所有如：

db.students.find()

b)、按条件查询（支持多条件）：db.集合.find(条件);

db.students.find({name:"tom",age:19});

对象中的条件要求同时成立

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}});

查询年龄大于17岁的学生：

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.updateOne({age:{'﹩eq':9}},{﹩set:{age:100}});

修改多条：

db.users.updateMany({age:{"﹩gte":10}},{﹩set:{age:30}});

更多

1.2.6、删除

db.集合.deleteOne(条件);

db.users.deleteOne({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

这样添加驱动就成功了。

连接数据库

代码语言：javascript复制

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。

示例代码：

代码语言：javascript复制

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、修改数据

示例代码：

代码语言：javascript复制

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、查询单条记录

示例代码：

代码语言：javascript复制

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、查询多条记录

代码语言：javascript复制

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、删除数据

 示例代码：

代码语言：javascript复制

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数据库为例

 访问数据库脚本如下：

代码语言：javascript复制

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("删除成功！");
    }
});

释放连接：

代码语言：javascript复制

//查询
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);
    });
});

参考脚本

代码语言：javascript复制

// 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框架。

https 网络安全 mongodb 数据库 sql

0 人点赞