Spring Boot集成MongoDB

• MongoDB回顾

2. MongoDB是一个基于分布式文件存储的数据库，它是一个介于关系数据库和非关系数据库之间的产品，
3. 其主要目标是在键/值存储方式（提供了高性能和高度伸缩性）和传统的RDBMS系统（具有丰富的功能）之间架起一座桥梁，
4. 它集两者的优势于一身。
6. MongoDB支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型，
7. 也因为他的存储格式也使得它所存储的数据在Nodejs程序应用中使用非常流畅。
9. 既然称为NoSQL数据库，Mongo的查询语言非常强大，其语法有点类似于面向对象的查询语言，
10. 几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。
12. 但是，MongoDB也不是万能的，同MySQL等关系型数据库相比，它们在针对不同的数据类型和事务要求上都存在自己独特的优势。
13. 在数据存储的选择中，坚持多样化原则，选择更好更经济的方式，而不是自上而下的统一化。
15. 较常见的，我们可以直接用MongoDB来存储键值对类型的数据，如：验证码、Session等；由于MongoDB的横向扩展能力，
16. 也可以用来存储数据规模会在未来变的非常巨大的数据，如：日志、评论等；
17. 由于MongoDB存储数据的弱类型，也可以用来存储一些多变json数据，如：与外系统交互时经常变化的JSON报文。
18. 而对于一些对数据有复杂的高事务性要求的操作，如：账户交易等就不适合使用MongoDB来存储。

• 引入MongoDB依赖

1. <dependency>
2.    <groupId>org.springframework.boot</groupId>
3.    <artifactId>spring-boot-starter-data-mongodb</artifactId>
4. </dependency>

• MongoDB的配置【application.properties】
  

1. # MONGODB (MongoProperties)
2. # Mongo database URI. When set, host and port are ignored.
3. #spring.data.mongodb.uri=mongodb://root:root@localhost:27017/mongotest
4. # Mongo server host.
5. spring.data.mongodb.host=localhost
6. # Mongo server port.
7. spring.data.mongodb.port=27017
8. # Login user of the mongo server.
9. spring.data.mongodb.username=root
10. # Login password of the mongo server.
11. spring.data.mongodb.password=root
12. # Authentication database name.
13. spring.data.mongodb.authentication-database=mongotest
14. # Database name
15. spring.data.mongodb.database=mongotest
16. # Fully qualified name of the FieldNamingStrategy to use.
17. #spring.data.mongodb.field-naming-strategy=
18. # GridFS database name.
19. #spring.data.mongodb.grid-fs-database=
20. # Enable Mongo repositories.
21. spring.data.mongodb.repositories.enabled=true
22. # Mongo database URI. When set, host and port are ignored.
23. #spring.data.mongodb.uri=mongodb://localhost/test

• MongoDB的POJO
  

1. package com.newcapec.dao.domain;
3. import org.springframework.data.annotation.Id;
5. /**
6. * @version V1.0
7. * @Title: Mongo实体
8. * @ClassName: com.newcapec.dao.domain
9. * @Description:
10. * @author: FLY
11. * @date:2017/10/178:06
12. */
13. publicclassUserMongoDo {
15.    //id属性是给mongodb用的，用@Id注解修饰
16.    @Id
17.    private String id;
19.    private String name;
21.    privateint age;
23.    public String getId() {
24.        return id;
25.    }
27.    publicvoidsetId(String id) {
28.        this.id = id;
29.    }
31.    public String getName() {
32.        return name;
33.    }
35.    publicvoidsetName(String name) {
36.        this.name = name;
37.    }
39.    publicintgetAge() {
40.        return age;
41.    }
43.    publicvoidsetAge(int age) {
44.        this.age = age;
45.    }
47.    @Override
48.    publicbooleanequals(Object o) {
49.        if (this == o) {
50.            returntrue;
51.        }
52.        if (o == null || getClass() != o.getClass()) {
53.            returnfalse;
54.        }
56.        UserMongoDothat= (UserMongoDo) o;
58.        if (age != that.age) {
59.            returnfalse;
60.        }
61.        if (id != null ? !id.equals(that.id) : that.id != null) {
62.            returnfalse;
63.        }
64.        return name != null ? name.equals(that.name) : that.name == null;
65.    }
67.    @Override
68.    publicinthashCode() {
69.        intresult= id != null ? id.hashCode() : 0;
70.        result = 31 * result + (name != null ? name.hashCode() : 0);
71.        result = 31 * result + age;
72.        return result;
73.    }
75.    @Override
76.    public String toString() {
77.        return"UserMongoDo{" +
78.                "id='" + id + '\'' +
79.                ", name='" + name + '\'' +
80.                ", age=" + age +
81.                '}';
82.    }
83. }

