当前位置：自学咖网 > 技术教程 > 编程最新 > SpringBoot整合MongoDB
wenwen 编程最新

SpringBoot整合MongoDB

SpringBoot整合MongoDB

  • NoSQL(Not Only SQL)，即反SQL运动或者是不仅仅SQL，指的是非关系型的数据库，是一项全新的数据库革命运动，是一种全新的思维注入
  • NoSQL优点
    • 数据库高并发读写
    • 海量数据高效率存储和访问
    • 数据库高扩展性和高可用性
  • NoSQL缺点
    • 数据库事务一致性需求
    • 数据库的写实时性和读实时性需求
    • 复杂的SQL查询，特别是夺标关联查询的需求
  • MongoDB概述
    • 由C++语言编写，是一个基于分布式文件存储的开源数据库系统；在高负载的情况下，添加更多的节点，可以保证服务器性能
    • MongoDB旨在为WEB应用提供可扩展的高性能数据存储解决方案；将数据存储为一个文档，数据结构由键值对组成。MongoDB文档类似于JSON对象字段值可以包含其他问你当、数组及文档数组
  • MongoDB特点
    • MongoDB是一个面向文档存储的数据库，操作起来比较简单和容易
    • MongoDB记录总可以设置任何属性的索引
    • 可以通过本地后者网络创建数据镜像，这使得MongoDB有更强的扩展性
    • 如果负载的增减（需要跟多的存储空间和更强的处理能力），它可以分布在计算机网络中的其他节点上，这就是所谓的分片
    • MongoDB支持丰富的查询表达式，查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象和数组
    • MongoDB使用update()命令可以实现替换完成的文档（数据）或者一些指定的数据字段
    • MongoDB中的Map/reduce主要是用来对数据进行批量处理和聚合操作
    • Map和Reduce
      • Map函数调用emit(key, value)便利集合中所有的记录，将key域value传给Reduce函数进行处理
      • Map和Reduce函数是使用JavaScript编写的，把那个可以通过db.runCommand或mapreduce命令来执行MapReduce操作
    • GridFS是MongoDB中的一个内置功能，可以用于存放大量的小文件
    • MongoDB允许在服务端执行脚本，可以用JavaScript编写某个函数，直接在服务端执行，也可以把函数的定义存储在服务端，下次直接调用即可
    • MongoDB支持跟中编程语言：RUBY、PYTHON、JAVA、C++、PHP、C#
    • 安装简单
  • MongoDB语法：略
  • SpringBoot整合MongoDB
    • 集成简介：spring-data-mongodb提供了MongoTemplate和MongoRepository两种方式访问MongoDB；MongoTemplate操作灵活，MongoRepository操作简单，不够灵活
    • 添加相关依赖
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
    <version>2.2.1.RELEASE</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.2.1.RELEASE</version>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.18.10</version>
</dependency>
<dependency>
    <groupId>joda-time</groupId>
    <artifactId>joda-time</artifactId>
    <version>2.10.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    <exclusions>
        <exclusion>
            <groupId>org.junit.vintage</groupId>
            <artifactId>junit-vintage-engine</artifactId>
        </exclusion>
    </exclusions>
</dependency>
  • 添加配置
spring.data.mongodb.uri=mongodb://Your IP:27017/your database
  • 创建与集合对应的实体类
@Data
@Document("User")   // 表示操作的是your database下的User集合
public class User {
    @Id
    private String id;
    private String name;
    private Integer age;
}
  • 测试MongoTemplate访问MongoDB（CRUD）
@SpringBootTest
public class MongoDBTest {
    @Autowired
    private MongoTemplate mongoTemplate;

