一. 安装:

  1. 启动docker

service docker start

  1. 创建并启动mongoDB容器:(这个命令是一次性的,用一次,后面就不用了)

docker run -d —restart=always -p 27017:27017 —name mymongo -v /data/db:/data/db -d mongo

  1. 启动mongoDB

docker start 249(容器id)

  1. 进入mongoDB

docker exec -it mymongo /bin/bash

  1. 使用MongoDB客户端进行操作

mongo

  1. 查询所有的数据库

show dbs
另外其他的操作,看尚医通word文档!
还有一点非常重要:mongoDB表不支持表连接(内连接,外连接等)

二. API(springboot集成 && 练习使用 && 68~72)

1. 知识点

image.png

(1)两种方式:

  • MongoTemplate:

优点:操作灵活
缺点:操作不简单

  • MongoRepository:

优点:操作简单
缺点:不够灵活

(2)常用API

1)MongoTemplate:
  • mongoTemplate.findAll(User.class): 查询User文档的全部数据
  • mongoTemplate.findById(, 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): 新增

    2)MongoRepository:

2. 如何使用?

34-mongoTeamplate操作.png

(1)pom

这里使用的是springData整合Mongo的依赖

  1. <dependency>
  2. <groupId>org.springframework.boot</groupId>
  3. <artifactId>spring-boot-starter-data-mongodb</artifactId>
  4. </dependency>

(2)yml

  1. spring.data.mongodb.uri=mongodb://192.168.237.127:27017/test

(3)代码:

MongoTemplate:

  • 实体类(加注解)
  • MongoTemplate测试类

