Spring Boot 结合 MongoDB 简单使用

1、什么是MongoDB ?

MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

MongoDB 是由C++语言编写的，是一个基于分布式文件存储的开源数据库系统。

在高负载的情况下，添加更多的节点，可以保证服务器性能。

MongoDB 将数据存储为一个文档，数据结构由键值(key=>value)对组成。

MongoDB 文档类似于 JSON 对象。字段值可以包含其他文档，数组及文档数组。

MongoDB和关系数据库的对比

mongodb的增删改查

Spring Boot对各种流行的数据源都进行了封装，当然也包括了mongodb,下面给大家介绍如何在spring boot中使用mongodb：

  • 1、pom包配置

pom包里面添加spring-boot-starter-data-mongodb包引用

<dependencies>
    <dependency> 
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency> 
</dependencies>
  • 2、在application.properties中添加配置
    pom包里面添加spring-boot-starter-data-mongodb包引用
<dependencies>
    <dependency> 
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency> 
</dependencies>
  • 2、在application.properties中添加配置
spring.data.mongodb.uri=mongodb://name:password@localhost:27017/admin

2、创建数据实体

@Data
@ToString
public class User implements Serializable {
    private static final long serialVersionUID = -3258839839160856613L;
    @Id
    private Long id;

    private String username;
    private Integer age;

    public User(Long id, String username, Integer age) {
        this.id = id;
        this.username = username;
        this.age = age;
    }
}
  • 实现User的数据访问对象：UserRepository
public interface UserRepository extends MongoRepository<User, Long> {

    User findByUsername(String username);
    
    User findByUsernameAndAge(String username, Integer age);

    User findByAge(Integer age);
}
  • 在单元测试中调用
@RunWith(SpringRunner.class)
@SpringBootTest
public class MongodbApplicationTests {
    @Autowired
    private UserRepository userRepository;
    
    @Test
    public void test1() throws Exception {
//        User user = userRepository.findByAge(40);
//        System.out.println(user.toString());
        
        User user1 = userRepository.findByUsernameAndAge("mama", 40);
        System.out.println(user1.toString());
    }

    @Test
    public void test() throws Exception {

        // 创建三个User，并验证User总数
        userRepository.save(new User(1L, "didi", 30));
        userRepository.save(new User(2L, "mama", 40));
        userRepository.save(new User(3L, "kaka", 50));

        Assert.assertEquals(3, userRepository.findAll().size());

        // 删除一个User，再验证User总数
        User u = userRepository.findById(1L).get();
        System.out.println(u.toString());
        userRepository.delete(u);
        Assert.assertEquals(2, userRepository.findAll().size());

        // 删除一个User，再验证User总数
        u = userRepository.findByUsername("mama");
        System.out.println(u.toString());
//        userRepository.delete(u);
        Assert.assertEquals(2, userRepository.findAll().size());
    }
}

使用 MongoTemplate 操作

  • 创建 UserEntity 
@Data
public class UserEntity implements Serializable {
        private static final long serialVersionUID = -3258839839160856613L;
        private String userName;
        private String passWord;

}
  • 创建实体dao的增删改查操作
    dao层实现了 UserEntity 对象的增删改查
 @Component
public class UserEntityDao implements IUserEntityDao {

    @Autowired
    private MongoTemplate mongoTemplate;

    public void save() {
        UserEntity userEntity = new UserEntity();
        userEntity.setUserName("mengma");
        userEntity.setPassWord("33333");
        mongoTemplate.save(userEntity);
    }


    public UserEntity findByUserName(String username) {
        //  使用 query 对象 声明查询 条件
        Query query = new Query(Criteria.where("userName").is(username));
        UserEntity userEntity = mongoTemplate.findOne(query, UserEntity.class);
        return userEntity;
    }

    /**
     * 通过 userName 更新  passWord
     *
     * @param:
     * @return:
     * @auther: Tangzhiqiang
     * @date: 2019/1/14 9:21
     */
    public void updateUser(String userName, String password) {

        // 通过 query 对象 声明更新的条件
        Query query = new Query(Criteria.where("userName").is(userName));

        // 通过 update 对象 声明更新字段 值
        Update update = new Update().set("passWord", password);

        UpdateResult updateResult = mongoTemplate.updateFirst(query, update, UserEntity.class);
    }

    public void delByUsername(String username) {
        Query query = new Query(Criteria.where("userName").is(username));
        mongoTemplate.remove(query, UserEntity.class);
    }

    /**
     * 查询分页
     *
     * @param:
     * @return:
     * @auther: Tangzhiqiang
     * @date: 2019/1/14 10:42
     */
    public void findPage(int size, int page, String username) {
        // 通过 pageable 对象设置 分页条件
        Pageable pageable = new PageRequest(page - 1, size);

        // 分页具体逻辑条件
        Query query = new Query(Criteria.where("userName").is(username));
        List<UserEntity> userEntityList = mongoTemplate.find(query.with(pageable), UserEntity.class);
        System.out.println(userEntityList.toString());
    }

}
  • 测试类
@RunWith(SpringRunner.class)
@SpringBootTest
public class UserEntityDaoTest {

    @Autowired
    private UserEntityDao userEntityDao;

    @Test
    public void save() {
        userEntityDao.save();
    }

    @Test
    public void findByUserName() {
        UserEntity userEntity = userEntityDao.findByUserName("mengma");
        System.out.println(userEntity.toString());
    }

    @Test
    public void updateUser() {
        userEntityDao.updateUser("mengma", "99999999");
    }

    @Test
    public void delByUserName() {
        userEntityDao.delByUsername("mengma");
    }

    @Test
    public void findPage() {
        userEntityDao.findPage(2, 1, "mengma");
    }

}
  • 分页查询
public void findPage(int size, int page, String username) {
        // 通过 pageable 对象设置 分页条件
        Pageable pageable = new PageRequest(page - 1, size);

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

推荐阅读更多精彩内容