使用Express框架操作MongoDB数据库

/*--------------------与数据库连接config(配置)文件-----------------------------*/
const Mongoose = require('mongoose');

//定义Mongodb数据库的连接字符串
const mdb_url = 'mongodb://127.0.0.1:27017/mytest';

/*3. 建立和MongoDB数据库的连接
    useNewUrlParser: 是否使用新的url转换方式,
    useUnifiedTopology: 是否使用新的用户安全策略
*/
Mongoose.connect(mdb_url,{useNewUrlParser:true,useUnifiedTopology:true});

//建立连接--连接成功触发connected事件
Mongoose.connection.on('connected',()=>{
    console.log('数据库连接成功！ 连接地址为:',mdb_url);
});
//连接异常-- 回调函数的参数中保存了异常的信息
Mongoose.connection.on('err',(err)=>{
    console.log('数据库连接异常!',err);
});

//断开连接
Mongoose.connection.on('disconnected',()=>{
    console.log('断开数据库的连接!');
});

//导出Mongoose,供dao层创建映射模型使用
module.exports = Mongoose;

（3）创建Schema，再由Schema创建Model

a、Schema：定义的是与集合对应的骨架。Schema中的属性对应的是MongoDB中集合的key

b、Model：是Schema的实例，用于操作MongoDB中的集合中的文档

关于模型名称和数据库中集合名称的对应关系

a. 数据库中没有集合：

mongoose.model(‘Blog’，BlogSchema) ==> 在模型名后加s就是集合名(不区分大小写) ==> blogs

mongoose.model(‘Blog’，BlogSchema，’blog’) ==> 第三个参数就是用户定义的集合名

b. 数据库中有集合：

mongoose.model(‘Blog’，BlogSchema，’数据库中已有的集合名’)

(4) dao层的定义

//------------------------CURD封装文件----------------------
//-----------------------dao层: 专门操作数据库的增删改查-------------

//导入模型
const Blog = require('../../model/blogModel');

//-------------封装CURD-------------------------
//-------------通过数据库映射模型,调用增删改查的方法-------------------------
const blogCrud = {
    //增加博客数据
    insertBlog: async (admin)=>{
        //创建实例
        const blog = new Blog({
            blogId:admin.c_id,
            type: admin.c_type,
            title: admin.c_title,
            content:admin.c_content,
            author:admin.c_author,
            creatAt:admin.c_time
        });
        return await blog.save();
    },

    //删除Blog
    removeBlog: async (del_id)=>{//通过id进行删除
        const result = await Blog.findOneAndRemove({blogId:del_id});

        return result;
    },
    //更新Blog
    updateBlog: async (temp)=>{
        const result = await Blog.findOneAndUpdate({blogId:temp.c_id},
            {$set:{
                    type: temp.c_type,
                    title: temp.c_title,
                    content:temp.c_content,
                }   });

        return result;
    },

    //查询所有Blog
    findAllBlog: async ()=>{
        const result = await Blog.find();
        return result;
    },

    //id自增的方法
    countAdd: async ()=>{
        const result = await Blog.count();
        return result;
    }
}

//将封装的blogCrud导出供服务层使用
module.exports = blogCrud;

（5）service服务层的定义

//---------------服务层接收(响应)前后端的数据

//导入dao层封装的crud对象导入
const blogCrud = require('../dao/crud/blogOption');

//增加blog的回调
exports.addBlog = async (req,res)=>{
    let count = 0;
    try {
        count = await blogCrud.findAllBlog().then((result)=>{
            if(result) return result[result.length-1].blogId;
        });
    }catch (e){
        console.log(e);
    }

    let admin = {
        c_id: count + 1,//保证id自增1
        c_type:req.body.cType,
        c_title:req.body.cTitle,
        c_content:req.body.cContent,
        c_author: '前端攻城狮',
        c_time: new Date(),
    }
    blogCrud.insertBlog(admin).then((data)=>{
        if(data){
            res.json({
                code:2000,
                msg:'添加成功'
            })
        }
    }).catch((e)=>{
        console.log('增加失败',e);
    });


};

//删除blog的回调
exports.delBlog = (req,res)=>{
    let del_id = req.body.del_id;
    blogCrud.removeBlog(del_id).then((data)=>{
        if(data){
            res.json({
                code:2000,
                msg:'删除成功'
            })
        }
    }).catch((e)=>{
        console.log('删除失败',e);
    })
};

//更新回调
exports.update_Blog = (req,res)=>{
    let temp = {
        c_id: req.body.cId,
        c_type:req.body.cType,
        c_title:req.body.cTitle,
        c_content:req.body.cContent,
    }
    blogCrud.updateBlog(temp).then((data)=>{
        if(data){
            res.json({
                code:2000,
                msg:'更新成功'
            })
        }
    }).catch((err)=>{
        console.log(err);
    })


};

//查询所有
exports.queryAll = (req,res)=>{
    blogCrud.findAllBlog().then((data)=>{
        if(data){
            res.json(data);
        }
    }).catch((err)=>{
        console.log(err);
    })
};

//

（6）路由接口文件的创建

//-------------------------路由中间件--------------------------
//导入创建路由的模块
const express = require('express');
const router = express.Router();

//导入服务层的api回调
const blogServices = require('../../dbmongodb/services/blogServices');

//增加接口,http://localhost:3000/blog/addBlog
router.post('/addBlog',blogServices.addBlog);

//删除接口,http://localhost:3000/blog/delBlog
router.delete('/delBlog',blogServices.delBlog);

//更新接口,http://localhost:3000/blog/updateBlog
router.post('/updateBlog',blogServices.update_Blog);

//查询所有接口,http://localhost:3000/blog/findAllBlog
router.get('/findAllBlog',blogServices.queryAll)

//导出路由器
module.exports = router;