封装MyBatisPlus+EasyCode模板升级

1.封装MyBatisPlus

1.目录 common-mybatis-plus-starter

CleanShot 2024-10-26 at 20.09.03@2x

2.SunRaysBaseService.java
package com.sunxiansheng.mybatis.plus.base.service;

import java.io.Serializable;
import java.util.List;

/**
 * Description: SunRays-Framework 基础Service接口
 *
 * @Author sun
 * @Create 2024/10/25 16:21
 * @Version 1.0
 */
public interface SunRaysBaseService<T, ID extends Serializable> {

    /**
     * 根据主键判断数据是否存在
     *
     * @param id 主键
     * @return 是否存在
     */
    boolean existsById(ID id);

    /**
     * 根据条件判断数据是否存在
     *
     * @param po
     * @return
     */
    boolean exists(T po);

    /**
     * 根据条件统计行数
     *
     * @param po 查询条件
     * @return 总行数
     */
    Long count(T po);

    /**
     * 根据主键查询单条数据
     *
     * @param id 主键
     * @return 实例对象
     */
    T listById(ID id);

    /**
     * 根据条件查询记录
     *
     * @param po 查询条件
     * @return 对象列表
     */
    List<T> listAll(T po);

    /**
     * 新增数据
     *
     * @param po 实例对象(如果设置了@TableId注解,会自动回写主键)
     * @return 影响行数
     */
    int insertOne(T po);

    /**
     * 根据主键修改数据
     *
     * @param po 实例对象
     * @return 影响行数
     */
    int updateById(T po);

    /**
     * 根据条件修改数据
     *
     * @param po
     * @param condition
     * @return
     */
    int update(T po, T condition);

    /**
     * 根据主键删除数据
     *
     * @param id 主键
     * @return 影响行数
     */
    int deleteById(ID id);

    /**
     * 根据主键批量删除数据
     *
     * @param ids 主键列表
     * @return 影响行数
     */
    int deleteBatchByIds(List<ID> ids);

    /**
     * 根据条件删除数据
     *
     * @param po
     * @return
     */
    int delete(T po);
}
3.SunRaysBaseServiceImpl.java
package com.sunxiansheng.mybatis.plus.base.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.sunxiansheng.mybatis.plus.base.service.SunRaysBaseService;

import java.io.Serializable;
import java.util.List;

/**
 * Description: SunRays-Framework 基础Service实现类
 *
 * @Author sun
 * @Create 2024/10/25 17:38
 * @Version 1.0
 */
public class SunRaysBaseServiceImpl<M extends BaseMapper<T>, T, ID extends Serializable>
        implements SunRaysBaseService<T, ID> {

    /**
     * MyBatis-Plus Mapper
     */
    protected M baseMapper;

    /**
     * 构造器注入具体子类的Mapper
     *
     * @param baseMapper
     */
    public SunRaysBaseServiceImpl(M baseMapper) {
        this.baseMapper = baseMapper;
    }

    @Override
    public boolean existsById(ID id) {
        T t = baseMapper.selectById(id);
        return t != null;
    }

    @Override
    public boolean exists(T po) {
        QueryWrapper<T> queryWrapper = new QueryWrapper<>(po);
        return baseMapper.exists(queryWrapper);
    }

    @Override
    public Long count(T po) {
        QueryWrapper<T> queryWrapper = new QueryWrapper<>(po);
        return baseMapper.selectCount(queryWrapper);
    }

    @Override
    public T listById(ID id) {
        return baseMapper.selectById(id);
    }

    @Override
    public List<T> listAll(T po) {
        QueryWrapper<T> queryWrapper = new QueryWrapper<>(po);
        return baseMapper.selectList(queryWrapper);
    }

    @Override
    public int insertOne(T po) {
        return baseMapper.insert(po);
    }

    @Override
    public int updateById(T po) {
        return baseMapper.updateById(po);
    }

    @Override
    public int update(T po, T condition) {
        QueryWrapper<T> queryWrapper = new QueryWrapper<>(condition);
        return baseMapper.update(po, queryWrapper);
    }

    @Override
    public int deleteById(ID id) {
        return baseMapper.deleteById(id);
    }

    @Override
    public int deleteBatchByIds(List<ID> ids) {
        return baseMapper.deleteBatchIds(ids);
    }

    @Override
    public int delete(T po) {
        QueryWrapper<T> queryWrapper = new QueryWrapper<>(po);
        return baseMapper.delete(queryWrapper);
    }
}

