经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 数据库/运维 » MongoDB » 查看文章
Spring Boot MongoDB
来源：cnblogs　　作者：废物大师兄　　时间：2022/1/17 11:00:10　　对本文有异议

1.  Linux下启动MongoDB并使用mongosh连接

启动方式有两种：

  • systemctl start mongod
  • mongod  <选项参数>

启动的时候有可能会报类似如下的错误：

ExecStart=/usr/bin/mongod $OPTIONS (code=exited, status=14)

mongod.service: Control process exited, code=exited status=14

当看到这种“code=exited, status=14”的时候，一般是文件或目录权限问题，即执行mongodb启动命令的用户对某些文件或目录没有访问权限，此时应检查一些几个文件或目录：

  • /var/run/mongodb/
  • /var/log/mongodb/
  • /var/lib/mongo/
  • /tmp/*.sock

看看这些文件或目录的所有者和所属组是否正确

  1. chown -R mongodb:mongodb /var/lib/mongodb
  2. chown -R mongodb:mongodb /var/log/mongodb/
  3. chown -R mongodb:mongodb /var/run/mongodb/
  4. chown mongodb:mongodb /tmp/mongodb-27017.sock

首先，不启用访问控制，创建一个用户管理员

然后，启用访问控制，用用户管理员认证，再创建其它用户

备忘录

  1. ls -l /var/run/mongodb/
  2. ls -l /var/log/mongodb/
  3. ls -l /var/lib/mongo/
  4. ls -l /tmp/*.sock
  6. id
  8. rm -rf /tmp/mongodb-27017.sock
  10. systemctl start mongod
  12. mongosh
  14. test> use admin
  15. admin> db.createUser(
  16.       {
  17.           user: "myUserAdmin",
  18.           pwd: passwordPrompt(),
  19.           roles: [
  20.               { role: "userAdminAnyDatabase", db: "admin" },
  21.               { role: "readWriteAnyDatabase", db: "admin" }
  22.           ]
  23.         }
  24.     )
  27. sudo vim /etc/mongod.conf
  28. sudo systemctl restart mongod
  30. mongosh --port 27017  --authenticationDatabase "admin"  -u "myUserAdmin" -p
  32. test> use book
  33. switched to db book
  34. book> db.chinese.insertOne({title:"语文"})
  36. test> use admin
  37. switched to db admin
  38. admin> db.auth("myUserAdmin","123456")
  39. { ok: 1 }
  40. admin> use book
  41. switched to db book
  42. book> db.createUser({user:"zhangsan",pwd:"123456",roles:[{role:"readWrite",db:"book"}]})
  43. { ok: 1 }
  44. book> db.auth("zhangsan","123456")
  45. { ok: 1 }
  46. book> show collections

2.  Docker 运行 MongoDB

方式一：另启一个容器去连接（PS：相当于远程连接）

  1. docker run -d --network my-network --name my-mongo     -e MONGO_INITDB_ROOT_USERNAME=mongoroot     -e MONGO_INITDB_ROOT_PASSWORD=123456     -v /data/mongo/db:/data/db     -p 27017:27017     mongo
  4. docker run -it --rm --network my-network mongo     mongosh --host my-mongo         -u mongoroot         -p 123456         --authenticationDatabase admin

方式二：从运行MongoDB实例的容器内部进行连接（PS：相当于本地连接）

  1. docker run -d --network my-network --name my-mongo     -e MONGO_INITDB_ROOT_USERNAME=mongoroot     -e MONGO_INITDB_ROOT_PASSWORD=123456     -v /data/mongo/db:/data/db     -p 27017:27017     mongo
  4. docker exec -it my-mongo mongosh

备忘录

  1. docker run -d --network my-network --name my-mongo     -e MONGO_INITDB_ROOT_USERNAME=mongoroot     -e MONGO_INITDB_ROOT_PASSWORD=123456     -v /data/mongo/db:/data/db     -p 27017:27017     mongo
  3. docker run -it --rm --network my-network mongo     mongosh --host my-mongo         -u mongoroot         -p 123456         --authenticationDatabase admin 
  6. docker exec -it my-mongo mongosh 
  8. docker run -it --rm mongo mongosh --help
  9. docker exec -it some-mongo bash
  10. docker logs -f some-mongo
  12. docker exec -it my-mongo mongosh 
  13. use admin
  14. db.auth("myUserAdmin","123456")
  15. db.createUser({user:"hello",pwd:"world",roles:[{role:"readWrite",db:"movie"}]})

补充

不建议用root用户来运行MongoDB

https://docs.mongodb.com/manual/tutorial/install-mongodb-on-red-hat/

3.  Spring Boot 集成 MongoDB

maven依赖

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

完整的pom.xml如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.6.2</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.cjs.example</groupId>
  12.     <artifactId>demo-mongodb</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>demo-mongodb</name>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.     </properties>
  19.     <dependencies>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-data-mongodb</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-web</artifactId>
  27.         </dependency>
  29.         <dependency>
  30.             <groupId>org.projectlombok</groupId>
  31.             <artifactId>lombok</artifactId>
  32.             <optional>true</optional>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>org.springframework.boot</groupId>
  36.             <artifactId>spring-boot-starter-test</artifactId>
  37.             <scope>test</scope>
  38.         </dependency>
  39.     </dependencies>
  41.     <build>
  42.         <plugins>
  43.             <plugin>
  44.                 <groupId>org.springframework.boot</groupId>
  45.                 <artifactId>spring-boot-maven-plugin</artifactId>
  46.                 <configuration>
  47.                     <excludes>
  48.                         <exclude>
  49.                             <groupId>org.projectlombok</groupId>
  50.                             <artifactId>lombok</artifactId>
  51.                         </exclude>
  52.                     </excludes>
  53.                 </configuration>
  54.             </plugin>
  55.         </plugins>
  56.     </build>
  58. </project>

application.yml

  1. spring:
  2.   data:
  3.     mongodb:
  4.       host: 192.168.28.32
  5.       port: 27017
  6.       database: movie
  7.       username: hello
  8.       password: world
  9. #      uri: mongodb://192.168.28.32:27017

连接字符串格式，参见  https://docs.mongodb.com/manual/reference/connection-string/

方式一：MongoTemplate

首先，定义一个实体类

  1. package com.cjs.example.domain;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  6. import org.springframework.data.annotation.Id;
  7. import org.springframework.data.mongodb.core.index.Indexed;
  8. import org.springframework.data.mongodb.core.mapping.Document;
  10. import java.io.Serializable;
  11. import java.util.List;
  13. /**
  14.  * @Author ChengJianSheng
  15.  * @Date 2022/1/12
  16.  */
  17. @Data
  18. @NoArgsConstructor
  19. @AllArgsConstructor
  20. @Document(collection = "film")
  21. public class Film implements Serializable {
  23.     @Id
  24.     private String id;
  26.     private String name;
  28.     private List<String> category;
  29. }

