SpringBoot 集成 MongoDB

       MongoDB是一个非常强大的非关系型数据库，他以集合的形式存储我们的数据到数据库，他灵活的数据结构以及便于快速迭代业务的使用场景，包括他强大的查询相应速度，导致应用场景越来越普遍，下面我们将讲解怎样使用我们的MongoDB集成我们的SpringBoot。
安装：

              这里讲解怎样在win10上面安装我们的MongoDB。下载地点。下载完成以后双击打开下载应用包。

背面一直下一步到完成就好。。。。。。。。。。，下面使用工具链接到我们的MongoDB，不需要账号暗码。

SpringBoot依赖：

  

1. <dependency>
2.     <groupId>org.springframework.boot</groupId>
3.     <artifactId>spring-boot-starter-data-mongodb</artifactId>
4.     <version>3.4.0</version>
5. </dependency>
7. <dependency>
8.     <groupId>org.projectlombok</groupId>
9.     <artifactId>lombok</artifactId>
10.     <version>1.18.28</version>
11.     <scope>compile</scope>
12. </dependency>

复制代码

1. spring.application.name=kafkaTest
3. spring.data.mongodb.host=localhost
4. spring.data.mongodb.port=27017
5. spring.data.mongodb.database=mydatabase
6. #不需要密码验证
7. spring.data.mongodb.uri=mongodb://localhost:27017/mydatabase
8. #需要密码验证
9. #spring.data.mongodb.uri=mongodb://rootuser:rootpwd@localhost:27017/mydatabase

复制代码

1. package org.aogo.kafkatest.entity;
3. import lombok.Data;
4. import lombok.experimental.Accessors;
5. import org.springframework.data.annotation.Id;
6. import org.springframework.data.mongodb.core.mapping.Document;
8. @Document(collection = "users")
9. @Data
10. @Accessors(chain = true)
11. public class User {
12.     @Id
13.     private String id;
14.     private String username;
15.     private String email;
17. }

复制代码

1. package org.aogo.kafkatest.api;
3. import jakarta.annotation.Resource;
4. import lombok.extern.slf4j.Slf4j;
5. import org.aogo.kafkatest.entity.User;
6. import org.aogo.kafkatest.server.UserService;
7. import org.springframework.transaction.annotation.Isolation;
8. import org.springframework.transaction.annotation.Transactional;
9. import org.springframework.web.bind.annotation.*;
12. @Slf4j
13. @RestController
14. @RequestMapping("/api/account")
15. @CrossOrigin(origins = "*")
16. public class AccountController {
18.     @Resource
19.     private UserService userService;
21.     @GetMapping("test")
22.     public User getUser() {
23.         User user = new User();
24.         user.setId("38");
25.         user.setUsername("388");
26.         user.setEmail("38888888@qq.com");
27.         userService.saveUser(user);
28.         if(user != null){
29.             throw new RuntimeException("Username cannot be null");
30.         }
31.         //userService.getUserByUser("28");
32.         return user;
33.     }
35. }

复制代码

1. package org.aogo.kafkatest.server;
3. import org.aogo.kafkatest.entity.User;
4. import org.springframework.data.mongodb.repository.MongoRepository;
6. public interface UserRepository extends MongoRepository<User, String> {
7.     // 可以在这里定义一些自定义的查询方法
8. }

复制代码

1. package org.aogo.kafkatest.server;
3. import org.aogo.kafkatest.entity.User;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.data.domain.*;
6. import org.springframework.stereotype.Service;
8. import java.util.List;
10. @Service
11. public class UserService {
13.     private final UserRepository userRepository;
15.     @Autowired
16.     public UserService(UserRepository userRepository) {
17.         this.userRepository = userRepository;
18.     }
20.     public void saveUser(User user) {
21.         //保存或者更新
22.         userRepository.save(user);
23.     }
25.     public User getUserById(String id) {
26.         return userRepository.findById(id).orElse(null);
27.     }
30.     public Page<User> getUserByUser(String id) {
31.         //分页
32.         Pageable pageable = PageRequest.of(0, 10, Sort.by("id").descending()); // 第 0 页，每页 10 条数据
33.         User user = new User();
34.         user.setUsername("名稱");
35.         Example<User> example = Example.of(user);
36.         // 查询分页结果
37.         Page<User> userPage = userRepository.findAll(example,pageable);
38.         return userPage;
39.     }
41. }

复制代码

常用语法：

1. //切换到数据库
2. use mydatabase
3. //创建用户并赋予权限
4. db.createUser({
5.   user: "rootuser",        // 用户名
6.   pwd: "rootpwd",         // 密码
7.   roles: [
8.     { role: "readWrite", db: "mydatabase" }  // 给用户赋予mydatabase数据库的权限   权限类别给admin类别
9.   ]
10. })
12. //查看用户
13. show users
14. //查看版本号
15. db.version()

复制代码

1. //插入数据
2. db.users.insert({
3.     _id: '50',
4.     username: "7899",
5.     email: "7899"
6. })
8. //查询文档
9. db.users.find()
11. //根据条件查询文档
12. db.users.find({_id:'50'})
14. //保存/更新
15. db.users.save({
16.     _id: '50',
17.     username: "789911",
18.     email: "7899"
19. })
20. //更新语句
21. db.users.update(
22.     { _id: "50" },  // 查询条件
23.     {               // 更新的内容
24.         $set: {
25.             username: "789911",
26.             email: "7899111"
27.         }
28.     }
29. )

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。