2.EasyCode模板升级

1.引入mapstruct
1.common-mybatis-plus-starter 引入依赖
        <!-- mapstruct -->
        <dependency>
            <groupId>org.mapstruct</groupId>
            <artifactId>mapstruct</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mapstruct</groupId>
            <artifactId>mapstruct-processor</artifactId>
        </dependency>
2.sunrays-dependencies 指定版本
        <mapstruct.version>1.4.2.Final</mapstruct.version>
3.Maven配置Lombok和MapStruct的依赖
<!-- maven的编译插件(配置注解处理器) -->
<plugins>
    <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <!-- maven编译插件版本号 -->
        <version>3.8.1</version>
        <configuration>
            <!-- 配置注解处理器(比如Lombok和MapStruct) -->
            <annotationProcessorPaths>
                <!-- Lombok 注解处理器 -->
                <path>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                    <version>${lombok.version}</version>
                </path>
                <!-- MapStruct 注解处理器 -->
                <path>
                    <groupId>org.mapstruct</groupId>
                    <artifactId>mapstruct-processor</artifactId>
                    <version>${mapstruct.version}</version>
                </path>
            </annotationProcessorPaths>
        </configuration>
    </plugin>
</plugins>
2.最新版本EasyCode模板
1.Controller.java
## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Controller.java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/controller"))

## 拿到主键
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.controller;
#end

import $!{tableInfo.savePackageName}.entity.req.$!{tableInfo.name}Req;
import $!{tableInfo.savePackageName}.entity.vo.$!{tableInfo.name}Vo;
import com.sunxiansheng.mybatis.plus.page.PageResult;
import $!{tableInfo.savePackageName}.service.$!{tableInfo.name}Service;
import com.sunxiansheng.web.base.BaseController;
import com.sunxiansheng.web.response.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * $!{tableInfo.comment}($!{tableInfo.name})控制层:接收前端请求
 *
 * @author $!author
 * @since $!time.currTime()
 */
@RestController
@RequestMapping("/$tool.hump2Underline($tool.firstLowerCase($tableInfo.name)).replace('_', '/')")
@Slf4j
public class $!{tableInfo.name}Controller extends BaseController {

    /**
     * 服务对象
     */
    @Resource
    private $!{tableInfo.name}Service $!tool.firstLowerCase($tableInfo.name)Service;

    /**
     * 分页查询数据
     *
     * @param req 筛选条件
     * @return 查询结果
     */
    @GetMapping("/queryPage")
    public Result<PageResult<$!{tableInfo.name}Vo>> queryByPage(@RequestBody $!{tableInfo.name}Req req) {
        // ============================== Preconditions 参数校验 ==============================

        // ============================== Preconditions 参数校验 ==============================

        // 调用service层
        PageResult<$!{tableInfo.name}Vo> $!{tool.firstLowerCase($tableInfo.name)}VoPageResult = this.$!{tool.firstLowerCase($tableInfo.name)}Service.listPage(req);
        return Result.ok($!{tool.firstLowerCase($tableInfo.name)}VoPageResult);
    }
}
2.Converter.java
## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Converter.java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/convert"))

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.convert;
#end

import $!{tableInfo.savePackageName}.entity.po.$!{tableInfo.name};
import $!{tableInfo.savePackageName}.entity.req.$!{tableInfo.name}Req;
import $!{tableInfo.savePackageName}.entity.vo.$!{tableInfo.name}Vo;
import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers;
import java.util.List;

/**
 * ($!{tableInfo.name})转换器:使用MapStruct实现对象之间的转换
 *
 * @Author $!author
 * @Create $!time.currTime()
 * @Version 1.0
 */
@Mapper
public interface $!{tableInfo.name}Converter {

