Springboot最简单的整合使用Mongodb案例

不念不忘少年蓝@ 2022-05-14 19:11 262阅读 0赞

创建一个springboot项目

然后pom.xml文件：（从pom文件里面可以看出，就一个包导入就可以了。）

<?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.jc</groupId>
       <artifactId>mongodemo</artifactId>
       <version>0.0.1-SNAPSHOT</version>
       <packaging>jar</packaging>
    
       <name>mongodemo</name>
       <description>Demo project for Spring Boot</description>
    
       <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>2.0.5.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-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>

然后，yml文件：

spring:
      data:
        mongodb:
          uri: mongodb://IP地址:端口（27017或者你设置的）/（数据库的名称）

到此，配置的条条框框（虽然没啥）已经搞完，那么我们开始进入使用环节。

第一步是干嘛呢?

先看下，mongodb里面数据的格式:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mzg3OTQw_size_27_color_FFFFFF_t_70][]

从上边截图可以看到，这里面的Collections（大集合），其实就是类似mysql里面的表的那种东西。然后右边的框，可以看到有个Key的概念，其实就是指这个Collections（大集合）里面，你需要获取的小集合信息，在这个小集合里面，实际上是对应一个实体类的，取值的时候就get方法就可以。

上面是简单的介绍一下，其实我们还是看代码吧：  
  
那么，我们先来建一个实体类吧，

UserEntity：

package com.jc.mongodemo.pojo;
    
    import java.io.Serializable;
    
    /**
     * @Author: JCccc
     * @CreateTime: 2018-09-28
     * @Description:
     */
    
    
    
    public class UserEntity implements Serializable {
        private static final long serialVersionUID = -3258839839160856613L;
        private Long id;
        private String userName;
        private String passWord;
        private String type;
    
        @Override
        public String toString() {
            return "UserEntity{" +
                    "id=" + id +
                    ", userName='" + userName + '\'' +
                    ", passWord='" + passWord + '\'' +
                    ", type='" + type + '\'' +
                    '}';
        }
    
        public static long getSerialVersionUID() {
            return serialVersionUID;
        }
    
        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 String getType() {
            return type;
        }
    
        public void setType(String type) {
            this.type = type;
        }
    }

好了，这里需要注意的是，上面实体类的字段，是必须一 一 对 应 mongodb里面某个小集合的 字段的！！！！！否则 ，不能成功取数据！（当然我们这教程是从0开始， 所以我们规定好，插入就行了。 后面取当然也就一一对应了。 但是如果你是直接上来就取数据，那么你就得注意对应了！）

然后写个方法类吧，我这里没严格解耦，

UserDaoImpl：

package com.jc.mongodemo.dao;
    
    import com.jc.mongodemo.pojo.UserEntity;
    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;
    
    /**
     * @Author: JCccc
     * @CreateTime: 2018-09-28
     * @Description:
     */
    @Component
    public class UserDaoImpl  {
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        /**
         * 创建对象
         * @param user
         */
    
        public void saveUser(UserEntity user) {
            mongoTemplate.save(user);
        }
    
    
        public List<UserEntity> findUserByType(String type) {
            Query query=new Query(Criteria.where("type").is(type));
            List<UserEntity> userlist =  mongoTemplate.findAllAndRemove(query , UserEntity.class);
            return userlist;
        }
    
        public List<UserEntity> findUserByCollection(String CollectionName,String type) {
            Query query=new Query(Criteria.where("type").is(type));
            List<UserEntity> userlist =  mongoTemplate.findAllAndRemove(query , UserEntity.class,CollectionName);
            return userlist;
        }
    
    
        /**
         * 根据用户名查询对象
         * @param userName
         * @return
         */
    
        public UserEntity findUserByUserName(String userName) {
            Query query=new Query(Criteria.where("userName").is(userName));
            UserEntity user =  mongoTemplate.findOne(query , UserEntity.class);
            return user;
        }
    
        /**
         * 更新对象
         * @param user
         */
    
        public void updateUser(UserEntity user) {
            Query query=new Query(Criteria.where("id").is(user.getId()));
            Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord());
            //更新查询返回结果集的第一条
            mongoTemplate.updateFirst(query,update,UserEntity.class);
            //更新查询返回结果集的所有
            // mongoTemplate.updateMulti(query,update,UserEntity.class);
        }
    
        /**
         * 删除对象
         * @param id
         */
    
        public void deleteUserById(Long id) {
            Query query=new Query(Criteria.where("id").is(id));
            mongoTemplate.remove(query,UserEntity.class);
        }
    }

从上边可以看到，已经开始使用mongodb了！！！！ 都开始往里面CRUD了！  关键点在于啥？？？   
关键点：

@Autowired    private MongoTemplate mongoTemplate;

这就是告诉项目，我这里要注入mongodb的使用！  
  
好了，然后我们去test里面去调用一下方法结束我们这个简单到极致的教程吧：

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class MongodemoApplicationTests {
    
       @Test
       public void contextLoads() {
       }
    
    
       @Autowired
       private UserDaoImpl userDao;
    
       //...............空着先
    }

然后开始尝试调用方法：

这是增加一个用户信息。

public void testSaveUser() throws Exception {
       UserEntity user=new UserEntity();
       user.setId(106l);
       user.setUserName("小凯");
       user.setPassWord("fffooo123");
       user.setType("A");
       userDao.saveUser(user);
    }

这是查询一个用户信息。

public void findUserByUserName(){
       UserEntity user= userDao.findUserByUserName("小凯");
       System.out.println("user is "+user);
    }

这是更新一个用户信息。

public void updateUser(){
       UserEntity user=new UserEntity();
       user.setId(106l);
       user.setUserName("大凯");
       user.setPassWord("11223344");
       userDao.updateUser(user);
    }

这是删除一个用户信息。

public void deleteUserById(){
       userDao.deleteUserById(106l);
    }

好了，到此结束吧。  
ps： 我这个例子，用户id我用的long类型哈，所以每个数字后面的l是让数字变成Long类型的意思。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM1Mzg3OTQw_size_27_color_FFFFFF_t_70]: /images/20220503/83d0fbf43906428298ec68f396bd93c6.png