• MongoDB的DAO层【需要继承MongoRepository接口】

1. package com.newcapec.dao.repository.mongo;
3. import com.newcapec.dao.domain.UserMongoDo;
4. import org.springframework.data.mongodb.repository.MongoRepository;
6. /**
7. * @version V1.0
8. * @Title: Mongo--DAO层的接口
9. * @ClassName: com.newcapec.dao.repository.mongo
10. * @Description: 继承自MongoRepository接口，MongoRepository接口包含了常用的CRUD操作，
11. * 例如：save、insert、findall等等。我们可以定义自己的查找接口，
12. * @author: FLY
13. * @date:2017/10/178:09
14. */
15. publicinterfaceUserMongoRepositoryextendsMongoRepository<UserMongoDo,String> {
16.    UserMongoDo findByName(String name);
17. }

• MongoDB的Controller层

1. package com.newcapec.controller.mongo;
3. import com.newcapec.dao.domain.UserMongoDo;
4. import com.newcapec.dao.repository.mongo.UserMongoRepository;
5. import io.swagger.annotations.Api;
6. import io.swagger.annotations.ApiOperation;
7. import org.slf4j.Logger;
8. import org.slf4j.LoggerFactory;
9. import org.springframework.beans.factory.annotation.Autowired;
10. import org.springframework.data.mongodb.core.MongoTemplate;
11. import org.springframework.web.bind.annotation.RequestMapping;
12. import org.springframework.web.bind.annotation.RequestMethod;
13. import org.springframework.web.bind.annotation.RestController;
15. import java.util.List;
17. /**
18. * @version V1.0
19. * @Title:
20. * @ClassName: com.newcapec.controller.mongo
21. * @Description:
22. * @author: FLY
23. * @date:2017/10/178:21
24. */
25. @Api(value = "MONGO服务", description = "基本的MONGO增删改查API")
26. @RestController
27. @RequestMapping(value = "/mongo")
28. publicclassUserMongoController {
30.    privatefinalLoggerlogger= LoggerFactory.getLogger(this.getClass());
32.    @Autowired
33.    private UserMongoRepository userMongoRepository;
35.    @Autowired
36.    private MongoTemplate mongoTemplate;
38.    @ApiOperation(value = "新建用户", notes = "根据UserMongoDo对象创建用户")
39.    @RequestMapping(value = "save",method = RequestMethod.POST)
40.    public String save(){
41.        UserMongoDouserMongoDo=newUserMongoDo();
42.        userMongoDo.setName("张三");
43.        userMongoDo.setAge(20);
44.        userMongoRepository.save(userMongoDo);
45.        logger.info("根据UserMongoDo对象创建用户:{}", userMongoDo);
47.        userMongoDo = newUserMongoDo();
48.        userMongoDo.setName("李四");
49.        userMongoDo.setAge(30);
50.        userMongoRepository.save(userMongoDo);
51.        logger.info("根据UserMongoDo对象创建用户:{}", userMongoDo);
53.        return"ok";
54.    }
56.    @ApiOperation(value = "查询所有UserMongoDo对象", notes = "查询所有UserMongoDo对象")
57.    @RequestMapping(value = "findAll", method = RequestMethod.GET)
58.    public List<UserMongoDo> find(){
59.        List<UserMongoDo> userMongoDoList = userMongoRepository.findAll();
60.        logger.info("查询所有UserMongoDo对象:{}", userMongoDoList);
61.        return userMongoDoList;
62.    }
64.    @ApiOperation(value = "根据姓名查询UserMongoDo对象", notes = "根据姓名查询UserMongoDo对象")
65.    @RequestMapping(value = "findByName", method = RequestMethod.GET)
66.    public UserMongoDo findByName(){
67.        return userMongoRepository.findByName("张三");
68.    }
70.    @RequestMapping("findAllByTemplate")
71.    public List<UserMongoDo> findAllByTemplate(){
72.        return mongoTemplate.findAll(UserMongoDo.class);
73.    }
74. }

• 效果图
  

参考来源： http://412887952-qq-com.iteye.com/blog/2318852

参考来源：http://www.jianshu.com/p/879caef9b0bc