MongoDB + SpringBoot

1添加依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>

2配置文件

# mongodb
spring.data.mongodb.host=10.1.255.20
spring.data.mongodb.port=27019
spring.data.mongodb.database=followup
spring.data.mongodb.username=followup
spring.data.mongodb.password=followup

3编写实体

@Document(collection = "demo_auto")
@Data
@ToString
public class MongoDemoDO implements Serializable {
    @Id
    private String id;

    private String name;

    private String gender;

    private Integer age;
}

spring-data-mongodb中的实体映射是通过MongoMappingConverter这个类实现的。它可以通过注释把java类转换为mongodb的文档。
它有以下几种注释：

@Id - 文档的唯一标识，在mongodb中为ObjectId，它是唯一的，通过时间戳+机器标识+进程ID+自增计数器（确保同一秒内产生的Id不会冲突）构成。

@Document - 把一个java类声明为mongodb的文档，可以通过collection参数指定这个类对应的文档。@Document(collection=“mongodb”) mongodb对应表

@DBRef - 声明类似于关系数据库的关联关系。ps：暂不支持级联的保存功能。在插入，删除操作时，并不检查对象之间的关联关系就直接操作了

@Indexed - 声明该字段需要索引，建索引可以大大的提高查询效率。

@CompoundIndex - 复合索引的声明，建复合索引可以有效地提高多字段的查询效率。

@GeoSpatialIndexed - 声明该字段为地理信息的索引。

@Transient - 映射忽略的字段，该字段不会保存到mongodb。

@PersistenceConstructor - 声明构造函数，作用是把从数据库取出的数据实例化为对象。该构造函数传入的值为从DBObject中取出的数据。

4 Service层（增删改查）

接口

public interface MongoDBService {
    /**
     * 新增或更新一条记录
     *
     * @param obj
     */
    <T> T save(T objectToSave);

    /**
     * 查询一条记录
     *
     * @param clazz
     * @param query
     * @return
     */
    <T> T findOne(Query query, Class<T> clazz);

    /**
     * 查询所有
     *
     * @param clazz
     * @return
     */
    <T> List<T> findAll(Class<T> clazz);

    /**
     * 根据ID查询一个对象
     *
     * @param clazz
     * @param id
     * @return
     */
    <T> T findById(Object id, Class<T> clazz);

    /**
     * 根据条件查询集合对象
     *
     * @param clazz
     * @param query
     * @return
     */
    <T> List<T> list(Query query, Class<T> clazz);

    /**
     * 分页查询
     */
    <T> Page<T> page(int currentPage, int pageSize, Query query, Class<T> clazz);

    /**
     * 根据条件查询总条数
     *
     * @param clazz
     * @param query
     * @return
     */
    <T> long count(Query query, Class<T> clazz);

    /**
     * 根据条件更新记录
     *
     * @param query 条件
     * @param update 需要更新的字段
     * @param clazz
     * @return
     */
    <T> long update(Query query, Update update, Class<T> clazz);

    /**
     * 根据id删除记录
     *
     * @param clazz
     * @param query
     * @return
     */
    <T> long deleteById(Object id, Class<T> clazz);

}

实现

@Service
public class MongoDBServiceImpl implements MongoDBService {
    @Resource
    private MongoTemplate mongoTemplate;

    @Override
    public <T> T save(T objectToSave) {
        return mongoTemplate.save(objectToSave);
    }

    @Override
    public <T> T findOne(Query query, Class<T> clazz) {
        return mongoTemplate.findOne(query, clazz);
    }

    @Override
    public <T> List<T> findAll(Class<T> clazz) {
        return mongoTemplate.findAll(clazz);
    }

    @Override
    public <T> T findById(Object id, Class<T> clazz) {
        return mongoTemplate.findById(id, clazz);
    }

    @Override
    public <T> List<T> list(Query query, Class<T> clazz) {
        return mongoTemplate.find(query, clazz);
    }

    @Override
    public <T> Page<T> page(int currentPage, int pageSize, Query query, Class<T> clazz) {
        query.limit(pageSize);
        query.skip(pageSize * (currentPage - 1));
        Page page = new Page();
        page.setPageNumber(currentPage);
        page.setPageSize(pageSize);
        long total = mongoTemplate.count(query, clazz);
        List<T> list = mongoTemplate.find(query, clazz);
        page.setList(list);
        page.setTotalNumber(total);
        page.setTotalPage(total / pageSize);
        return page;
    }

