1. 简介

spring-data-mongodb 提供了 MongoTemplate 与 MongoRepository 两种方式访问 mongodb，MongoRepository 操作简单，MongoTemplate操作灵活，我们在项目中可以灵活适用这两种方式操作 mongodb。

依赖

<dependencies>
  <!-- mongoDB 依赖 -->
  <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-mongodb</artifactId>
      <version>${spring-boot.version}</version>
  </dependency>
  <!-- 日期时间工具类 -->
  <dependency>
      <groupId>joda-time</groupId>
      <artifactId>joda-time</artifactId>
      <version>2.10.1</version>
  </dependency>
</dependencies>

配置文件

spring.data.mongodb.uri=mongodb://192.168.58.100:27017/yygh

数据库查看

> db.User.find();
{ "_id" : ObjectId("61dc10dc43132b7ebb6c2179"), "name" : "yxw", "age" : 24, "email" : "1076372957@qq.com", "_class" : "com.xuwei.springboot_mongodb.entity.User" }
{ "_id" : ObjectId("61dc12cf9dcacf1e4858d18d"), "name" : "张三", "age" : 20, "email" : "3332200@qq.com", "_class" : "com.xuwei.springboot_mongodb.entity.User" }
{ "_id" : ObjectId("61dc12e020d7eb12fa067296"), "name" : "李四", "age" : 24, "email" : "3332200@qq.com", "_class" : "com.xuwei.springboot_mongodb.entity.User" }

2. 基于MongoTemplate

2.1 常用方法

mongoTemplate.findAll(User.class): 查询User文档的全部数据
mongoTemplate.findById(<id>, User.class): 查询User文档id为id的数据
mongoTemplate.find(query, User.class);: 根据query内的查询条件查询
mongoTemplate.upsert(query, update, User.class): 修改
mongoTemplate.remove(query, User.class): 删除
mongoTemplate.insert(User): 新增
Query对象
1. 创建一个query对象（用来封装所有条件对象)，再创建一个criteria对象（用来构建条件）
2. 精准条件：criteria.and(“key”).is(“条件”)，模糊条件：criteria.and(“key”).regex(“条件”)   封装条件：query.addCriteria(criteria)
3. 大于（创建新的criteria）：Criteria gt = Criteria.where(“key”).gt（“条件”）
4. 小于（创建新的criteria）：Criteria lt = Criteria.where(“key”).lt（“条件”）
5. Query.addCriteria(new Criteria().andOperator(gt,lt));
6. 一个query中只能有一个andOperator()。其参数也可以是Criteria数组。
7. 排序 ：query.with（new Sort(Sort.Direction.ASC, "age"). and(new Sort(Sort.Direction.DESC, "date")))

2.2 具体案例

实体类省略。

@SpringBootTest
public class MongodbApplicationTest {
    @Autowired
    private MongoTemplate mongoTemplate;
    @Test
    public void createUser() {
        User user = new User();
        user.setAge(25);
        user.setName("YXW");
        user.setEmail("1076372957@qq.com");
        User user1 = mongoTemplate.insert(user);
        System.out.println(user1);
    }
    @Test
    public void findAllUser() {
        // 同理findById
        List<User> users = mongoTemplate.findAll(User.class);
        System.out.println(users);
    }
    @Test
    public void findUserList() {
        Query query = new Query(
                Criteria.where("name").is("yxw").and("age").is(24)
        );
        List<User> users = mongoTemplate.find(query, User.class);
        System.out.println(users);
    }
    @Test
    public void findUserLikeName() {
        String name = "yxw";
        // 模糊查询，匹配规则，相当于 where name like 'yxw%'
        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> userList = mongoTemplate.find(query, User.class);
        System.out.println(userList);
    }
    @Test
    public void findUserPage() {
        String name = "yxw";
        Query query = new Query();
        String regex = String.format("%s%s%s", "^.*", name, ".*$");
        Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
        query.addCriteria(Criteria.where("name").regex(pattern));
        // 分页查询
        int pageNumber = 1;
        int pageSize = 10;
        int totalCount = (int) mongoTemplate.count(query, User.class);
        List<User> userList = mongoTemplate.find(query.skip((pageNumber - 1) * pageSize).limit(pageSize), User.class);
        Map<String, Object> pageMap = new HashMap<>();
        pageMap.put("list", userList);
        pageMap.put("totalCount",totalCount);
        System.out.println(pageMap);
    }
    @Test
    public void updateUser() {
        User user = mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);
        user.setName("test_1");
        user.setAge(25);
        user.setEmail("493220990@qq.com");
        Query query = new Query(Criteria.where("_id").is(user.getId()));
        Update update = new Update();
        update.set("name", user.getName());
        UpdateResult result = mongoTemplate.upsert(query, update, User.class);
        long count = result.getModifiedCount();
        System.out.println(count);
    }
    @Test
    public void delete() {
        Query query = new Query(Criteria.where("_id").is("5ffbfa2ac290f356edf9b5aa"));
        DeleteResult result = mongoTemplate.remove(query, User.class);
        long count = result.getDeletedCount();
        System.out.println(count);
    }
}

