Node.js学习之路23——Node.js利用mongoose连接mongodb数据库

Node.js利用mongoose连接mongodb数据库

• 代码组织结构

|---|根目录
|---|---|connect.js(mongoose测试连接)
|---|---|user.js(定义user数据表)
|---|---|operate.js(定义mongodb的增删改查功能)
|---|---|login.js(Node后台调用operate.js文件的方法处理数据)

1. 引入mongoose测试连接

• 该文件为connect.js

1.1 代码部分

const mongoose = require("mongoose");
const DB_URL = "mongodb://127.0.0.1:27017/infos";
mongoose.Promise = global.Promise;
mongoose.connect(DB_URL, { useMongoClient: true });
mongoose.connection.on("connected", () => {
    console.log("mongodb数据库连接成功")
});
mongoose.connection.on("error", (error) => {
    console.log("mongodb数据库连接失败", error)
});
module.exports = mongoose;

1.2 代码分析

1.2.1 引入mongoose模块

• const mongoose = require("mongoose");

1.2.2 获取mongodb的本机地址

• const DB_URL = "mongodb://127.0.0.1:27017/infos";
• 127.0.0.1是本地IP地址
• 27017是mongodb的服务启动端口

• infos是mongodb的一个数据集合名字

  • mongodb可以有很多数据集合，每个集合中可以有很多数据表。
  • 类比一下：你有一个巨型停车场(mongodb)，里边分了不同的停车区(集合，这里的infos)，每个停车区可以停很多车((下文提到的user)，相当于每个数据集合里边可以有很多张数据表)。

• 如果需要给mongodb加上用户及密码，可以这样

  • const DB_URL = "mongodb://username:[email protected]:27017/infos";
  • 其中username为用户名，中间英文:，password为密码，其余不变

1.2.3 连接数据库成功

• mongoose.connection.on("connected", callback())
• 数据库连接成功后，会在控制台输出mongodb数据库连接成功

1.2.4 连接数据库失败

• mongoose.connection.on("error", callback())
• 数据库连接成功后，会在控制台输出mongodb数据库连接失败和错误信息

1.2.5 导出mongoose模块

• module.exports = mongoose;

2. 定义每张数据表的字段

• 该文件为user.js

2.1 代码介绍

const mongoose = require('mongoose');
const db = require('./connect.js');
const userSchema = new mongoose.Schema({
    number: { type: Number},
    email: { type: String },
    password: { type: String },
    rePassword: { type: String },
    mobile: { type: String },
    question: { type: String },
    answer: { type: String },
});
let userModel = db.model('user', userSchema);
module.exports = userModel;

2.2 代码分析

2.2.1 引入mongoose模块

• const mongoose = require("mongoose");

2.2.1 引入连接mongodb数据库的模块

• const db = require('./connect.js');

2.2.2 定义Schema

• const userSchema = new mongoose.Schema({})
• 通过mongoose对象的Schema属性创建一个Schema对象

• Schema所能够拥有的数据类型有以下几个

  • String
  • Number
  • Date
  • Buffer
  • Boolean
  • Mixed
  • ObjectId
  • Array

• 字段介绍，以Number字段为例

  • type是该字段的数据类型
  • default是该字段的默认值
  • 还有很多其他的属性，以及可以自定义属性

2.2.3 确认数据表和该数据表的字段

• let userModel = db.model('user', userSchema);
• 定义一个数据表userModel
• 使用db.model方法，第一个参数是数据表的名字，第二个参数是该数据表使用的Schema

2.2.4 最终导出定义的数据表

• module.exports = userModel;
• 导出之后，在operate.js中使用这个对象的mongodb的增删改查方法

3. 定义mongodb的增删改查功能

3.1 代码部分

• 该文件为operate.js

let userModel = require('./user.js');
module.exports = {
    save(data) {
        return new Promise((resolve, reject) => {
            userModel.create(data, (err, docs) => {
                if (err) {
                    rejct(err);
                } else {
                    resolve(docs);
                }
            })
        })
    },
    find(data = {}, fields = null, options = {}) {
        return new Promise((resolve, reject) => {
            //model.find(需要查找的对象(如果为空，则查找到所有数据), 属性过滤对象[可选参数], options[可选参数], callback)
            userModel.find(data, fields, options, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    findOne(data) {
        return new Promise((resolve, reject) => {
            //model.findOne(需要查找的对象,callback)
            userModel.findOne(data, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    findById(data) {
        return new Promise((resolve, reject) => {
            //model.findById(需要查找的id对象 ,callback)
            userModel.findById(data, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    update(conditions, update) {
        return new Promise((resolve, reject) => {
            //model.update(查询条件,更新对象,callback)
            userModel.update(conditions, update, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    },
    remove(conditions) {
        return new Promise((resolve, reject) => {
            //model.update(查询条件,callback)
            userModel.remove(conditions, (error, doc) => {
                if (error) {
                    reject(error)
                } else {
                    resolve(doc)
                }
            })
        })
    }
};

3.2 代码分析

• 引入user模块
• let userModel = require('../models/users');
• 引入该文件的目的是，让userModel这个数据表直接的调用mongodb的各种方法

4. 后台直接使用operate处理数据

• 该文件为login.js

4.1 代码部分

const express = require('express');
const router = express.Router();
let operate = require('./operate');
router.post('/', function (req, res, next) {
    let param = {};
    param.email = req.body.email;
    param.password = req.body.password;
    console.log(param);
    operate.save(param).then(result => {
        if (result) {
            res.json({
                data: result,
                success: true
            })
        } else {
            res.json({
                data: result,
                success: false
            })
        }
    });
});
module.exports = router;

4.2 代码分析

• 需要熟练使用Express的router方法
• 引入Express，定义一个post方法
• post方法传递的对象数据挂在在req.body上
• 直接调用operate.save()方法，传递param对象参数
• 获取到返回结果result，对获取到的结果进行进一步处理