springboot整合mongodb增删改查入门

忘是亡心i 2022-08-31 11:23 291阅读 0赞

###  ###

*   *  1.配置与依赖
     *  2.实体与repository层
     *  3.测试

适合新手。  
要求：安装好mongodb  
代码和运行程序如下：  
目录：  
![在这里插入图片描述][5d6d18a7f90f426b9fbeb0043e12b056.png]  
![在这里插入图片描述][2531bdfe110147b5ad5f46f54095331b.png]

## 1.配置与依赖 ##

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

spring.data.mongodb.uri=mongodb://127.0.0.1:27017/test

## 2.实体与repository层 ##

public class User implements Serializable { 
            private static final long serialVersionUID = -3258839839160856613L;
            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;
            }
    
            @Override
            public String toString() { 
                    return "UserEntity{" +
                            "id=" + id +
                            ", userName='" + userName + '\'' +
                            ", passWord='" + passWord + '\'' +
                            '}';
            }
    }

Repository

public interface UserRepository { 
    
        public void saveUser(User user);
    
        public User findUserByUserName(String userName);
    
        public long updateUser(User user);
    
        public void deleteUserById(Long id);
    
    }

接口实现类

package com.neo.repository.impl;
    
    import com.mongodb.client.result.UpdateResult;
    import com.neo.repository.UserRepository;
    import com.neo.model.User;
    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;
    
    /** * Created by summer on 2017/5/5. */
    @Component
    public class UserRepositoryImpl implements UserRepository { 
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        /** * 创建对象 * @param user */
        @Override
        public void saveUser(User user) { 
            mongoTemplate.save(user);
        }
    
        /** * 根据用户名查询对象 * @param userName * @return */
        @Override
        public User findUserByUserName(String userName) { 
            Query query=new Query(Criteria.where("userName").is(userName));
            User user =  mongoTemplate.findOne(query , User.class);
            return user;
        }
    
        /** * 更新对象 * @param user */
        @Override
        public long updateUser(User user) { 
            Query query=new Query(Criteria.where("id").is(user.getId()));
            Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord());
            //更新查询返回结果集的第一条
            UpdateResult result =mongoTemplate.updateFirst(query,update,User.class);
            //更新查询返回结果集的所有
            // mongoTemplate.updateMulti(query,update,UserEntity.class);
            if(result!=null)
                return result.getMatchedCount();
            else
                return 0;
        }
    
        /** * 删除对象 * @param id */
        @Override
        public void deleteUserById(Long id) { 
            Query query=new Query(Criteria.where("id").is(id));
            mongoTemplate.remove(query,User.class);
        }
    }

## 3.测试 ##

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class UserRepositoryTest { 
    
        @Autowired
        private UserRepository userDao;
    
        @Test
        public void testSaveUser() throws Exception { 
            User user=new User();
            user.setId(2l);
            user.setUserName("小明");
            user.setPassWord("fffooo123");
            userDao.saveUser(user);
        }
    
        @Test
        public void findUserByUserName(){ 
           User user= userDao.findUserByUserName("小明");
           System.out.println("user is "+user);
        }
    
        @Test
        public void updateUser(){ 
            User user=new User();
            user.setId(2l);
            user.setUserName("天空");
            user.setPassWord("fffxxxx");
            userDao.updateUser(user);
        }
    
        @Test
        public void deleteUserById(){ 
            userDao.deleteUserById(1l);
        }
    
    }

运行testSaveUser  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70]  
更新：  
![在这里插入图片描述][6c3e5a7567e746b1b0be475cb6dbca97.png]

[5d6d18a7f90f426b9fbeb0043e12b056.png]: /images/20220829/da389bbd85c5414398d4121316967527.png
[2531bdfe110147b5ad5f46f54095331b.png]: /images/20220829/abd65151aa6c481b858169c2241ec597.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70]: /images/20220829/76f9288c47f647cc980b43670716f4ea.png
[6c3e5a7567e746b1b0be475cb6dbca97.png]: /images/20220829/9183cf3884494455b7981bec67454f55.png