    /**
     * 获取 $!{tableInfo.name}Converter 的代理对象
     */
    $!{tableInfo.name}Converter INSTANCE = Mappers.getMapper($!{tableInfo.name}Converter.class);

    /**
     * 将请求对象转换为实体对象(Req -> Po)
     *
     * @param req 请求对象
     * @return 实体对象
     */
    $!{tableInfo.name} convertReq2Po($!{tableInfo.name}Req req);

    /**
     * 将实体对象转换为视图对象(Po -> Vo)
     *
     * @param po 实体对象
     * @return 视图对象
     */
    $!{tableInfo.name}Vo convertPo2Vo($!{tableInfo.name} po);

    /**
     * 将实体对象列表转换为视图对象列表(List<Po> -> List<Vo>)
     *
     * @param poList 实体对象列表
     * @return 视图对象列表
     */
    List<$!{tableInfo.name}Vo> convertPoList2VoList(List<$!{tableInfo.name}> poList);
}
3.po.java
## 引入宏定义
$!{sunrays-framework.vm}

## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, ".java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/entity/po"))

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.entity.po;
#end

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableLogic;
import lombok.*;
import lombok.experimental.Accessors;
import com.sunxiansheng.web.base.BaseEntity;
import java.io.Serializable;

## 检查是否包含 DateBigDecimal 类型的字段
#set($containsDate = false)
#set($containsBigDecimal = false)

#foreach($column in $tableInfo.fullColumn)
    ## 检查是否包含 Date 类型
    #if($tool.getClsNameByFullName($column.type) == "Date")
        #set($containsDate = true)
    #end

    ## 检查是否包含 BigDecimal 类型
    #if($tool.getClsNameByFullName($column.type) == "BigDecimal")
        #set($containsBigDecimal = true)
    #end
#end

## 如果包含 Date 类型的字段,导入 java.util.Date
#if($containsDate)
import java.util.Date;
#end

## 如果包含 BigDecimal 类型的字段,导入 java.math.BigDecimal
#if($containsBigDecimal)
import java.math.BigDecimal;
#end

## 主键字段获取
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

/**
 * $!{tableInfo.comment}($!{tableInfo.name})PO实体类:对应数据库表字段
 *
 * @author $!author
 * @since $!time.currTime()
 */
@Data
@EqualsAndHashCode(callSuper = true) // 包含父类属性的 equals 和 hashCode
@ToString
@AllArgsConstructor
@NoArgsConstructor
@Accessors(chain = true) // 支持链式调用
public class $!{tableInfo.name} extends BaseEntity implements Serializable {

    private static final long serialVersionUID = 1L;

    #foreach($column in $tableInfo.fullColumn)
        ## 跳过排除字段
        #if(!$excludedFields.contains($column.name))
            ## 判断是否为主键字段
            #if($column.name == $pk.name)
            /**
             * 自增主键,insert时自动写回id
             */
            @TableId(value = "$!{column.name}", type = IdType.AUTO)
            private $!{tool.getClsNameByFullName($column.type)} $!{column.name};
            ## 判断是否为逻辑删除字段
            #elseif($column.name == $logicDeleteField)
            /**
             * 逻辑删除标识(需要在配置文件中配置逻辑删除)
             */
            @TableLogic
            private $!{tool.getClsNameByFullName($column.type)} $!{column.name};
            ## 普通字段处理
            #else
            #if($column.comment)/**
             * $column.comment
             */#end
            private $!{tool.getClsNameByFullName($column.type)} $!{column.name};
            #end
        #end
    #end
}
4.req.java
## 引入宏定义
$!{sunrays-framework.vm}

## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Req.java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/entity/req"))

## 拿到主键
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.entity.req;
#end

import com.sunxiansheng.mybatis.plus.page.PageInfo;
import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;

## 检查是否包含 DateBigDecimal 类型的字段
#set($containsDate = false)
#set($containsBigDecimal = false)

#foreach($column in $tableInfo.fullColumn)
    ## 检查是否包含 Date 类型
    #if($tool.getClsNameByFullName($column.type) == "Date")
        #set($containsDate = true)
    #end

    ## 检查是否包含 BigDecimal 类型
    #if($tool.getClsNameByFullName($column.type) == "BigDecimal")
        #set($containsBigDecimal = true)
    #end