    @Override
    public <T> long count(Query query, Class<T> clazz) {
        return mongoTemplate.count(query, clazz);
    }

    @Override
    public <T> long update(Query query, Update update, Class<T> clazz) {
        return mongoTemplate.updateMulti(query, update, clazz).getModifiedCount();
    }

    @Override
    public <T> long deleteById(Object id, Class<T> clazz) {
        Query query = new Query();
        query.addCriteria(Criteria.where("id").is(id));
        return mongoTemplate.remove(query, clazz).getDeletedCount();
    }@Service
public class MongoDBServiceImpl implements MongoDBService {
    @Resource
    private MongoTemplate mongoTemplate;

    @Override
    public <T> T save(T objectToSave) {
        return mongoTemplate.save(objectToSave);
    }

    @Override
    public <T> T findOne(Query query, Class<T> clazz) {
        return mongoTemplate.findOne(query, clazz);
    }

    @Override
    public <T> List<T> findAll(Class<T> clazz) {
        return mongoTemplate.findAll(clazz);
    }

    @Override
    public <T> T findById(Object id, Class<T> clazz) {
        return mongoTemplate.findById(id, clazz);
    }

    @Override
    public <T> List<T> list(Query query, Class<T> clazz) {
        return mongoTemplate.find(query, clazz);
    }

    @Override
    public <T> Page<T> page(int currentPage, int pageSize, Query query, Class<T> clazz) {
        query.limit(pageSize);
        query.skip(pageSize * (currentPage - 1));
        Page page = new Page();
        page.setPageNumber(currentPage);
        page.setPageSize(pageSize);
        long total = mongoTemplate.count(query, clazz);
        List<T> list = mongoTemplate.find(query, clazz);
        page.setList(list);
        page.setTotalNumber(total);
        page.setTotalPage(total / pageSize);
        return page;
    }

    @Override
    public <T> long count(Query query, Class<T> clazz) {
        return mongoTemplate.count(query, clazz);
    }

    @Override
    public <T> long update(Query query, Update update, Class<T> clazz) {
        return mongoTemplate.updateMulti(query, update, clazz).getModifiedCount();
    }

    @Override
    public <T> long deleteById(Object id, Class<T> clazz) {
        Query query = new Query();
        query.addCriteria(Criteria.where("id").is(id));
        return mongoTemplate.remove(query, clazz).getDeletedCount();
    }

单元测试

@SpringBootTest
@Slf4j
class DemoApplicationTests {

    @Resource
    MongoDBService mongoDBService;

    @Test
    void save() {
        MongoDemoDO save = new MongoDemoDO();
        save.setName("戚薇");
        save.setGender("女");
        save.setAge(20);
        MongoDemoDO result = mongoDBService.save(save);
        log.info("ressult:{}", result);
    }

    @Test
    void findById() {
        MongoDemoDO result = mongoDBService.findById("603750ab5f3ee121e806620a", MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void findOne() {
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("戚薇"));
        MongoDemoDO result = mongoDBService.findOne(query, MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void findAll() {
        List<MongoDemoDO> result = mongoDBService.findAll(MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void list() {
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("戚薇"));
        List<MongoDemoDO> result = mongoDBService.list(query, MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void page() {
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("戚薇"));
        Page<MongoDemoDO> result = mongoDBService.page(2, 1, query, MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void count() {
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("戚薇"));
        long result = mongoDBService.count(query, MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void remove() {
        long result = mongoDBService.deleteById("603771a05f3ee121e806620b", MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

    @Test
    void update() {
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("戚薇"));
        Update update = new Update();
        update.set("age","12");
        long result = mongoDBService.update(query,update, MongoDemoDO.class);
        log.info("ressult:{}", result);
    }

}

最后编辑于：2021.02.26 16:37:15

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 220,367评论 6赞 512
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 93,959评论 3赞 396
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 166,750评论 0赞 357
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 59,226评论 1赞 295
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 68,252评论 6赞 397
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,975评论 1赞 308
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,592评论 3赞 420
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 39,497评论 0赞 276
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 46,027评论 1赞 319
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 38,147评论 3赞 340
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 40,274评论 1赞 352
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,953评论 5赞 347
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 41,623评论 3赞 331
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 32,143评论 0赞 23
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 33,260评论 1赞 272
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 48,607评论 3赞 375
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 45,271评论 2赞 358