    /** 新增 */
    @Test
    public void insert() {
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        User u = mongoTemplate.insert(user);
        System.out.println("user = " + u);
    }
    /** 查询所有记录 */
    @Test
    public void findAll() {
        List<User> all = mongoTemplate.findAll(User.class);
        System.out.println("all = " + all);
    }
    /** ID查询 */
    @Test
    public void findById() {
        User u = mongoTemplate.findById("rge8vcuxdfsfdfsdf", User.class);
        System.out.println("u = " + u);
    }
    /** 条件查询 */
    @Test
    public void findUserList() {
        Query query = new Query(Criteria.where("name").is("xiansen").and("age").is(18));
        List<User> users = mongoTemplate.find(query, User.class);
        System.out.println("users = " + users);
    }
    /** 模糊查询 */
    @Test
    public void findUserListByLike() {
        String name = "xian";
        String regex = String.format("%s%s%s", "^.*", name, ".*$");
        Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);  // 大小写敏感
        Query query = new Query(Criteria.where("name").regex(pattern));   // 使用正则表达式实现模糊查询
        List<User> users = mongoTemplate.find(query, User.class);
        System.out.println("users = " + users);
    }
    /** 分页查询 */
    @Test
    public void findPageUserList() {
        int current = 1;
        int limit = 3;
        String name = "xian";
        String regex = String.format("%s%s%s", "^.*", name, ".*$");
        Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);  // 大小写敏感
        Query query = new Query(Criteria.where("name").regex(pattern));
        // 查询的记录数
        Long count = mongoTemplate.count(query, User.class);
        System.out.println("count = " + count);
        // 分页查询
        List<User> users = mongoTemplate.find(query.skip((current-1)*limit).limit(limit), User.class);
        System.out.println("users = " + users);
    }
    /** 修改 */
    @Test
    public void updateUser() {
        User u = mongoTemplate.findById("ds98h98sdhds6gt7u", User.class);
        u.setName("hello");
        u.setAge(20);
        Query query = new Query(Criteria.where("_id").is(u.getId()));
        Update update = new Update();
        update.set("name", u.getName());
        update.set("age", u.getAge());
        UpdateResult upsert = mongoTemplate.upsert(query, update, User.class);
        long modifiedCount = upsert.getModifiedCount();  // 影响的行数
        System.out.println("modifiedCount = " + modifiedCount);
    }
    /** 删除 */
    @Test
    public void deleteUser() {
        Query query = new Query(Criteria.where("_id").is("ds98h98sdhds6gt7u"));
        DeleteResult remove = mongoTemplate.remove(query, User.class);
        long deletedCount = remove.getDeletedCount();  // 影响的行数
        System.out.println("deletedCount = " + deletedCount);
    }
}
  • 相比于MongoTemplate，MongoRepository实现CRUD操作，还需要创建一个继承MongoRepository接口的接口，如
@Repository
public interface UserRepository extends MongoRepository<User, String> {}
  • 测试MongoRepository访问MongoDB（CRUD）
@SpringBootTest
public class MongoDBTest {
    @Autowired
    private UserRepository userRepository;


    /** 新增 */
    @Test
    public void insert() {
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        User u = userRepository.save(user);
        System.out.println("user = " + u);
    }
    /** 查询所有记录 */
    @Test
    public void findAll() {
        List<User> all = userRepository.findAll();
        System.out.println("all = " + all);
    }
    /** ID查询 */
    @Test
    public void findById() {
        User u = userRepository.findById("rge8vcuxdfsfdfsdf").get();
        System.out.println("u = " + u);
    }
    /** 条件查询 */
    @Test
    public void findUserList() {
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        Example<User> userExample = Example.of(user);
        List<User> users = userRepository.findAll(userExample);
        System.out.println("users = " + users);
    }
    /** 模糊查询 */
    @Test
    public void findUserListByLike() {
        User user = new User();
        user.setName("xian");
        user.setAge(18);
        ExampleMatcher matcher = ExampleMatcher.matching()
                .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)    // 表示模糊查询
                .withIgnoreCase(true);   // 忽略大小写
        Example<User> userExample = Example.of(user, matcher);
        List<User> users = userRepository.findAll(userExample);
        System.out.println("users = " + users);
    }
    /** 分页查询 */
    @Test
    public void findPageUserList() {
        // 分页设置参数
        Pageable pageable = PageRequest.of(0, 3);// 0表示第一页
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        Example<User> userExample = Example.of(user);
        Page<User> page = userRepository.findAll(userExample, pageable);
        System.out.println("page = " + page);
    }
    /** 修改 */
    @Test
    public void updateUser() {
        User u = userRepository.findById("ds98h98sdhds6gt7u").get();
        u.setName("hello");
        u.setAge(20);
        User user = userRepository.save(u);
        System.out.println("user = " + user);
    }
    /** 删除 */
    @Test
    public void deleteUser() {
        userRepository.deleteById("ds98h98sdhds6gt7u");
    }
}
hmoban主题是根据ripro二开的主题，极致后台体验，无插件，集成会员系统
自学咖网 » SpringBoot整合MongoDB

wen 普通

分享到：

相关推荐

php怎么设置页面过期

php设置页面过期的方法：首先打开相应的PHP页面文件；然后通过【header("Last-Modified: " . gmdate("D, d M Y H:i:s") . &qu...

BC2-小飞机

KiKi 学会了 printf 在屏幕输出信息，他想输出一架小飞机。请帮他编写程序输出这架小飞机。

了解PHP中的Trait 特性及作用

自 PHP 5.4.0 起，PHP 实现了代码复用的一个方法，称为 traits。 Traits 是一种为类似 PHP 的单继承语言而准备的代码复用机制。Trait 为了减少单继承语言的限制，使开发人员能够自由地在不同层...

PHP中环境变量的操作

在 PHP 中，我们可以通过 phpinfo() 查看到当前系统中的环境变量信息（Environment）。在代码中，我们也可以通过两个函数，查看和修改相应的环境变量信息。 getenv() 获取环境变量信息 在不传参数...