#end

## 如果包含 Date 类型的字段,导入 java.util.Date
#if($containsDate)
import java.util.Date;
#end

## 如果包含 BigDecimal 类型的字段,导入 java.math.BigDecimal
#if($containsBigDecimal)
import java.math.BigDecimal;
#end

/**
 * $!{tableInfo.comment}($!{tableInfo.name})Req实体类:接受前端请求
 *
 * @author $!author
 * @since $!time.currTime()
 */
@Data
@EqualsAndHashCode(callSuper = true) // 包含父类属性的 equals 和 hashCode
@ToString
@AllArgsConstructor
@NoArgsConstructor
@Accessors(chain = true) // 支持链式调用
public class $!{tableInfo.name}Req extends PageInfo implements Serializable {

    private static final long serialVersionUID = 1L;

    #foreach($column in $tableInfo.fullColumn)
        ## 跳过排除字段
        #if(!$excludedFields.contains($column.name))
            ## 添加字段注释
            #if($column.comment)/**
             * $column.comment
             */#end
            private $!{tool.getClsNameByFullName($column.type)} $!{column.name};
        #end
    #end
}
5.vo.java
## 引入宏定义
$!{sunrays-framework.vm}

## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Vo.java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/entity/vo"))

## 拿到主键
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.entity.vo;
#end

import lombok.*;
import lombok.experimental.Accessors;
import java.io.Serializable;

## 检查是否包含 DateBigDecimal 类型的字段
#set($containsDate = false)
#set($containsBigDecimal = false)

#foreach($column in $tableInfo.fullColumn)
    ## 检查是否包含 Date 类型
    #if($tool.getClsNameByFullName($column.type) == "Date")
        #set($containsDate = true)
    #end

    ## 检查是否包含 BigDecimal 类型
    #if($tool.getClsNameByFullName($column.type) == "BigDecimal")
        #set($containsBigDecimal = true)
    #end
#end

## 如果包含 Date 类型的字段,导入 java.util.Date
#if($containsDate)
import java.util.Date;
#end

## 如果包含 BigDecimal 类型的字段,导入 java.math.BigDecimal
#if($containsBigDecimal)
import java.math.BigDecimal;
#end

/**
 * $!{tableInfo.comment}($!{tableInfo.name})VO实体类:封装后端给前端的响应
 *
 * @author $!author
 * @since $!time.currTime()
 */
@Data
@EqualsAndHashCode 
@ToString 
@AllArgsConstructor 
@NoArgsConstructor
@Accessors(chain = true) // 支持链式调用
public class $!{tableInfo.name}Vo implements Serializable {

    private static final long serialVersionUID = 1L;

    #foreach($column in $tableInfo.fullColumn)
        ## 跳过排除字段
        #if(!$excludedFields.contains($column.name))
            ## 添加字段注释
            #if($column.comment)/**
             * $column.comment
             */#end
            private $!{tool.getClsNameByFullName($column.type)} $!{column.name};
        #end
    #end
}
6.Service.java
## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Service.java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/service"))

## 拿到主键
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.service;
#end

import com.sunxiansheng.mybatis.plus.base.service.SunRaysBaseService;
import $!{tableInfo.savePackageName}.entity.po.$!{tableInfo.name};
import $!{tableInfo.savePackageName}.entity.req.$!{tableInfo.name}Req;
import $!{tableInfo.savePackageName}.entity.vo.$!{tableInfo.name}Vo;
import com.sunxiansheng.mybatis.plus.page.PageResult;

/**
 * $!{tableInfo.comment}($!{tableInfo.name})Service接口:定义业务逻辑
 *
 * @author $!author
 * @since $!time.currTime()
 */
public interface $!{tableInfo.name}Service extends SunRaysBaseService<$!{tableInfo.name}, $pk.type> {

    /**
     * 分页查询
     *
     * @param $!{tool.uncapitalize($!{tableInfo.name})}Req 查询条件
     * @return 对象列表
     */
    PageResult<$!{tableInfo.name}Vo> listPage($!{tableInfo.name}Req $!{tool.uncapitalize($!{tableInfo.name})}Req);
}
7.ServiceImpl.java
## 引入宏定义
$!{define.vm}

## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "ServiceImpl.java"))
$!callback.setSavePath($tool.append($tableInfo.savePath, "/service/impl"))

## 拿到主键
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

## 包声明
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.service.impl;
#end

## 导入相关类
import com.sunxiansheng.mybatis.plus.base.service.impl.SunRaysBaseServiceImpl;
import $!{tableInfo.savePackageName}.convert.${tableInfo.name}Converter;
import $!{tableInfo.savePackageName}.entity.po.${tableInfo.name};
import $!{tableInfo.savePackageName}.entity.req.${tableInfo.name}Req;
import $!{tableInfo.savePackageName}.entity.vo.${tableInfo.name}Vo;
import $!{tableInfo.savePackageName}.mapper.${tableInfo.name}Mapper;
import com.sunxiansheng.mybatis.plus.page.PageResult;
import com.sunxiansheng.mybatis.plus.page.SunPageHelper;
import $!{tableInfo.savePackageName}.service.${tableInfo.name}Service;
import org.springframework.stereotype.Service;
import java.util.List;

/**
 * $!{tableInfo.comment}($!{tableInfo.name})Service实现类:实现业务逻辑
 *
 * @author $!{author}
 * @since $!time.currTime()
 */
@Service("$!tool.firstLowerCase($!{tableInfo.name})Service")
public class $!{tableInfo.name}ServiceImpl 
    extends SunRaysBaseServiceImpl<$!{tableInfo.name}Mapper, $!{tableInfo.name}, Integer> 
    implements $!{tableInfo.name}Service {

    /**
     * 为父类注入baseMapper
     *
     * @param baseMapper
     */
    public $!{tableInfo.name}ServiceImpl($!{tableInfo.name}Mapper baseMapper) {
        super(baseMapper);
    }

    @Override
    public PageResult<$!{tableInfo.name}Vo> listPage($!{tableInfo.name}Req $!tool.firstLowerCase($!{tableInfo.name})Req) {
        // req转换为po
        $!{tableInfo.name} po = $!{tableInfo.name}Converter.INSTANCE.convertReq2Po($!tool.firstLowerCase($!{tableInfo.name})Req);
        
        // 分页查询
        PageResult<$!{tableInfo.name}Vo> paginate = SunPageHelper.paginate(
            $!tool.firstLowerCase($!{tableInfo.name})Req.getPageNo(), 
            $!tool.firstLowerCase($!{tableInfo.name})Req.getPageSize(),
            () -> {
                // 计算count
                return this.count(po);
            }, 
            (offset, limit) -> {
                // 查询数据,并转换为vo
                List<$!{tableInfo.name}> ${tool.firstLowerCase($!{tableInfo.name})}List = 
                    baseMapper.queryPage(po, offset, limit);
                return $!{tableInfo.name}Converter.INSTANCE.convertPoList2VoList(${tool.firstLowerCase($!{tableInfo.name})}List);
            }
        );
        return paginate;
    }
}
8.Mapper.java
## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Mapper.java"))
$!callback.setSavePath($tool.append($modulePath, "/src/main/java/$!{tableInfo.savePackageName.replace('.','/')}/mapper"))

## 包声明和导入
#if($tableInfo.savePackageName)package $!{tableInfo.savePackageName}.mapper;
#end

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import $!{tableInfo.savePackageName}.entity.po.$!{tableInfo.name};
import org.apache.ibatis.annotations.Param;
import java.util.List;

/**
 * ($!{tableInfo.name})数据库访问层
 *
 * @author $!{author}
 * @since $!{time.currTime('yyyy-MM-dd HH:mm:ss')}
 */
public interface $!{tableInfo.name}Mapper extends BaseMapper<$!{tableInfo.name}> {

    /**
     * 分页查询
     *
     * @param po 查询条件
     * @param offset 偏移量:计算公式 (pageNo - 1) * pageSize
     * @param limit 页面大小
     * @return 对象列表
     */
    List<$!{tableInfo.name}> queryPage(@Param("po") $!{tableInfo.name} po, 
                                       @Param("offset") Long offset, 
                                       @Param("limit") Long limit);