然后，利用MongoTemplate进行操作

  1. package com.cjs.example;
  3. import com.cjs.example.domain.Film;
  4. import com.cjs.example.repository.FilmRepository;
  5. import org.junit.jupiter.api.Test;
  6. import org.springframework.boot.test.context.SpringBootTest;
  7. import org.springframework.data.mongodb.core.MongoTemplate;
  8. import org.springframework.data.mongodb.core.query.Criteria;
  9. import org.springframework.data.mongodb.core.query.Query;
  11. import javax.annotation.Resource;
  12. import java.util.Arrays;
  13. import java.util.List;
  15. @SpringBootTest
  16. class DemoMongodbApplicationTests {
  18.     @Resource
  19.     private MongoTemplate mongoTemplate;
  22.     /**
  23.      * movie> db.createUser({user:"hello",pwd:"world",roles:["readWrite"]})
  24.      */
  25.     @Test
  26.     void contextLoads() {
  27.         Film film = new Film();
  28.         film.setName("我和我的父辈");
  29.         film.setCategory(Arrays.asList("剧情"));
  30.         mongoTemplate.insert(film);
  31.     }
  33.     @Test
  34.     void testQuery() {
  35.         List<Film> filmList = mongoTemplate.findAll(Film.class);
  36.         System.out.println(filmList);
  38.         Query query = new Query();
  39.         query.addCriteria(Criteria.where("name").is("我和我的父辈").and("category").in("爱情","战争","剧情"));
  40.         Film film = mongoTemplate.findOne(query, Film.class);
  41.         System.out.println(film);
  42.     }
  44.     @Test
  45.     void testSave() {
  46.         Film film = new Film();
  47.         film.setId("asdfgh");
  48.         film.setName("长津湖");
  49.         film.setCategory(Arrays.asList("战争","历史"));
  50.         mongoTemplate.save(film);
  51.     }
  53. }

方式二：Spring Data MongoDB Repositories 

