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");
    }
}