1. 先引入依赖(这里以gradle项目为例)

implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'

2. 在对应应类上获取MongoTemplate

 private final MongoTemplate mongoTemplate;

3. 下面就是一些常用功能实现

注: 下面的XXX是你的表名

3.1 数据保存
实现1 : 基本数据插入方式1:

Map<String, Object> map = new HashMap();
map.put("name","test");
Document document = new Document();
document.putAll(map);
Document insert = mongoTemplate.insert(document, XXX);
// 如果需要获取保存后的数据的主键id,则进行下面的操作
String childId = insert.get(MongoKeyConstants.PRIMARY_KEY).toString();

基本数据插入方式2:

Document doc = new Document();
doc.put("name", "狮子狗");
mongoTemplate.insert(doc, licenseAllocation);

3.2 数据查询
查询一条:
举个栗子: 查询用户名为光头强的数据

Query query = new Query();
query.addCriteria(Criteria.where("username").is("光头强"));
Document doc = mongoTemplate.findOne(query, Document.class, XXX);

查询多条:
注: 查询后的主键id返回的是一个object对象,所以需要处理一下

Query query = new Query();
query.addCriteria(Criteria.where("username").is("光头强"));
List<Document> dataList = mongoTemplate.find(query, Document.class, XXX);
// Constants.PRIMARY_KEY 值为  "_id"
dataList.forEach(document -> {document.put(MongoKeyConstants.PRIMARY_KEY, t.get(Constants.PRIMARY_KEY).toString());
});

查询条件3: 根据cinInfoId,开始时间和结束时间,以及xx名称模糊查询,进行筛选
注: 1. Constants 里的都是表里的字段
2. 这里的开始时间和结束时间都是可以单选的,所以需要分开判断

Query query = new Query();query.addCriteria(Criteria.where(MongoKeyConstants.CI_INFO_ID).is(cinInfoId));if (searchForm.getUpdateBy() != null) {query.addCriteria(Criteria.where(Constants.UPDATED_BY).is(searchForm.getUpdateBy()));}Date updateStart = searchForm.getUpdateStart();Date updateEnd = searchForm.getUpdateEnd();if (Objects.nonNull(updateStart) && Objects.nonNull(updateEnd)) {query.addCriteria(Criteria.where(Constants.UPDATED_AT).gte(updateStart).lte(updateEnd));} else {if (updateStart != null) {query.addCriteria(Criteria.where(Constants.UPDATED_AT).gte(updateStart));}if (updateEnd != null) {query.addCriteria(Criteria.where(Constants.UPDATED_AT).lte(updateEnd));}}//根据字段名模糊查询String updateFieldName = searchForm.getUpdateFieldName();if (StringUtils.isNotBlank(updateFieldName)) {query.addCriteria(Criteria.where(Constants.CHANGE_CONTENT).elemMatch(Criteria.where("fieldName").is(updateFieldName)));}//查询List<Document> documents = mongoTemplate.find(query, Document.class, XXX);