Spring Boot MongDB的配置及使用方法

绝地灬酷狼 2022-02-03 09:59 927阅读 0赞

**1、MongoDB配置**

*  在pom.xml导入MongoDB的starter，Spring Boot会自动给我们配置MongoDB

<dependency>
       		<groupId>org.springframework.boot</groupId>
       		<artifactId>spring-boot-starter-data-mongodb</artifactId>
       	</dependency>

*  在application.propertis配置MongoDB数据库信息

#Mongodb
    spring.data.mongodb.host=127.0.0.1
    spring.data.mongodb.port=27037
    spring.data.mongodb.database=test
    spring.data.mongodb.username=admin
    spring.data.mongodb.password=admin

*  在Spring Boot启动入口的Application类上使用@EnableMongoAuditing注解，此注解的作用是启用MonoDB自动检测，可以使@CreatedDate（创建数据时自动填入创建时间）、@LastModifiedDate（创建或更新数据时自动填入修改时间）等注解生效

@SpringBootApplication
    @EnableMongoAuditing
    public class MyApplication { 
    
    	public static void main(String[] args) { 
    		SpringApplication.run(MyApplication.class, args);
    	}
    
    }

*  在MongoDB中新增数据库名，及设置数据库的用户名和密码，在此我们使用Robo工具进行配置  
    1）创建新的数据库  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70]  
    2）设置数据库名为test  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70 1]  
    3）右击数据库，选择Open Shell打开命令行界面  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70 2]  
    4）设置用户名和密码

db.createUser({user:"admin",pwd:"admin",roles:["readWrite"]})执行此命令

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70 3]  
点击执行按钮，设置成功。

*  MongoDB配置完成

**2、MongoDB的使用方法**

*  创建BaseDocument基类

import lombok.EqualsAndHashCode;
    import lombok.Getter;
    import lombok.Setter;
    import org.springframework.data.annotation.CreatedDate;
    import org.springframework.data.annotation.Id;
    import org.springframework.data.annotation.LastModifiedDate;
    
    import java.io.Serializable;
    import java.util.Date;
    
    /** * Document - 基类 */
    @Getter
    @Setter
    @EqualsAndHashCode
    public abstract class BaseDocument implements Serializable { 
    
       private static final long serialVersionUID = -5420167694405035912L;
       /** ID */
       @Id
       private String id;
       /** 创建日期 */
       @CreatedDate
       private Date createdDate;
       /** 修改日期 */
       @LastModifiedDate
       private Date lastModifiedDate;
    
    }

*  创建实体Document

import lombok.Getter;
    import lombok.Setter;
    import org.springframework.data.mongodb.core.index.Indexed;
    import org.springframework.data.mongodb.core.mapping.Document;
    
    import java.util.Date;
    import java.util.List;
    
    /** * Document - 用户 */
    @Getter
    @Setter
    @Document
    public class User extends BaseDocument { 
    
       private static final long serialVersionUID = 1599863084430069988L;
       /** 用户名 */
       @Indexed(unique = true)
       private String username;
       /** 手机号码 */
       @Indexed(unique = true)
       private String mobile;
       /** 密码 */
       private String password;
    }

*  实现MongoRepository接口

import org.springframework.data.mongodb.repository.MongoRepository;
    
    public interface UserRepository extends MongoRepository<User, String> { 
       /* 通过用户名查找用户 */
       User findByUsername(String username);
    }

Spring Boot给我们自动实现了对应的Repository接口，这里我们无需实现

*  设置或获取User数据

import lombok.AllArgsConstructor;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    /* 测试 */
    @AllArgsConstructor(onConstructor = @__({ @Autowired}))
    @Controller
    @RequestMapping("/user")
    public class UserController { 
    
       private final UserRepository userRepository ;
    
       /* 保存数据 */
       @PostMapping("/save")
       @ResponseBody
       public Message save(){ 
       	User user = new User();
           user.setUsername("zhagnsan");
           user.setMobile("13000000000")
           user.setPassword("abc123")
           userRepository .save(user);
           return Message.success("");
       }
       
       /* 通过用户名查找用户 */
       @GetMapping
       @ResponseBody
       public User get(String username){ 
       	return userRepository.findByUsername(username);
       }
    }

还可以使用MongoTemplate自定义查询条件去访问或设置数据

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70]: /images/20220203/36d166460f8e42c1bf6e79e87f4cb6b1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70 1]: /images/20220203/79c6d7766a8741b7b738014de7caf99a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70 2]: /images/20220203/f07f1945c7224e54aa621a3f3ec15c54.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L01pY2hlYW4_size_16_color_FFFFFF_t_70 3]: /images/20220203/54844874600d4fdbb7e758ed75a13cf2.png