MongoRepository:

  • 实体类(加注解)
  • 接口继承MongoRepository
  • MongoRepository测试类
    1)MongoTemplate测试类
    ```lua

import com.heyu.mongdb.entity.User; import com.mongodb.client.result.DeleteResult; import com.mongodb.client.result.UpdateResult; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Update; import org.springframework.test.context.junit4.SpringRunner;

import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.regex.Pattern;

@SpringBootTest @RunWith(SpringRunner.class) public class DemomogoApplicationTests {

  1. @Autowired
  2. private MongoTemplate mongoTemplate;
  3. //添加
  4. @Test
  5. public void createUser() {
  6. User user = new User();
  7. user.setAge(20);
  8. user.setName("test");
  9. user.setEmail("4932200@qq.com");
  10. User user1 = mongoTemplate.insert(user);
  11. System.out.println(user1);
  12. }
  13. //查询所有
  14. @Test
  15. public void findUser() {
  16. List<User> userList = mongoTemplate.findAll(User.class);
  17. System.out.println(userList);
  18. }
  19. //根据id查询
  20. @Test
  21. public void getById() {
  22. User user =
  23. mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);
  24. System.out.println(user);
  25. }
  26. //条件查询
  27. @Test
  28. public void findUserList() {
  29. Query query = new Query(Criteria
  30. .where("name").is("test")
  31. .and("age").is(20));
  32. List<User> userList = mongoTemplate.find(query, User.class);
  33. System.out.println(userList);
  34. }
  35. //模糊查询
  36. @Test
  37. public void findUsersLikeName() {
  38. String name = "est";
  39. String regex = String.format("%s%s%s", "^.*", name, ".*$");
  40. Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
  41. Query query = new Query(Criteria.where("name").regex(pattern));
  42. List<User> userList = mongoTemplate.find(query, User.class);
  43. System.out.println(userList);
  44. }
  45. //分页查询
  46. @Test
  47. public void findUsersPage() {
  48. String name = "est";
  49. int pageNo = 1;
  50. int pageSize = 10;
  51. Query query = new Query();
  52. String regex = String.format("%s%s%s", "^.*", name, ".*$");
  53. Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);
  54. query.addCriteria(Criteria.where("name").regex(pattern));
  55. int totalCount = (int) mongoTemplate.count(query, User.class);
  56. List<User> userList = mongoTemplate.find(query.skip((pageNo - 1) * pageSize).limit(pageSize), User.class);
  57. Map<String, Object> pageMap = new HashMap<>();
  58. pageMap.put("list", userList);
  59. pageMap.put("totalCount",totalCount);
  60. System.out.println(pageMap);
  61. }
  62. //修改
  63. @Test
  64. public void updateUser() {
  65. User user = mongoTemplate.findById("5ffbfa2ac290f356edf9b5aa", User.class);
  66. user.setName("test_1");
  67. user.setAge(25);
  68. user.setEmail("493220990@qq.com");
  69. Query query = new Query(Criteria.where("_id").is(user.getId()));
  70. Update update = new Update();
  71. update.set("name", user.getName());
  72. update.set("age", user.getAge());
  73. update.set("email", user.getEmail());
  74. UpdateResult result = mongoTemplate.upsert(query, update, User.class);
  75. long count = result.getModifiedCount();
  76. System.out.println(count);
  77. }
  78. //删除操作
  79. @Test
  80. public void delete() {
  81. Query query =
  82. new Query(Criteria.where("_id").is("61ee936ea3c0a73a98608a31"));
  83. DeleteResult result = mongoTemplate.remove(query, User.class);
  84. long count = result.getDeletedCount();
  85. System.out.println(count);
  86. }

}

  1. <a name="jIaJ4"></a>
  2. ##### 2)MongoRepository测试类
  3. ```java
  4. import com.heyu.mongdb.entity.User;
  5. import com.heyu.mongdb.repository.UserRepository;
  6. import org.junit.Test;
  7. import org.junit.runner.RunWith;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.test.context.SpringBootTest;
  10. import org.springframework.data.domain.*;
  11. import org.springframework.test.context.junit4.SpringRunner;
  12. import java.util.List;
  13. @SpringBootTest
  14. @RunWith(SpringRunner.class)
  15. public class DemomogoApplicationTests1 {
  16. @Autowired
  17. private UserRepository userRepository;
  18. //添加
  19. @Test
  20. public void createUser() {
  21. User user = new User();
  22. user.setAge(20);
  23. user.setName("张三");
  24. user.setEmail("3332200@qq.com");
  25. User user1 = userRepository.save(user);
  26. }
  27. //查询所有
  28. @Test
  29. public void findUser() {
  30. List<User> userList = userRepository.findAll();
  31. System.out.println(userList);
  32. }
  33. //id查询
  34. @Test
  35. public void getById() {
  36. User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();
  37. System.out.println(user);
  38. }
  39. //条件查询
  40. @Test
  41. public void findUserList() {
  42. User user = new User();
  43. user.setName("张三");
  44. user.setAge(20);
  45. Example<User> userExample = Example.of(user);
  46. List<User> userList = userRepository.findAll(userExample);
  47. System.out.println(userList);
  48. }
  49. //模糊查询
  50. @Test
  51. public void findUsersLikeName() {
  52. //创建匹配器,即如何使用查询条件
  53. ExampleMatcher matcher = ExampleMatcher.matching() //构建对象
  54. .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //改变默认字符串匹配方式:模糊查询
  55. .withIgnoreCase(true); //改变默认大小写忽略方式:忽略大小写
  56. User user = new User();
  57. user.setName("三");
  58. Example<User> userExample = Example.of(user, matcher);
  59. List<User> userList = userRepository.findAll(userExample);
  60. System.out.println(userList);
  61. }
  62. //分页查询
  63. @Test
  64. public void findUsersPage() {
  65. Sort sort = Sort.by(Sort.Direction.DESC, "age");
  66. //0为第一页
  67. Pageable pageable = PageRequest.of(0, 10, sort);
  68. //创建匹配器,即如何使用查询条件
  69. ExampleMatcher matcher = ExampleMatcher.matching() //构建对象
  70. .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING) //改变默认字符串匹配方式:模糊查询
  71. .withIgnoreCase(true); //改变默认大小写忽略方式:忽略大小写
  72. User user = new User();
  73. user.setName("三");
  74. Example<User> userExample = Example.of(user, matcher);
  75. //创建实例
  76. Example<User> example = Example.of(user, matcher);
  77. Page<User> pages = userRepository.findAll(example, pageable);
  78. System.out.println(pages);
  79. }
  80. //修改
  81. @Test
  82. public void updateUser() {
  83. User user = userRepository.findById("5ffbfe8197f24a07007bd6ce").get();
  84. user.setName("张三_1");
  85. user.setAge(25);
  86. user.setEmail("883220990@qq.com");
  87. User save = userRepository.save(user);
  88. System.out.println(save);
  89. }
  90. //删除
  91. @Test
  92. public void delete() {
  93. userRepository.deleteById("61ee9ae0a3c0a74360c6bbfb");
  94. }
  95. }

另外还要写一个接口,继承MongoRepository
image.png

三. 理论

1. springData和Mongo的关系:

image.png
image.png
参考:https://blog.csdn.net/qq_28289405/article/details/82382441
https://blog.csdn.net/qq_16313365/article/details/70142729

四. 命令行操作mongo

  1. 使用MongoDB客户端进行操作 mongo

  2. show dbs #查询所有的数据库
  3. 查看当前使用的数据库 db.getName();
  4. 创建一个集合(table) db.createCollection( “集合名”);
  5. 创建并插入表数据(大小写有区分)

db.User.save({name:’zhangsan’,age:21,sex:true})

  1. 查看表数据:db.User.find()

    五. bug:

  2. P68报错:空指针异常!测试类加上@RunWith(SpringRunner.class)

    六. 补充:

    2022.1.24 21:40
    还有一个非常重要的点:就是MongoRepository给的一个非常方便的地方,那就是给出接口,自己写实现类的操作。。。牛不!!!
    image.png
    具体如何操作,当然要具体了解!!!