Maven引入

注意：項目搭建環(huán)境默認為 SpringBoot

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

創(chuàng)建實體類

1. 實體類的創(chuàng)建需要在類上指定映射的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) -> {
                //數據處理，可以直接返回數據，防止需要處理
            }
    );
    
}