六.SpringBoot集成实例系列-单数据源mongodb(权限控制)

待我称王封你为后i 2022-06-08 03:44 168阅读 0赞

文章列表  
  
本系列将通过实例分别实现Springboot集成mybatis(mysql),mail,mongodb,cassandra,scheduler,redis,kafka,shiro,websocket。  
具体文章系列如下：  
一.SpringBoot集成实例系列-xml型单数据源mybatis  
二.SpringBoot集成实例系列-xml型多数据源mybatis  
三.SpringBoot集成实例系列-注解型单数据源mybatis  
四.SpringBoot集成实例系列-注解型多数据源mybatis  
五.SpringBoot集成实例系列-邮件email  
六.SpringBoot集成实例系列-单数据源mongodb  
七.SpringBoot集成实例系列-多数据源mongodb  
八.SpringBoot集成实例系列-缓存redis  
九.SpringBoot集成实例系列-数据库cassandra  
十.SpringBoot集成实例系列-定时任务scheduler  
十一.SpringBoot集成实例系列-消息队列kafka  
十二.SpringBoot集成实例系列-消息推送websocket

MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。

本文将通过实例实现springboot与mongodb集成。  
1.需求  
实现用户的增删查改  
2.技术要点

2.1 springboot集成mongodb配置

![Center][]

通过username和password实现mongodb权限控制

2.2 MongoTemplate依赖注入

![Center 1][]

就像Spring提供的JDBC，hibernate和ibatis的template一样，spring-data-mongodb也提供了一个基础的泛型MongoTemplate供开发者可以快速的利用代码完成基础的crud工作。在实践中可以考虑完全省去dao层的设计，直接在service层注入相应的template实例。  
spring-data-mongodb详情操作：  
[https://docs.spring.io/spring-data/data-mongodb/docs/current/reference/html/][https_docs.spring.io_spring-data_data-mongodb_docs_current_reference_html]  
3.代码实现

3.1 项目结构

![Center 2][]

3.2 properties配置文件

spring.application.name=spirngboot-int-mongodbeg
    
    spring.data.mongodb.database=#
    spring.data.mongodb.host=#
    spring.data.mongodb.password=#
    spring.data.mongodb.port=27017
    spring.data.mongodb.username=#

3.3 UserEntity实体

package com.lm.entity;
    
    import java.io.Serializable;
    
    public class UserEntity 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 + '\'' +
                            '}';
            }
    }

3.4 MongoTemplate操作

package com.lm.dao.impl;
    
    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 com.lm.dao.UserDao;
    import com.lm.entity.UserEntity;
    import com.mongodb.WriteResult;
    
    @Component
    public class UserDaoImpl implements UserDao {
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        /**
         * 创建对象
         * @param user
         */
        @Override
        public void saveUser(UserEntity user) {
            mongoTemplate.save(user);
        }
    
        /**
         * 根据用户名查询对象
         * @param userName
         * @return
         */
        @Override
        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
         */
        @Override
        public int 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());
            //更新查询返回结果集的第一条
            WriteResult result =mongoTemplate.updateFirst(query,update,UserEntity.class);
            //更新查询返回结果集的所有
            // mongoTemplate.updateMulti(query,update,UserEntity.class);
            if(result!=null)
                return result.getN();
            else
                return 0;
        }
    
        /**
         * 删除对象
         * @param id
         */
        @Override
        public void deleteUserById(Long id) {
            Query query=new Query(Criteria.where("id").is(id));
            mongoTemplate.remove(query,UserEntity.class);
        }
    }

3.5 测试用例

package com.lm;
    
    import org.junit.Test;
    import org.springframework.beans.factory.annotation.Autowired;
    
    import com.lm.dao.UserDao;
    import com.lm.entity.UserEntity;
    
    public class UserDaoTest extends AppTest {
    
        @Autowired
        private UserDao userDao;
    
        @Test
        public void testSaveUser() throws Exception {
            UserEntity user=new UserEntity();
            user.setId(2l);
            user.setUserName("小明");
            user.setPassWord("xiaoming1");
            userDao.saveUser(user);
        }
    
        @Test
        public void findUserByUserName(){
           UserEntity user= userDao.findUserByUserName("小明");
           System.out.println("user is "+user);
        }
    
        @Test
        public void updateUser(){
            UserEntity user=new UserEntity();
            user.setId(2l);
            user.setUserName("小红");
            user.setPassWord("小红1");
            userDao.updateUser(user);
        }
    
        @Test
        public void deleteUserById(){
            userDao.deleteUserById(1l);
        }
    
    }

3.6 实例结果

![Center 3][]

4. 代码地址  
Github: [https://github.com/a123demi/spring-boot-integration][https_github.com_a123demi_spring-boot-integration]

[Center]: /images/20220608/7160937d6c954f31b6b592affe382ffa.png
[Center 1]: /images/20220608/2ec5f525dd1349f6b89d0ec73b17ca1d.png
[https_docs.spring.io_spring-data_data-mongodb_docs_current_reference_html]: https://docs.spring.io/spring-data/data-mongodb/docs/current/reference/html/
[Center 2]: /images/20220608/965ce02137f14d1eb6a2328f137cb2f6.png
[Center 3]: /images/20220608/e27b2868645e4d9f94f84e37a55b3927.png
[https_github.com_a123demi_spring-boot-integration]: https://github.com/a123demi/spring-boot-integration