SpringBoot使用MongoDB

一、什么是MongoDB

MongoDB是一个基于分布式文件存储的数据库，由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。

MongoDB是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。它支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型。Mongo最大的特点是它支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

二、MongoDB的安装和配置

1.下载安装包

访问这个地址下载对应的安装包https://www.mongodb.com/download-center#community。

以window版本为例，双击mongodb-win32-x86_64-3.4.15-signed.exe文件，除了路径改为其他盘符外其他默认就可以了，然后电脑里会多个mongodb的目录。

以管理员的身份运行cmd，进入对应的bin目录，输入命令

mongod --dbpath D:datadb --logpath D:logmongodb.log --logappend --install --serviceName "MongoDB"

前提是你的电脑存在D:datadb和D:log，如果没有就自己先创建一个。先启动服务MongoDB再双击mongo.exe。如图则表示安装成功。

其他系统的安装步骤和使用可以参考菜鸟教程

三、整合SpringBoot

1.用idea新建项目时勾选mongodb就可以了，对应的pom是

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

2.在application.properties文件中添加配置：

spring.data.mongodb.uri=mongodb://127.0.0.1:27017/test?maxPoolSize=256

总的格式是：

mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]

这里因为没有开启安全认证（整了好久都没弄好。。），所以不需要输入用户名和密码。

3.代码编写，我们直接使用框架提供的mongoTemplate就可以了，但如果是spring框架的话还需要在xml文件中进行一些配置。

Person实体类

package cn.sp.bean;

import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

import java.io.Serializable;
import java.util.Date;

/**
 * @author ship
 * @Description
 * @Date: 2018-07-04 14:15
 */
//@Data  lombok虽然好用但隐藏了好多坑啊,@RequestBody注解获取不到pId的值
@Document(collection = "personInfo")
public class Person implements Serializable{
    @Id
    @Field("p_id")
    private int pId;
    private String name;
    private int  age;
    private Date  birthday;

    public int getpId() {
        return pId;
    }

    public void setpId(int pId) {
        this.pId = pId;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }
}

PersonDao接口

package cn.sp.dao;

import cn.sp.bean.Person;

/**
 * @author ship
 * @Description
 * @Date: 2018-07-04 14:17
 */
public interface PersonDao {

    /**
     * 插入
     * @param person
     */
    void insert(Person person);

    /**
     * 更新文档
     * @param person
     */
    void update(Person person);

    /**
     * 删除文档
     * @param pId
     */
    void delete(int pId);

    /**
     * 查询文档
     * @param pId
     * @return
     */
    Person findByPId(int pId);
}

实现类

package cn.sp.dao.Impl;

import cn.sp.bean.Person;
import cn.sp.dao.PersonDao;
import com.mongodb.client.result.DeleteResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Service;

/**
 * @author ship
 * @Description
 * @Date: 2018-07-04 14:17
 */
@Service("personDao")
public class PersonDaoImpl implements PersonDao{

    @Autowired
    private MongoTemplate mongoTemplate;


    @Override
    public void insert(Person person) {
        mongoTemplate.insert(person);
    }

    @Override
    public void update(Person person) {
        Query query = new Query(Criteria.where("_id").is(person.getpId()));
        Update update = new Update()
                            .set("name",person.getName())
                            .set("age",person.getAge())
                            .set("birthday",person.getBirthday());
        //更新查询返回结果集的第一条
        mongoTemplate.updateFirst(query,update,Person.class);
    }

    @Override
    public void delete(int pId) {
        DeleteResult result = mongoTemplate.remove(new Query(Criteria.where("_id").is(pId)), Person.class);
    }

    @Override
    public Person findByPId(int pId) {
        return mongoTemplate.findOne(new Query(Criteria.where("_id").is(pId)), Person.class);
    }
}

controller层

package cn.sp.controller;

import cn.sp.bean.Person;
import cn.sp.dao.PersonDao;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

/**
 * @author ship
 * @Description
 * @Date: 2018-07-04 15:25
 */
@RestController
@RequestMapping("person")
public class TestController {

    @Resource
    private PersonDao personDao;


    @PostMapping("add")
    public String addPerson(@RequestBody Person person){
        System.out.println("插入数据：" + person.toString());
        personDao.insert(person);
        return "ok";
    }

    @GetMapping("/{pId}")
    public Person find(@PathVariable int pId){
        return personDao.findByPId(pId);
    }

    @DeleteMapping("/{pId}")
    public String remove(@PathVariable int pId){
        personDao.delete(pId);
        return "ok";
    }

    @PostMapping("update")
    public String update(@RequestBody Person person){
        personDao.update(person);
        return "ok";
    }
}

请大家注意实体上的注解，@Document(collection = "personInfo")将会在文档数据库中创建一个personInfo的集合，@Id表示指定该字段为主键， @Field("")表示实体字段存在MongoDB中的字段名称是什么。

根据MongoDB官方文档介绍，如果在插入数据时没有指定主键，MongoDB会自动给插入行自动加上一个主键_id，MongoDB客户端把这个id类型称为ObjectId，看上去就是一个UUID。我们可以通过注解自己设置主键类型，但是根据实践，_id名称是无法改变的。@Id和 @Field("p_id")表面看上去是我想创建一个p_id为主键的表，但是实际主键只有_id而没有p_id。当然，主键的类型不一定非要是UUID，可以是你自己根据业务生成的唯一流水号等等。

四、测试总结

分别使用postman（没用过的自己去下载）请求四个接口完成CURD操作，同时使用命令行查看数据情况。

use test

db.personInfo.find().pretty()

总的来说使用起来还是挺方便的，但是@Data注解自动生成getset方法有个坑，它会弄成setPId()和getPId()，如果是手动生成就是setpId()和getpId()。导致前端传来的json字符串转对象的时候pId这个属性一直是0，获取不到值。

之前也发现类似的坑，比如isValid，注解生成的就变成setValid()和getValid()。

参考链接：https://www.cnblogs.com/jeffwongishandsome/p/spring-boot-integrate-mongodb-practise.html

代码地址：https://github.com/2YSP/mongodb_demo

关于mongodb3.X开启安全认证的部分:http://www.yangbajing.me/2016/01/11/mongodb-3-x-%E7%94%A8%E6%88%B7%E8%AE%A4%E8%AF%81/