    /**
     * 批量新增数据(MyBatis原生foreach方法)
     *
     * @param entities 实例对象列表(会封装新增的id)
     * @return 影响行数
     */
    int insertBatch(@Param("entities") List<$!{tableInfo.name}> entities);

    /**
     * 批量新增或按主键更新数据(MyBatis原生foreach方法)
     *
     * @param entities 实例对象列表(会封装新增的id)
     * @return 影响行数
     * @throws org.springframework.jdbc.BadSqlGrammarException 入参是空List的时候会抛SQL语句错误的异常,请自行校验入参
     */
    int insertOrUpdateBatch(@Param("entities") List<$!{tableInfo.name}> entities);
}
9.Mapper.xml
## 引入宏定义
$!{sunrays-framework.vm}

## 引入MyBatis支持
$!{mybatisSupport.vm}

## 设置保存名称与保存位置
$!callback.setFileName($tool.append($!{tableInfo.name}, "Mapper.xml"))
$!callback.setSavePath($tool.append($modulePath, "/src/main/resources/mapper"))

## 拿到主键
#if(!$tableInfo.pkColumn.isEmpty())
    #set($pk = $tableInfo.pkColumn.get(0))
#end

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="$!{tableInfo.savePackageName}.mapper.$!{tableInfo.name}Mapper">

    <resultMap type="$!{tableInfo.savePackageName}.entity.po.$!{tableInfo.name}" id="$!{tableInfo.name}Map">
        <id property="$!pk.name" column="$!pk.obj.name"/>
#foreach($column in $tableInfo.fullColumn)
    #if($column.name != $pk.name)
        <result property="$!column.name" column="$!column.obj.name"/>
    #end
#end
    </resultMap>

    <!-- 分页查询指定行数据 -->
    <select id="queryPage" resultMap="$!{tableInfo.name}Map">
        select #allSqlColumn()
        from $!{tableInfo.obj.name}
        <where>
#foreach($column in $tableInfo.fullColumn)
            <if test="po.$!column.name != null#if($column.type.equals('java.lang.String')) and po.$!column.name != ''#end">
                and $!column.obj.name = #{po.$!column.name}
            </if>