定义一个Repository

  1. package com.cjs.example.repository;
  3. import com.cjs.example.domain.Film;
  4. import org.springframework.data.repository.CrudRepository;
  6. import java.util.List;
  8. /**
  9.  * @Author ChengJianSheng
  10.  * @Date 2022/1/12
  11.  */
  12. public interface FilmRepository extends CrudRepository<Film, String> {
  13.     
  14.     List<Film> findByName(String name);
  15. }

完整测试代码如下：

  1. package com.cjs.example;
  3. import com.cjs.example.domain.Film;
  4. import com.cjs.example.repository.FilmRepository;
  5. import org.junit.jupiter.api.Test;
  6. import org.springframework.boot.test.context.SpringBootTest;
  7. import org.springframework.data.mongodb.core.MongoTemplate;
  8. import org.springframework.data.mongodb.core.query.Criteria;
  9. import org.springframework.data.mongodb.core.query.Query;
  11. import javax.annotation.Resource;
  12. import java.util.Arrays;
  13. import java.util.List;
  15. @SpringBootTest
  16. class DemoMongodbApplicationTests {
  18.     @Resource
  19.     private MongoTemplate mongoTemplate;
  21.     @Resource
  22.     private FilmRepository filmRepository;
  24.     /**
  25.      * movie> db.createUser({user:"hello",pwd:"world",roles:["readWrite"]})
  26.      */
  27.     @Test
  28.     void contextLoads() {
  29.         Film film = new Film();
  30.         film.setName("我和我的父辈");
  31.         film.setCategory(Arrays.asList("剧情"));
  32.         mongoTemplate.insert(film);
  33.     }
  35.     @Test
  36.     void testQuery() {
  37.         List<Film> filmList = mongoTemplate.findAll(Film.class);
  38.         System.out.println(filmList);
  40.         Query query = new Query();
  41.         query.addCriteria(Criteria.where("name").is("我和我的父辈").and("category").in("爱情","战争","剧情"));
  42.         Film film = mongoTemplate.findOne(query, Film.class);
  43.         System.out.println(film);
  44.     }
  46.     @Test
  47.     void testSave() {
  48.         Film film = new Film();
  49.         film.setId("asdfgh");
  50.         film.setName("长津湖");
  51.         film.setCategory(Arrays.asList("战争","历史"));
  52.         mongoTemplate.save(film);
  53.     }
  55.     @Test
  56.     void testSaveByRepository() {
  57.         filmRepository.save(new Film("1234", "火影忍者", Arrays.asList("动画","喜剧","动作","冒险")));
  58.     }
  60.     @Test
  61.     void testQueryByRepository() {
  62.         Film film = filmRepository.findById("1234").orElse(null);
  63.         System.out.println(film);
  64.         film = filmRepository.findByName("火影忍者").get(0);
  65.         System.out.println(film);
  67.         filmRepository.findAll().forEach(System.out::println);
  68.     }
  69. }

工程结构如下：

原文链接：http://www.cnblogs.com/cjsblog/p/15795184.html

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

MongoDB热门文章

  • MongoDB 数组查询（$elemMatch）、更新操作(占位符$)详解
  • MongoDB 聚合分组取第一条记录的案例及实现
  • 利用“海底捞算法”在MongoDB中优雅地存储一棵树
  • 瞧一瞧！这儿实现了MongoDB的增量备份与还原（含部署代码）
  • MongoDB 安装
  • MongoDB Python官方驱动 PyMongo 的简单封装
  • 记一次Mongodb数据库查询之包含所有指定元素的数组或者都在指定元素的数组中 - du-blog
  • Java将日期类型Date时间戳转换为MongoDB的时间类型数据
  • MongoDB动态建表方案（官方原生驱动）
  • MongoDB的模糊查询操作(类关系型数据库的 like 和 not like)

    • MongoDB推荐文章

  • SpringBoot集成Mongodb文档数据库
  • 用Python脚本迁移MongoDB数据到金仓-kingbase数据库 - 惟-koko
  • 使用Docker搭建MongoDB 5.0版本副本集集群
  • MongoDB 中的事务
  • 【最佳实践】高可用mongodb集群(1分片+3副本):规划及部署
  • 【最佳实践】MongoDB导出导入数据
  • MongoDB从入门到实战之.NET Core使用MongoDB开发ToDoList系统（8）-Ant Design Blazor前端框架搭建
  • 基于SqlSugar的开发框架循序渐进介绍（27）-- 基于MongoDB的数据库操作整合
  • .NET Core MongoDB数据仓储和工作单元模式实操
  • .NET Core MongoDB数据仓储和工作单元模式封装

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号