3. 基于MongoRepository

3.1 具体规范

Spring Data 提供了对 mongodb 数据访问的支持，我们只需要继承 MongoRepository 类，按照 Spring Data 规范就可以了。

不是随便声明的，而需要符合一定的规范。
查询方法以find | read | get开头。
涉及条件查询时，条件的属性用条件关键字连接。
要注意的是：条件属性首字母需要大写。
支持属性的级联查询，但若当前类有符合条件的属性则优先使用，而不使用级联属性，若需要使用级联属性，则属性之间使用_强制进行连接。

3.2 具体案例

1、添加 repository/MongoRepository 类：

@Repository
public interface UserRepository extends MongoRepository<User, String> {
}

2、测试类。

@SpringBootTest
class SpringbootMongodbApplicationTests2 {
    @Autowired
    private UserRepository userRepository;
    //添加
    @Test
    public void createUser() {
        User user = new User();
        user.setAge(24);
        user.setName("李四");
        user.setEmail("3332200@qq.com");
        User user1 = userRepository.save(user);
        System.out.println(user1);
    }
    //查询所有
    @Test
    public void findUser() {
        List<User> userList = userRepository.findAll();
        System.out.println(userList);
    }
    //id查询
    @Test
    public void getById() {
        User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();
        System.out.println(user);
    }
    //条件查询
    @Test
    public void findUserList() {
        User user = new User();
        user.setName("张三");
        user.setAge(20);
        Example<User> userExample = Example.of(user);
        List<User> userList = userRepository.findAll(userExample);
        System.out.println(userList);
    }
    //模糊查询
    @Test
    public void findUsersLikeName() {
        //创建匹配器，即如何使用查询条件
        ExampleMatcher matcher = ExampleMatcher.matching() //构建对象
                .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //改变默认字符串匹配方式：模糊查询
                .withIgnoreCase(true); //改变默认大小写忽略方式：忽略大小写
        User user = new User();
        user.setName("三");
        Example<User> userExample = Example.of(user, matcher);
        List<User> userList = userRepository.findAll(userExample);
        System.out.println(userList);
    }
    //分页查询
    @Test
    public void findUsersPage() {
        Sort sort = Sort.by(Sort.Direction.DESC, "age");
        //0为第一页
        Pageable pageable = PageRequest.of(0, 10, sort);
        //创建匹配器，即如何使用查询条件
        ExampleMatcher matcher = ExampleMatcher.matching() //构建对象
                .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //改变默认字符串匹配方式：模糊查询
                .withIgnoreCase(true); //改变默认大小写忽略方式：忽略大小写
        User user = new User();
        user.setName("三");
        Example<User> userExample = Example.of(user, matcher);
        //创建实例
        Example<User> example = Example.of(user, matcher);
        Page<User> pages = userRepository.findAll(example, pageable);
        System.out.println(pages);
    }
    //修改
    @Test
    public void updateUser() {
        User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();
        user.setName("张三_1");
        user.setAge(25);
        user.setEmail("883220990@qq.com");
        User save = userRepository.save(user);
        System.out.println(save);
    }
    //删除
    @Test
    public void delete() {
        userRepository.deleteById("5ffbfe8197f24a07007bd6ce");
    }
}

Java 企业级开发实践

整合MongoDB