#3 mongoose 基本使用

mongoose连接mongodb

创建Schema和model

var mongoose = require('mongoose');

var Schema = mongoose.Schema;

var BookSchema = new Schema({
    title: String,
    author: String,
    year: Number
});

//mongoose.model 创建一个 Schema 的实例
module.exports = mongoose.model('Book', BookSchema);

连接到MongoDB

var connection = mongoose.connection;

# 这个是数据库地址
var db = 'mongodb://james:123456@localhost:27017/example';

// 连接
mongose.connect(db);

// 连接后的事件 这里主要用来表示是否成功连接到数据库
connection.on('connected', function() {
  console.log('Mongoose 连接到 example数据库');
}) 
connection.once('open', function(callback){
    console.log('数据库启动了');
    // app.listen(8080, () => console.log('Express server listening on port 8080'));
})

实例操作

数据库的操作通常就是 create | remove | update | delete， 也就是常说的 '增删改查'。

1.创建数据模型

// Book.model.js
var mongoose = require('mongoose')
var Schema = mongoose.Schema

// Schema相当于数据骨架
var BookSchema = new Schema({
    title: {
      type: String,
      required: true
    },
    author: String,
    category: String
    //publishDate: {
    //  type: Date,
    //  default: Date.now
    //} 
});

// mongoose.model 表示实例化Schema
module.exports = mongoose.model('Book', BookSchema);

关于 schema的类型定义， mongoose doc

2.操作数据

使用 'express','body-parser'

// app.js
var express = require('express');
var app = express();
var bodyParser = require('body-parser'); // 获取URL中的参数
var mongoose = require('mongoose');
var Book = require('./Book.model');


app.use(bodyParser.json()); // 用来解析json数据格式
// extended 布尔值的含义
// true: 表示使用 'querystring' 库来解析 url-encoded 数据
// false: 表示使用 'qs' 库来解析
app.use(bodyParser.urlencoded({
    extended: true
}));

// example 为 数据库名
var db_url = 'mongodb://james:123456@localhost:27017/example';

// 连接mongodb
mongoose.connect(db_url);

mongoose.connection.on('connected', function() {
    console.log('Mongoose connection  open to example');
})
mongoose.connection.on('error', function(err) {
    console.log('Mongoose connection error ' + err);
})
mongoose.connection.once('open', function(callback){
    console.log('数据库启动了');
    // app.listen(8080, () => console.log('Express server listening on port 8080'));
})

var port = 8080;

app.get('/', function(req, res) {
    res.send('hello');
})

// get请求 查询数据 find()
app.get('/books', function(req, res) {
    console.log('getting all books');
    Book.find({})
        .exec(function(err, books) {
            if (err) {
                console.log('err',err);
                res.send('error has occured');
            } else {
                res.json(books);
                console.log(books);
            }
        })
})

// get请求 查询数据 findOne()
app.get('/books/:id', function(req, res) {
    console.log('get one book');
    Book.findOne({  // 查询单个
        _id: req.params.id
    })
    .exec(function(err, book) {
        console.log('get one book');
        if (err) {
            res.send(err);
        } else {
            res.json(book);
            console.log('get book')
        }
    })
})

// post请求 新增一条数据 save
// 此处使用表单的形式，（使用 'x-www-form-urlencoded'）将参数添加到url中
// 然后使用postman 模拟表单提交
app.post('/book', function(req, res) {
    // 实例化一个文档对象
    var newBook = new Book();
    // 使用bodyParser对url参数进行解析
    newBook.title = 'req.body.title';
    newBook.author = req.body.author;
    newBook.category = req.body.category;

    newBook.save(function(err, book) {
        if (err) {
            res.send(err);
        } else {
            console.log(book);
            res.send(book);
        }
    });
});

// 'put'请求 修改数据 findByIdAndUpdate
app.put('/book/:id', function(req, res) {
    Book.findByIdAndUpdate(req.params.id, 
        {$set: { title: req.body.title }},
        {new: true},
        function(err, book) {
            if (err) {
                res.send(err);
            } else {
                res.send(book);
            }
        }
    )
});

// 'delete'请求 删除数据 findOneAndRemove
app.delete('/book/:id', function(req, res) {
    Book.findOneAndRemove({
        _id: req.params.id,
    }, function(err, book) {
        if (err) {
            console.log(err);
            res.send(err);
        } else {
            console.log(book);
            res.send(book);
        }
    })
})


app.listen(port, function() {
    console.log('app listening on port ' + port);
})

mongoose对数据库的操作函数和MongoDB类似，这个查看官方文档即可。

另外postman 模拟请求：

postman模拟post请求.png

mongoose 使用 promise

因为mongoose内置的promise库已经是废弃状态，我们可以使用 bluebird 等promise库让mongoose支持promise

// 安装bluebird步骤已省略
// 使mongoose支持promise写法
mongoose.Promise = require('bluebird');

// 然后可以使用promise风格书写代码
// get请求 查询数据 findOne()
app.get('/books/:id', function(req, res) {
    console.log('get one book');
    Book.findOne({  // 查询单个
        _id: req.params.id
    })
    .exec(function(err, book) {
        console.log('get one book');
        if (err) {
            res.send(err);
        } else {
            res.json(book);
            console.log('get book')
        }
    })
})

// 可以改写为
// get请求 查询数据 findOne()
app.get('/books/:id', function(req, res) {
    console.log('get one book');
    Book.findOne({  // 查询单个
        _id: req.params.id
    })
    .exec()
    then(function(book) {
        res.json(book)
    })
    .catch(err => res.send(err))
})

扩展阅读

1. body-parser的用法