#end
            and $logicDeleteFieldUnder = $notDeletedColumnValue
        </where>
        limit #{offset}, #{limit}
    </select>

    <!-- 批量新增多条记录 -->
    <insert id="insertBatch" keyProperty="$!pk.name" useGeneratedKeys="true">
        insert into $!{tableInfo.obj.name}(
        #foreach($column in $tableInfo.otherColumn)
            $!column.obj.name#if($foreach.hasNext), #end
        #end)
        values
        <foreach collection="entities" item="entity" separator=",">
            (#foreach($column in $tableInfo.otherColumn)#{entity.$!column.name}#if($foreach.hasNext), #end#end)
        </foreach>
    </insert>

    <!-- 插入或更新(根据主键冲突) -->
    <insert id="insertOrUpdateBatch" keyProperty="$!pk.name" useGeneratedKeys="true">
        insert into $!{tableInfo.obj.name}(id,
        #foreach($column in $tableInfo.otherColumn)
            $!column.obj.name#if($foreach.hasNext), #end
        #end)
        values
        <foreach collection="entities" item="entity" separator=",">
            (#{entity.id},
            #foreach($column in $tableInfo.otherColumn)#{entity.$!column.name}#if($foreach.hasNext), #end#end)
        </foreach>
        on duplicate key update
        #foreach($column in $tableInfo.otherColumn)
            $!column.obj.name = values($!column.obj.name)#if($foreach.hasNext), #end
        #end
    </insert>

</mapper>
3.其余配置
1.编写BaseEntity.java 封装通用字段(只需编写一次)
package com.sunxiansheng.web.base;

import lombok.*;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.Date;

/**
 * Description: Entity基类
 *
 * @Author sun
 * @Create 2024/10/26 10:35
 * @Version 1.0
 */
@Data
@EqualsAndHashCode
@ToString
@AllArgsConstructor
@NoArgsConstructor
@Accessors(chain = true)
public class BaseEntity implements Serializable {

    private static final long serialVersionUID = 1L;

    /**
     * 创建者
     */
    private String createBy;

    /**
     * 创建时间
     */

    private Date createTime;

    /**
     * 更新者
     */
    private String updateBy;

    /**
     * 更新时间
     */
    private Date updateTime;
}
2.application.yml 配置mybatis-plus逻辑删除
mybatis-plus:
  global-config:
    db-config:
      logic-delete-field: is_deleted # 全局逻辑删除字段名
      logic-delete-value: 1 # 逻辑已删除值
      logic-not-delete-value: 0 # 逻辑未删除值
  # mybatis-plus配置控制台打印完整带参数SQL语句
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
3.EasyCode配置宏定义属性

CleanShot 2024-10-26 at 20.24.42@2x

## 定义配置宏

    ## 指定逻辑删除字段名(驼峰命名)
    #set($logicDeleteField = "isDeleted")
    ## 指定逻辑删除字段名(下划线命名)
    #set($logicDeleteFieldUnder = "is_deleted")
    
    ##定义全局逻辑删除字段的删除值和未删除值
    #set($deleteColumnValue = 1)
    #set($notDeletedColumnValue = 0)

    ## 配置排除的字段列表(驼峰命名)
    #set($excludedFields = ["createBy", "createTime", "updateBy", "updateTime"])

3.代码生成演示

1.新建表
1.注意点一:通用字段需要是跟BaseEntity以及宏定义中一致
["create_by", "create_time", "update_by", "update_time"])
2.注意点二:逻辑删除字段需要与application.yml以及宏定义中一致
is_deleted
2.SQL
-- auto-generated definition
create table sample_table
(
    id             int auto_increment comment '主键ID'
        primary key,
    user_name      varchar(50)                           not null comment '用户名',
    email          varchar(100)                          not null comment '电子邮件',
    phone_number   varchar(20)                           null comment '联系电话',
    address        varchar(200)                          null comment '地址',
    age            int                                   null comment '年龄',
    gender         varchar(10)                           null comment '性别',
    salary         decimal(10, 2)                        null comment '薪资',
    hire_date      date                                  null comment '入职日期',
    last_login     datetime                              null comment '最后登录时间',
    account_status varchar(20) default 'ACTIVE'          null comment '账户状态',
    is_active      tinyint(1)  default 1                 null comment '是否激活',
    create_by      varchar(50)                           null comment '创建人',
    create_time    datetime    default CURRENT_TIMESTAMP null comment '创建时间',
    update_by      varchar(50)                           null comment '更新人',
    update_time    datetime    default CURRENT_TIMESTAMP null on update CURRENT_TIMESTAMP comment '更新时间',
    is_deleted     tinyint(1)  default 0                 null comment '逻辑删除标识',
    department     varchar(50)                           null comment '部门',
    position       varchar(50)                           null comment '职位',
    notes          text                                  null comment '备注'
)
    comment '示例表' charset = utf8mb4;
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10001, 'Georgi', 'Facello', 'M');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10002, 'Bezalel', 'Simmel', 'F');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10003, 'Parto', 'Bamford', 'M');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10004, 'Chirstian', 'Koblick', 'M');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10005, 'Kyoichi', 'Maliniak', 'M');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10006, 'Anneke', 'Preusig', 'F');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10007, 'Tzvetan', 'Zielinski', 'F');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10008, 'Saniya', 'Kalloufi', 'M');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10009, 'Sumant', 'Peac', 'F');
INSERT INTO MY_TABLE(id, first_name, last_name, birth) VALUES (10010, 'Duangkaew', 'Piveteau', 'F');

3.生成代码

CleanShot 2024-10-26 at 20.55.19@2x

4.分页查询测试

CleanShot 2024-10-26 at 20.57.36@2x

评论 3
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包

打赏作者

S-X-S

你的鼓励将是我创作的最大动力

¥1 ¥2 ¥4 ¥6 ¥10 ¥20
扫码支付:¥1
获取中
扫码支付

您的余额不足,请更换扫码支付或充值

打赏作者

实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值