SpringBoot 集成FluentMybatis 实现简单增删改查功能

野性酷女 2023-10-10 13:24 47阅读 0赞

## 本文基于上一篇：[SpringBoot 集成FluentMybatis 框架][SpringBoot _FluentMybatis] ##

## 完整pom.xml 文件 ##

<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.digipower</groupId>
    	<artifactId>Single</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.9.RELEASE</version>
    		<relativePath /> 
    	</parent>
    
    	<properties>
    		<java.version>1.8</java.version>
    		<maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>
    		<fluent-mybatis.version>1.8.7</fluent-mybatis.version>
    	</properties>
    
    	<dependencies>
    		<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>
    
    		
    		
    		<dependency>
    			<groupId>com.github.atool</groupId>
    			<artifactId>fluent-mybatis</artifactId>
    			<version>${fluent-mybatis.version}</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>com.github.atool</groupId>
    			<artifactId>fluent-mybatis-processor</artifactId>
    			<scope>provided</scope>
    			<version>${fluent-mybatis.version}</version>
    		</dependency>
    		<dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.2.0</version>
            </dependency>
    
    		
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<version>8.0.11</version>
    		</dependency>
    
    
    		
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		
    		<dependency>
    			<groupId>com.google.guava</groupId>
    			<artifactId>guava</artifactId>
    			<version>30.1.1-jre</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>cn.hutool</groupId>
    			<artifactId>hutool-all</artifactId>
    			<version>5.5.2</version>
    		</dependency>
    
    
    	</dependencies>
    
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    				<configuration>
    					<excludes>
    						<exclude>
    							<groupId>org.projectlombok</groupId>
    							<artifactId>lombok</artifactId>
    						</exclude>
    					</excludes>
    				</configuration>
    			</plugin>
    		</plugins>
    	</build>
    
    
    
    </project>

## application.properties 配置 ##

# 指定服务端口
    server.port=9092
    # 指定日志文件配置
    logging.config=classpath:logback.xml
    # MyBatis mysql8 配置
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/banan_test?serverTimezone=Asia/Shanghai&useSSL=false&allowPublicKeyRetrieval=true&allowMultiQueries=true
    spring.datasource.username=root
    spring.datasource.password=123456
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

## logback.xml 错误日志配置 ##

<?xml version="1.0" encoding="UTF-8"?> 
      
      
      
      
      
      
      
    <configuration scan="true" scanPeriod="60 seconds" debug="false">  
          
        <property name="log_dir" value="/logs/single" />  
          
        <property name="maxHistory" value="30"/>  
      
      
          
        <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">  
              
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger -%msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
          
        <appender name="ERROR" class="ch.qos.logback.core.rolling.RollingFileAppender">  
              
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>ERROR</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
              
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/error.log</fileNamePattern>  
                  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
                      
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
        <appender name="WARN" class="ch.qos.logback.core.rolling.RollingFileAppender">  
              
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>WARN</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/warn.log  
                </fileNamePattern>  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
        <appender name="INFO" class="ch.qos.logback.core.rolling.RollingFileAppender">  
              
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>INFO</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/info.log  
                </fileNamePattern>  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
        <appender name="DEBUG" class="ch.qos.logback.core.rolling.RollingFileAppender">  
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>DEBUG</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/debug.log  
                </fileNamePattern>  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
        
        <logger name="org.springframework.web"/>
        <logger name="com.single" />
    		
          
          
        <root level="ERROR">  
              
            <appender-ref ref="STDOUT" />  
              
            <appender-ref ref="ERROR" />  
            <appender-ref ref="INFO" />  
            <appender-ref ref="WARN" />  
            <appender-ref ref="DEBUG" />  
        </root>  
    </configuration>

程序启动入口：

package com.single;
    
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    @MapperScan({"com.single.entity.mapper"})
    public class SingleApplication {
    
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(SingleApplication.class, args);
    	}
    
    }

主要功能实现:

*  标记程序入口
 *  扫描Mapper

## 程序配置化对象 ##

package com.single.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import cn.org.atool.fluent.mybatis.spring.MapperFactory;
    
    @Configuration
    public class SingleConfig {
    	// 定义fluent mybatis的MapperFactory
    	@Bean
    	public MapperFactory mapperFactory() {
    		return new MapperFactory();
    	}
    
    }

主要功能:

*  实列化FluentMybatis 之MapperFactory工厂类对象。

## 程序拦截器 ##

