springboot集成MongoDB

待我称王封你为后i 2023-06-01 06:23 8阅读 0赞

1.先安装MongoDB（百度一下就有了0.0）。

2.创建springboot项目

3.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.cxb</groupId>
        <artifactId>springboot_mongodb</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
    
        <name>springboot_mongodb</name>
        <description>springboot_mongodb</description>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.9.RELEASE</version>
            <relativePath/> 
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-mongodb</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    
    </project>

4.application.properties

##端口号
    server.port=8888
    
    
    ##mongo配置
    spring.data.mongodb.host=127.0.0.1
    spring.data.mongodb.port=27017
    spring.data.mongodb.database=springboot

5.UserInfo

import org.springframework.data.annotation.Id;
    
    public class UserInfo {
    
        @Id
        private Long id;
    
        private String username;
    
        private String password;
    
        public Long getId() {
            return id;
        }
    
        public void setId(Long id) {
            this.id = id;
        }
    
        public String getUsername() {
            return username;
        }
    
        public void setUsername(String username) {
            this.username = username;
        }
    
        public String getPassword() {
            return password;
        }
    
        public void setPassword(String password) {
            this.password = password;
        }
    
        public UserInfo(Long id, String username, String password) {
            this.id = id;
            this.username = username;
            this.password = password;
        }
    }

6.UserRepository

import com.cxb.entity.UserInfo;
    import org.springframework.data.mongodb.repository.MongoRepository;
    
    public interface UserRepository extends MongoRepository<UserInfo,Long> {
    }

6.1 DAO

package com.dalaoyang.dao;
    
    import com.dalaoyang.entity.UserInfo;
    import org.springframework.beans.factory.annotation.Autowired;
    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.stereotype.Component;
    
    import java.util.List;
    
    //必须要加Componet使得该组件可以被spring管理起来
    @Component
    public class MongoDAO {
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        public void insert(UserInfo user) {
            mongoTemplate.insert(user);
            System.out.println("添加成功");
        }
    
        public void update(UserInfo user) {
            Criteria criteria = Criteria.where("id").in(user.getId());
            Query query = new Query(criteria);
            Update update = new Update();
            update.set("username", user.getUsername());
            update.set("password", user.getPassword());
            mongoTemplate.updateMulti(query, update, UserInfo.class);
            System.out.println("更新成功！！！");
        }
    
        public List<UserInfo> select (Integer id) {
            Criteria criteria = Criteria.where("id").in(id);
            Query query = new Query(criteria);
            return mongoTemplate.find(query,UserInfo.class);
        }
    
        public void delById (Integer id) {
            Criteria criteria = Criteria.where("id").in(id);
            Query query = new Query(criteria);
            mongoTemplate.remove(query, UserInfo.class);
            System.out.println("删除成功！！！");
        }
    
        public List<UserInfo> findAll () {
            return mongoTemplate.findAll(UserInfo.class);
        }
    }

7.controller

import com.cxb.entity.UserInfo;
    import com.dalaoyang.repository.UserRepository;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    @RestController
    public class UserController {
    
        @Autowired
        private UserRepository userRepository;
        
        @Autowired
        private MongoDAO mongoDAO;
    
        //http://localhost:8888/save
        @GetMapping("save")
        public String save(){
            UserInfo userInfo = new UserInfo(System.currentTimeMillis(),"用户"+System.currentTimeMillis(),"123");
            userRepository.save(userInfo);
            return "success";
        }
    
        //http://localhost:8888/getUserList
        @GetMapping("getUserList")
        public List<UserInfo> getUserList(){
            List<UserInfo> userInfoList = userRepository.findAll();
            // 这里两种方式都可以查询出结果
            List<UserInfo> all = mongoDAO.findAll();
            return all;
        }
    
        //http://localhost:8888/delete?id=1525503798382
        @GetMapping("delete")
        public String delete(Long id){
            userRepository.delete(id);
            return "success";
        }
    
        //http://localhost:8888/update?id=1525503912550&username=111&password=222
        @GetMapping("update")
        public String update(Long id,String username,String password){
            UserInfo userInfo = new UserInfo(id,username,password);
            userRepository.save(userInfo);
            return "success";
        }
    }

8.启动类

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    public class SpringbootMongodbApplication {
    
       public static void main(String[] args) {
          SpringApplication.run(SpringbootMongodbApplication.class, args);
       }
    }

9.测试

[http://localhost:8888/save][http_localhost_8888_save] 先保存数据

![2019100223205970.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70][]

数据保存成功。

[http://localhost:8888/getUserList][http_localhost_8888_getUserList] 查询数据。

![20191002232209812.png][]

springboot MongoDB ok！！！

[http_localhost_8888_save]: http://localhost:8888/save
[2019100223205970.png]: /images/20230601/35e3b4e10c8746eebed0495a864d73a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMzcxNzY2_size_16_color_FFFFFF_t_70]: /images/20230601/ace2756e7a3d48638caee787940e0db2.png
[http_localhost_8888_getUserList]: http://localhost:8888/getUserList
[20191002232209812.png]: /images/20230601/f98f8a3316704f6c853225ae5dbde267.png