Springboot连接NoSQL数据库MongoDB，读取集合数据文档

刺骨的言语ヽ痛彻心扉 2023-10-01 12:44 19阅读 0赞

这里有MongoDB搭建配置和启动介绍：

[MongoDB数据库开发环境搭建与配置，Windows环境下\_Zhang Phil-CSDN博客MongoDB是一种NoSQL数据库。本文以Windows环境为例搭建配置MongoDB。MongoDB下载链接：MongoDB Community Download | MongoDBhttps://www.mongodb.com/try/download/community解压后，可以看到在\\bin目录下有两个.exe文件，mongo.exe和mongod.exe。mongo.exe是连接MongoDB数据库的客户端，mongod.exe是服务器端程序。（1）启动MongoDB服务器端。![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/122453754][MongoDB_Windows_Zhang Phil-CSDN_MongoDB_NoSQL_Windows_MongoDB_MongoDB_MongoDB Community Download _ MongoDBhttps_www.mongodb.com_try_download_community_bin_.exe_mongo.exe_mongod.exe_mongo.exe_MongoDB_mongod.exe_1_MongoDB_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_122453754]

下面是在spring boot里面载入MongoDB，然后读取MongoDB的集合数据（基于上面文章创建的MongoDB数据库和集合）。

前提是启动MongoDB数据库：

mongod --dbpath=d:/mongodb/data

（1）写一个类，此类对应MongoDB里面集合的文档：

import org.springframework.data.mongodb.core.mapping.Document;
    import org.springframework.data.mongodb.core.mapping.FieldType;
    import org.springframework.data.mongodb.core.mapping.MongoId;
    
    import java.util.List;
    
    @Document
    public class Person {
        @MongoId(value = FieldType.OBJECT_ID)
        private String id;
    
        private String name;
        private String city;
        private String age;
        private List it;
    
        public Person() {
    
        }
    
        public Person(String id, String name, String city, String age, List it) {
            this.id = id;
            this.name = name;
            this.city = city;
            this.age = age;
            this.it = it;
        }
    
        public String getId() {
            return id;
        }
    
        public void setId(String id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public String getCity() {
            return city;
        }
    
        public void setCity(String city) {
            this.city = city;
        }
    
        public String getAge() {
            return age;
        }
    
        public void setAge(String age) {
            this.age = age;
        }
    
        public List getIt() {
            return it;
        }
    
        public void setIt(List it) {
            this.it = it;
        }
    
        @Override
        public String toString() {
            return "{" +
                    "id='" + id + '\'' +
                    ", name='" + name + '\'' +
                    ", city='" + city + '\'' +
                    ", age='" + age + '\'' +
                    ", it=" + it +
                    '}';
        }
    }

（2）定义Person的存储访问接口：

import org.springframework.data.mongodb.repository.MongoRepository;
    import org.springframework.stereotype.Repository;
    
    
    @Repository
    public interface PersonRepository extends MongoRepository<Person, String> {
    
    }

完成PersonRepository的实现：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.domain.Example;
    import org.springframework.data.domain.Page;
    import org.springframework.data.domain.Pageable;
    import org.springframework.data.domain.Sort;
    import org.springframework.data.mongodb.core.MongoTemplate;
    import org.springframework.data.repository.query.FluentQuery;
    import org.springframework.stereotype.Component;
    
    import java.util.List;
    import java.util.Optional;
    import java.util.function.Function;
    
    @Component
    public class PersonRepositoryImpl implements PersonRepository {
        @Autowired
        private MongoTemplate mongoTemplate;
    
        private final String COLLECTION_NAME = "zhangphil_collection";
    
        @Override
        public Optional<Person> findById(String id) {
            Person person = mongoTemplate.findById(id, Person.class, COLLECTION_NAME);
            return Optional.of(person);
        }
    
        @Override
        public List<Person> findAll() {
            return mongoTemplate.findAll(Person.class, COLLECTION_NAME);
        }
    
    
        @Override
        public <S extends Person> List<S> saveAll(Iterable<S> entities) {
            return null;
        }
    
        @Override
        public List<Person> findAll(Sort sort) {
            return null;
        }
    
        @Override
        public <S extends Person> S insert(S entity) {
            return null;
        }
    
        @Override
        public <S extends Person> List<S> insert(Iterable<S> entities) {
            return null;
        }
    
        @Override
        public <S extends Person> List<S> findAll(Example<S> example) {
            return null;
        }
    
        @Override
        public <S extends Person> List<S> findAll(Example<S> example, Sort sort) {
            return null;
        }
    
        @Override
        public Page<Person> findAll(Pageable pageable) {
            return null;
        }
    
        @Override
        public <S extends Person> S save(S entity) {
            return null;
        }
    
        @Override
        public boolean existsById(String s) {
            return false;
        }
    
        @Override
        public Iterable<Person> findAllById(Iterable<String> strings) {
            return null;
        }
    
        @Override
        public long count() {
            return 0;
        }
    
        @Override
        public void deleteById(String s) {
    
        }
    
        @Override
        public void delete(Person entity) {
    
        }
    
        @Override
        public void deleteAllById(Iterable<? extends String> strings) {
    
        }
    
        @Override
        public void deleteAll(Iterable<? extends Person> entities) {
    
        }
    
        @Override
        public void deleteAll() {
    
        }
    
        @Override
        public <S extends Person> Optional<S> findOne(Example<S> example) {
            return Optional.empty();
        }
    
        @Override
        public <S extends Person> Page<S> findAll(Example<S> example, Pageable pageable) {
            return null;
        }
    
        @Override
        public <S extends Person> long count(Example<S> example) {
            return 0;
        }
    
        @Override
        public <S extends Person> boolean exists(Example<S> example) {
            return false;
        }
    
        @Override
        public <S extends Person, R> R findBy(Example<S> example, Function<FluentQuery.FetchableFluentQuery<S>, R> queryFunction) {
            return null;
        }
    }

重点是前两个函数，findAll和findById。后面的函数本项目中暂不使用。

（3）写一个控制器：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    import java.util.Optional;
    
    @RestController
    @RequestMapping("/person") //父域
    public class PersonController {
        @Autowired
        private PersonRepositoryImpl personRepository;
    
        public PersonController(PersonRepositoryImpl personRepository) {
            this.personRepository = personRepository;
        }
    
        @GetMapping("")
        public String getAllPerson() {
            List<Person> persons = personRepository.findAll();
            String str = "";
            for (Person p : persons) {
                str = str + p + "\n";
            }
    
            return str;
        }
    
        @GetMapping("/{personId}")
        public String findByPersonId(@PathVariable String personId) {
            Optional<Person> optional = personRepository.findById(personId);
            return optional.get().toString();
        }
    }

（4）在application.properties里面定义MongoDB的访问配置：

spring.data.mongodb.host=localhost
    spring.data.mongodb.port=27017
    spring.data.mongodb.database=zhangphil_db

写好后，运行，在浏览器访问 [http://localhost:8080/person][http_localhost_8080_person]

返回结果：

\{id='61dea31fe74004760a936564', name='zhangphil', city='Chengdu', age='2021', it=\[spring, mongo, mysql, python, android, java\]\}

在浏览器访问  
  
[http://localhost:8080/person/61dea31fe74004760a936564][http_localhost_8080_person_61dea31fe74004760a936564]

返回：

\{id='61dea31fe74004760a936564', name='zhangphil', city='Chengdu', age='2021', it=\[spring, mongo, mysql, python, android, java\]\}

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[MongoDB_Windows_Zhang Phil-CSDN_MongoDB_NoSQL_Windows_MongoDB_MongoDB_MongoDB Community Download _ MongoDBhttps_www.mongodb.com_try_download_community_bin_.exe_mongo.exe_mongod.exe_mongo.exe_MongoDB_mongod.exe_1_MongoDB_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_122453754]: https://blog.csdn.net/zhangphil/article/details/122453754
[http_localhost_8080_person]: http://localhost:8080/person
[http_localhost_8080_person_61dea31fe74004760a936564]: http://localhost:8080/person/61dea31fe74004760a936564

发表评论取消回复

表情：

评论列表（有 0 条评论，19人围观）

还没有评论，来说两句吧...

相关阅读

相关 springboot连接mongodb

引入依赖 <dependencies> <dependency> <groupId>org.springframewor

落日映苍穹つ/ 2024年04月03日 09:13/ 0 赞/ 159 阅读

相关 mongodb 学习笔记之二 mongodb入门（数据库、文档和集合）

MongOdb 基本概念： 1、文档是Mongodb中数据的基本单元，类似于关系型数据库中的行。（但比行要复杂的多） 2、集合可以看出是没有字段属性的表。 3、Mongo

r囧r小猫/ 2023年10月16日 21:11/ 0 赞/ 146 阅读

相关【MongoDB】数据库、集合、文档常用CRUD命令

目录一、数据库操作 1、创建数据库操作 2、查看当前有哪些数据库 3、查看当前在使用哪个数据库 4、删除数据库二、集合操作 1、查看有哪些集合 2、删除集合

逃离我推掉我的手/ 2023年10月14日 16:09/ 0 赞/ 190 阅读

相关 spring boot连接NoSQL数据库Redis写入和读取数据

既然是连接Redis数据库，首先需要把Redis数据库启动起来。配置启动Redis详情： [Windows环境搭建最新版NoSQL数据库Redis数据存储服务\_Zhang

淩亂°似流年/ 2023年10月01日 15:39/ 0 赞/ 126 阅读

相关 Springboot连接NoSQL数据库MongoDB，读取集合数据文档

这里有MongoDB搭建配置和启动介绍： [MongoDB数据库开发环境搭建与配置，Windows环境下\_Zhang Phil-CSDN博客MongoDB是一种NoSQL数

刺骨的言语ヽ痛彻心扉/ 2023年10月01日 12:44/ 0 赞/ 20 阅读

相关 springboot连接MongoDB

application.properties: spring.data.mongodb.uri=mongodb://localhost:27017/MongoDBa

秒速五厘米/ 2023年06月03日 02:58/ 0 赞/ 102 阅读

相关 .net core 使用 mongodb（nosql）数据库

首先运行mongodb服务器安装包安装MongoDB.Driver包建立模型 public class Book {

朴灿烈づ我的快乐病毒、/ 2023年03月03日 05:57/ 0 赞/ 138 阅读

相关 NoSql、MongoDb 数据库介绍及MongoDb安装、使用

1、数据库和文件的主要区别数据库有数据库表、行和列的概念，让我们存储操作数据更方便数据库提供了非常方便的接口，可以让 nodejs、php java .n

约定不等于承诺〃/ 2023年02月13日 03:45/ 0 赞/ 41 阅读

相关 MongoDB数据库/集合/文档基本操作

MongoDB官网下载地址：[https://www.mongodb.com/try/download/community][https_www.mongodb.com_try

野性酷女/ 2023年01月16日 02:53/ 0 赞/ 271 阅读

相关 NoSQL之MongoDB Shell连接MongoDB服务

语法 > mongodb://\[username:password@\]host1\[:port1\]\[,host2\[:port2\],…\[,hostN\[:po

淩亂°似流年/ 2022年06月04日 07:21/ 0 赞/ 427 阅读