package com.single.filter;
    
    import java.io.IOException;
    import javax.servlet.Filter;
    import javax.servlet.FilterChain;
    import javax.servlet.FilterConfig;
    import javax.servlet.ServletException;
    import javax.servlet.ServletRequest;
    import javax.servlet.ServletResponse;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.stereotype.Component;
    
    /**
     * 
     * @ClassName:  CorsFilter   
     * @Description: SpringBoot 跨域处理拦截器
     */
    
    @Component
    public class CROSFilter implements Filter {
    	public static final Logger logger = LoggerFactory.getLogger(CROSFilter.class);
    	
    	@Override
    	public void init(FilterConfig filterConfig) throws ServletException {
    		// TODO Auto-generated method stub
    		
    	}
    
    	@Override
    	public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain)
    			throws IOException, ServletException {
    		HttpServletResponse response = (HttpServletResponse) res;  
    		  
            HttpServletRequest reqs = (HttpServletRequest) req;  
            /*
             * 跨域设置允所有请求跨域 
             * 如果允许指定的客户端跨域设置: http://127.0.0.1:8020
             */
            response.setHeader("Access-Control-Allow-Origin","*");  
            response.setHeader("Access-Control-Allow-Credentials", "true");  
            response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");  
            response.setHeader("Access-Control-Max-Age", "3600");  
            response.setHeader("Access-Control-Allow-Headers", "Content-Type");  
            if (((HttpServletRequest) req).getMethod().equals("OPTIONS")) {
                response.getWriter().println("ok");
                return;
            }
    
            chain.doFilter(req, res);  
    	}
    
    	@Override
    	public void destroy() {
    		// TODO Auto-generated method stub
    		
    	}
    
    }

主要功能:

*  实现CROS跨域请求

## 程序控制层 ##

package com.single.controller;
    
    import javax.annotation.Resource;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    import com.single.entity.UcasAuthUserEntity;
    import com.single.entity.mapper.UcasAuthUserMapper;
    
    /**
     * 
     * @ClassName: UserController
     * @Description: 用户管理
     */
    @Controller
    @RequestMapping("/api/user")
    public class UserController {
    	@Resource
    	UcasAuthUserMapper userMapper;
    
    	/**
    	 * 根据ID查询数据1
    	 * 
    	 * @param id
    	 * @return
    	 */
    	@RequestMapping(value = "/getByIdOne", method = RequestMethod.GET)
    	@ResponseBody
    	public UcasAuthUserEntity getByIdOne(HttpServletRequest req, HttpServletResponse res) {
    		String id = req.getParameter("sid");
    		return userMapper.findById(id);
    	}
    
    	/**
    	 * 根据ID删除
    	 * 
    	 * @param id
    	 */
    
    	@RequestMapping(value = "/deleteById", method = RequestMethod.GET)
    	public void deleteById(HttpServletRequest req, HttpServletResponse res) {
    		String sid = req.getParameter("sid");
    		userMapper.deleteById(sid);
    	}
    
    	/**
    	 * 根据ID进行更新
    	 * 
    	 * @param userEntity
    	 * @return
    	 */
    	@RequestMapping(value = "/updateById", method = RequestMethod.POST)
    	@ResponseBody
    	public UcasAuthUserEntity updateById(@RequestBody UcasAuthUserEntity userEntity) {
    		int b = userMapper.updateById(userEntity);
    		if (b > 0) {
    			return userMapper.findById(userEntity.getSid());
    		}
    		return null;
    	}
    
    	/**
    	 * 新增
    	 * 
    	 * @param userEntity
    	 * @return
    	 */
    	@RequestMapping(value = "/insert", method = RequestMethod.POST)
    	@ResponseBody
    	public String insert(@RequestBody UcasAuthUserEntity userEntity) {
    		boolean target = userMapper.saveOrUpdate(userEntity);
    		if(target){
    			return "success";
    		}
    		return "error";
    	}
    
    }

主要功能

*  实现用户表简单增删改查功能。

FluentMyBatis 生成工具生成类文件请自行拷贝至src/main/java 文件目录下，主要包含dao、helper、mapper、wrapper、Ref.java 和IEntityRelation.java

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_13_color_FFFFFF_t_70_g_se_x_16][]

## PostMan 接口模拟测试 ##

insert 接口测试

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16][]

updateById 接口测试![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

deleteById 接口测试

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

getByIdOne 接口测试

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

[SpringBoot _FluentMybatis]: https://blog.csdn.net/zhouzhiwengang/article/details/121124149
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_13_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/d3a3aab52664453092577acc3fe6f878.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT,size_13,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/ed126225eb9f480f9a52381dd96b0435.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/68dfaba90a4c4ba680a0661559951d11.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/02fe9a924bef4f24a088e21afbb52357.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/2aae29e704e7485f9f97c9533dcd0fc6.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT,size_20,color_FFFFFF,t_70,g_se,x_16