SpringBoot整合MongoDB的实现步骤

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。本文介绍SpringBoot项目如何整合MongoDB

一、技术介绍

1.MongoDB是什么？

MongoDB（来自于英文单词“Humongous”，中文含义为“庞大”）是可以应用于各种规模的企业、各个行业以及各类应用程序的开源数据库。作为一个适用于敏捷开发的数据库，MongoDB的数据模式可以随着应用程序的发展而灵活地更新。与此同时，它也为开发人员提供了传统数据库的功能：二级索引，完整的查询系统以及严格一致性等等。 MongoDB能够使企业更加具有敏捷性和可扩展性，各种规模的企业都可以通过使用MongoDB来创建新的应用，提高与客户之间的工作效率，加快产品上市时间，以及降低企业成本。 MongoDB是专为可扩展性，高性能和高可用性而设计的数据库。它可以从单服务器部署扩展到大型、复杂的多数据中心架构。利用内存计算的优势，MongoDB能够提供高性能的数据读写操作。 MongoDB的本地复制和自动故障转移功能使您的应用程序具有企业级的可靠性和操作灵活性。

二、使用步骤

1.引入maven库

代码如下（示例）：

  org.springframework.bootspring-boot-starter-parent2.4.1  org.springframework.bootspring-boot-starter-data-mongodb

2.具体使用示例

MongoDB封装：

 /** * mongo db助手 * * @Author: heyuhua * @Date: 2021/1/19 9:52 */ @Component public class MongoDBHelper { @Autowired private MongoTemplate mongoTemplate; /** * 保存 * * @param t * @param  * @return */ public  T save(T t) { return mongoTemplate.save(t); } /** * 保存 * * @param t * @param collectionName * @param  * @return */ public  T save(T t, String collectionName) { return mongoTemplate.save(t, collectionName); } /** * 查询 * * @param query * @param tClass * @param  * @return */ public  List find(Query query, Class tClass) { return mongoTemplate.find(query, tClass); } /** * 查询所有 * * @param tClass * @param  * @return */ public  List findAll(Class tClass) { return mongoTemplate.findAll(tClass); } }

3.配置文件

代码如下（示例）：

 server: port: 8088 spring: #mongodb配置 data: mongodb: uri: mongodb://admin:admin@127.0.0.1:27017/admin

4.单元测试

测试代码如下（示例）：

 package com.hyh.core.test; import com.hyh.core.test.base.HyhTest; import com.hyh.core.test.po.Person; import com.hyh.mongodb.helper.MongoDBHelper; import org.junit.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.CriteriaDefinition; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.TextCriteria; import java.util.List; /** * MongoDb Test * * @Author: heyuhua * @Date: 2021/1/19 10:28 */ public class MongoDBTest extends HyhTest { @Autowired private MongoDBHelper mongoDBHelper; @Test public void testSave() { Person person = new Person(); person.setName("heyuhua"); person.setAge(25); mongoDBHelper.save(person); Person person2 = new Person(); person2.setName("hyh"); person2.setAge(52); mongoDBHelper.save(person2); } @Test public void testSaveCollection() { Person person = new Person(); person.setName("heyuhua"); person.setAge(25); mongoDBHelper.save(person, "personCollection"); Person person2 = new Person(); person2.setName("hyh"); person2.setAge(52); mongoDBHelper.save(person2, "personCollection"); } @Test public void testFindAll() { List list = mongoDBHelper.findAll(Person.class); for (Person person : list) { System.out.println("name=" + person.getName() + ",age=" + person.getAge()); } } @Test public void testFind() { Criteria criteria = new Criteria(); criteria.and("age").gte("25"); Query query = new Query(criteria); List list = mongoDBHelper.find(query,Person.class); for (Person person : list) { System.out.println("name=" + person.getName() + ",age=" + person.getAge()); } } @Test @Override public void test() { System.out.println("---MongoDb Test---"); } }