Maven引入

注意：项目搭建环境默认为 SpringBoot

<!-- MongoDB依赖引入 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

创建实体类

1. 实体类的创建需要在类上指定映射的Collection名称

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

/**
 * Class description
 * MongoDB表 集合实体类
 * @author SuperDaHei
 * @data 2019-06-11
 */

@Document(collection = "MongoDB_Collection_name")
public class CollectionInfoModel {

    /** 指定该属性为主键 */
    @Id 
    private String id;

    /** 指定该实现映射的集合字段名 */
    @Field("name") 
    private String name;

}

2.数据处理层进行数据的增删改查

引入 MongoTemplate ，需要在类上添加扫描注解 @Repository或者@Component,如果 MongoTemplate 提示没有该bind建议maven clean一下，或者maven刷新下。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
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.SerializationUtils;
import org.springframework.data.mongodb.core.query.Update;

/**
 * Class description
 * 数据层
 * @author SuperDaHei
 * @data 2019-06-11
 */
@Repository
public class CommodityInfoDaoImpl {

    @Autowired
    private MongoTemplate mongoTemplate;

    public void queryAll(CollectionInfoModel model) {
        
        //查询该集合所有的数据
        List<CollectionInfoModel> list = mongoTemplate.findAll(CollectionInfoModel.class);
        
        //查询该集合符合条件的数据
        Query query = new Query();
        /**
         * Criteria.where( MongoDB集合字段名称 ).is( 条件 )；
         *
         *  中的 is 是 = ; lt 小于 ; gt 大于 ; ne 不等于 
         *
         */
        query.addCriteria(Criteria.where( MongoDB集合字段名称 ).is( 条件 ));
        //排序查询
        query.with(new Sort(Sort.Direction.DESC, MongoDB集合字段名称 ));
        List<CollectionInfoModel> list = mongoTemplate.find(query, CollectionInfoModel.class);
        
        //增加数据
        //直接放入处理后的实体类
        mongoTemplate.insert(model);
        
        //删除数据
        /**
        *
        * remove 删除多个
        *
        * findAndRemove 删除一个并且返回删除的集合
        *
        */
        mongoTemplate.remove(model);
        
        //更新操作
        
       /**
        *
        * updateMulti 更新所有符合条件的数据 
        *
        * updateFirst 更新一条数据
        *
        */
        Update update = new Update();
        mongoTemplate.updateFirst(new Query().addCriteria(Criteria.where("_id").is(model.getId())),
                update , CollectionInfoModel.class);
    }
    
}

3.对数据集进行分页查询

建立分页类

package com.aioff.common.entity;


import com.jeesite.common.entity.DataEntity;
import lombok.Setter;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;

/**
 * Class description
 * MongoDB 分页查询条件实现类
 * @author SuperDaHei
 * @data 2019-06-20
 */
@Setter
public class MongoDBPageRequest implements Pageable {

    /**
     * 当前页码
     */
    private int pageNumber = 1;

    /**
     * 每页显示条数
     */
    private int pageSize = 20;

    /**
     * 查询条件
     */
    private Sort sort;

    @Override
    public int getPageNumber() {
        return pageNumber;
    }

    @Override
    public int getPageSize() {
        return pageSize;
    }

    @Override
    public long getOffset() {
        return (getPageNumber() - 1) * getPageSize();
    }

    @Override
    public Sort getSort() {
        return sort;
    }

    @Override
    public Pageable next() {
        return null;
    }

    @Override
    public Pageable previousOrFirst() {
        return null;
    }

    @Override
    public Pageable first() {
        return null;
    }

    @Override
    public boolean hasPrevious() {
        return false;
    }

    /**
     * 初始话MongDB分页查询
     * @param pageNumber 当前页码
     * @param pageSize 每页数目
     * @param sort 排序
     * @return
     */
    public static MongoDBPageRequest initMongoDBPageRequest(int pageNumber, int pageSize, Sort sort) {
        MongoDBPageRequest mongoDBPageRequest = new MongoDBPageRequest();
        mongoDBPageRequest.setPageNumber(pageNumber);
        mongoDBPageRequest.setPageSize(pageSize);
        mongoDBPageRequest.setSort(sort);
        return mongoDBPageRequest;
    }
}

分页逻辑处理

public Page<CollectionInfoModel> queryPage(VideoInfoPageModel model) {
    //设立查询条件
    Query query = new Query();
    //添加分页基本数据，页数，码数，排序
    MongoDBPageRequest mongoDBPageRequest = MongoDBPageRequest.initMongoDBPageRequest(pageNumber, pageSize, new Sort( Sort.Direction.DESC, "createSequence"));
    query.with(mongoDBPageRequest);
    //查询出分页数据
    List<CollectionInfoModel> list = mongoTemplate.find(query, CollectionInfoModel.class);
    PageImpl<CollectionInfoModel> pageImpl = ( PageImpl<CollectionInfoModel> ) PageableExecutionUtils.getPage(list, mongoDBPageRequest,
            () -> mongoTemplate.count( query, VideoInfoModel.class));
    pageImpl.getContent().stream().forEach(
            (v) -> {
                //数据处理，可以直接返回数据，防止需要处理
            }
    );
    
}