Mybatis Map保存到数据库，Mybatis Map动态同步表，Mybatis Map Foreach插入数据库

时间 2021-01-29

标签 java 正则表达式 spring 数据库 apache 数组 mybatis app ide 工具栏目 MyBatis 繁體版

原文原文链接

Mybatis Map保存到数据库，Mybatis Map动态同步表，Mybatis Map Foreach插入数据库java

Mybatis 保存Map<String, Object>正则表达式

================================spring

©Copyright 蕃薯耀 2021-01-29数据库

https://www.cnblogs.com/fanshuyao/apache

1、情景描述数组

后台接口方式同步表数据。mybatis

为了让表数据同步自动化，避免后面重复开发，采起经过接收List<Map<String, Object>>对象的方式，将数据保存到相应的表中去。app

后台程序代码自动将Map<String, Object>转换成insert语句，将数据保存到数据库中。其中Map<String, Object>的键为字段名，值为字段的内容。ide

2、相关代码逻辑和配置工具

一、mybatis mapper.xml配置

${tableName}为$符号

#{item}为#符号，使用#符号，不要使用statementType="STATEMENT"声明

<?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="com.xxx.dao.SyncDataDao">

    <!-- 使用#{}点位符时， 不要使用statementType="STATEMENT"声明 -->
    <insert id="saveData" parameterType="map">
        insert into ${tableName}
        <foreach collection="tableColumns" index="index" item="item" open="(" close=")" separator=",">
            ${index} 
        </foreach>
        values
        <foreach collection="tableColumns" index="index" item="item" open="(" close=")" separator=",">
            #{item}
        </foreach>
    </insert>
    
    
    <insert id="deleteAllData" parameterType="string">
        delete from ${tableName}
    </insert>
    
</mapper>

foreach 元素的功能很是强大，它容许你指定一个集合，声明能够在元素体内使用的集合项（item）和索引（index）变量。

它也容许你指定开头与结尾的字符串以及集合项迭代之间的分隔符。

提示：你能够将任何可迭代对象（如 List、Set 等）、Map 对象或者数组对象做为集合参数传递给 foreach。

当使用可迭代对象或者数组时，index 是当前迭代的序号，item 的值是本次迭代获取到的元素。

当使用 Map 对象（或者 Map.Entry 对象的集合）时，index 是键，item 是值。

二、Dao类

import java.util.Map;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;

/**
 * <p>
 * 数据同步的配置表 Mapper 接口
 * </p>
 *
 * @since 2021-01-27
 */
public interface SyncDataDao extends BaseMapper<Object> {

    public void saveData(Map<String, Object> dataMap);
    
    public void deleteAllData(String tableName);
    
}

注：此处saveData方法的参数Map<String, Object> dataMap没有用@Param注解。若是使用了@Param("dataMap")，则Mapper配置文件也要增长

    <insert id="saveData" parameterType="map">
        insert into ${dataMap.tableName}
        <foreach collection="dataMap.tableColumns" index="index" item="item" open="(" close=")" separator=",">
            ${index} 
        </foreach>
        values
        <foreach collection="dataMap.tableColumns" index="index" item="item" open="(" close=")" separator=",">
            #{item}
        </foreach>
    </insert>

当不加@Param("dataMap")时，其实默认是：_parameter，但能够忽略。

三、Service类

import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.szpl.cu.biz.st.dao.SyncDataDao;
import com.szpl.cu.biz.st.service.SyncDataService;
import com.szpl.cu.security.exception.RunException;

/**
 * <p>
 * 数据同步的配置表 服务实现类
 * </p>
 *
 * @since 2021-01-27
 */
@Service
public class SyncDataServiceImpl extends ServiceImpl<SyncDataDao, Object> implements SyncDataService {
    
    @Transactional
    @Override
    public void saveData(Map<String, Object> dataMap) {
        this.baseMapper.saveData(dataMap);
    }
    
    @Transactional
    @Override
    public void deleteAllData(String tableName) {
        if(StringUtils.isBlank(tableName)) {
            RunException.run("参数错误");
        }
        this.baseMapper.deleteAllData(tableName);
    }
    
    
    @Transactional
    @Override
    public void saveAllDataByDeleteTable(String tableName, List<Map<String, Object>> datas) {
        //先删除，再新增
        this.deleteAllData(tableName);
        
        for (Map<String, Object> dataMap : datas) {
            this.saveData(dataMap);
        }
    }
    
    
}

四、调用方法（相似Controller）

//远程接口获取的数据
@SuppressWarnings("unchecked")
List<Map<String, Object>> datas = (List<Map<String, Object>>) result.getDatas();

//要保存的数据，经过datas转换
List<Map<String, Object>> newDatas = new ArrayList<Map<String,Object>>(datas.size());

//datas转换
for (Map<String, Object> data : datas) {
    LinkedHashMap<String, Object> dataMap = new LinkedHashMap<String, Object>();
    
    //处理时间类型的字段，由于返回的时间字段被转成字符串，不转换Mybatis识别不了
    Map<String, Object> newData = MapDataFormatUtil.format(data);
    
    //设置保存的表名
    dataMap.put("tableName", syncTableConfig.getTableName());
    //设置保存的字段
    dataMap.put("tableColumns", newData);
    
    newDatas.add(dataMap);
}

//保存同步数据
syncDataService.saveAllDataByDeleteTable(syncTableConfig.getTableName(), newDatas);

tableColumns、tableColumns对应Mapper文件的属性。

MapDataFormatUtil工具类：

import java.util.Map;

import org.apache.commons.lang3.StringUtils;

import com.szpl.cu.util.DateUtils;
import com.szpl.cu.util.RegUtils;

public class MapDataFormatUtil {

    public static Map<String, Object> format(Map<String, Object> dataMap) throws Exception{
        if(dataMap == null || dataMap.size() < 1) {
            return dataMap;
        }
        
        for (Map.Entry<String, Object> entry : dataMap.entrySet()) {
            Object value = entry.getValue();
            if(value instanceof String) {
                String tempValue = (String) entry.getValue();
                if(!StringUtils.isBlank(tempValue) && RegUtils.isDateTime(tempValue)) {
                    dataMap.put(entry.getKey(), DateUtils.parseDateTime(tempValue));
                }
            }
        }
        
        return dataMap;
    }
    
    
}

RegUtils工具类：

import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.commons.lang.StringUtils;

/**
 * 正则表达式工具类
 *
 */
public class RegUtils {
    /**
     * 邮箱
     */
    public static final String EMAIL = "^\\w+((-\\w+)|(\\.\\w+))*\\@[A-Za-z0-9]+((\\.|-)[A-Za-z0-9]+)*\\.[A-Za-z0-9]+$";
    /**
     * 手机号码
     */
    public static final String PHONE = "^(1[3-9]([0-9]{9}))$";
    /**
     * 仅中文
     */
    public static final String CHINESE = "^[\\u4E00-\\u9FA5\\uF900-\\uFA2D]+$";
    /**
     * 整数
     */
    public static final String INTEGER = "^-?[1-9]\\d*$";
    /**
     * 数字
     */
    public static final String NUMBER = "^([+-]?)\\d*\\.?\\d+$";
    /**
     * 正整数
     */
    public static final String INTEGER_POS = "^[1-9]\\d*$";
    /**
     * 浮点数
     */
    public static final String FLOAT = "^([+-]?)\\d*\\.\\d+$";
    /**
     * 正浮点数
     */
    public static final String FLOAT_POS = "^[1-9]\\d*.\\d*|0.\\d*[1-9]\\d*$";
    /**
     * 是否为正整数数字，包括0（00，01非数字）
     */
    public static final String INTEGER_WITH_ZERO_POS = "^(([0-9])|([1-9]([0-9]+)))$";
    /**
     * 是否为整数数字，包括正、负整数，包括0（00，01非数字）
     */
    public static final String NUMBER_WITH_ZERO = "^((-)?(([0-9])|([1-9]([0-9]+))))$";
    /**
     * 是否为数字字符串
     */
    public static final String NUMBER_TEXT = "^([0-9]+)$";
    /**
     * 数字(整数、0、浮点数），能够判断是否金额，也能够是负数
     */
    public static final String NUMBER_ALL = "^((-)?(([0-9])|([1-9][0-9]+))(\\.([0-9]+))?)$";
    /**
     * QQ，5-14位
     */
    public static final String QQ = "^[1-9][0-9]{4,13}$";
    /**
     * IP地址
     */
    public static final String IP = "((?:(?:25[0-5]|2[0-4]\\d|[01]?\\d?\\d)\\.){3}(?:25[0-5]|2[0-4]\\d|[01]?\\d?\\d))";
    /**
     * 邮编
     */
    public static final String POST_CODE = "[1-9]\\d{5}(?!\\d)";
    /**
     * 普通日期
     */
    public static final String DATE = "^[1-9]\\d{3}-((0[1-9])|(1[0-2]))-((0[1-9])|([1-2][0-9])|(3[0-1]))$";
    /**
     * 复杂日期，不区分闰年的2月
     * 日期格式：2017-10-19
     * 或2017/10/19
     * 或2017.10.19
     * 或2017年10月19日
     * 最大31天的月份：(((01|03|05|07|08|10|12))-((0[1-9])|([1-2][0-9])|(3[0-1])))
     * 最大30天的月份：(((04|06|11))-((0[1-9])|([1-2][0-9])|(30)))
     * 最大29天的月份：(02-((0[1-9])|([1-2][0-9])))
     */
    public static final String DATE_COMPLEX = "^(([1-2]\\d{3})(-|/|.|年)((((01|03|05|07|08|10|12))(-|/|.|月)((0[1-9])|([1-2][0-9])|(3[0-1])))|(((04|06|11))(-|/|.|月)((0[1-9])|([1-2][0-9])|(30)))|(02-((0[1-9])|([1-2][0-9]))))(日)?)$";
    
    /**
     * 复杂的日期，区分闰年的2月
     * 这个日期校验能区分闰年的2月，格式以下：2017-10-19
     * （见：http://www.jb51.net/article/50905.htm）
     * ^((?!0000)[0-9]{4}-((0[1-9]|1[0-2])-(0[1-9]|1[0-9]|2[0-8])|(0[13-9]|1[0-2])-(29|30)|(0[13578]|1[02])-31)|([0-9]{2}(0[48]|[2468][048]|[13579][26])|(0[48]|[2468][048]|[13579][26])00)-02-29)$
     */
    public static final String DATE_COMPLEX_LEAP_YEAR = "^(?:(?!0000)[0-9]{4}-(?:(?:0[1-9]|1[0-2])-(?:0[1-9]|1[0-9]|2[0-8])|(?:0[13-9]|1[0-2])-(?:29|30)|(?:0[13578]|1[02])-31)|(?:[0-9]{2}(?:0[48]|[2468][048]|[13579][26])|(?:0[48]|[2468][048]|[13579][26])00)-02-29)$";
    
    
    /**
     * 普通日期，带时间
     */
    public static final String DATE_TIME = "^[1-9]\\d{3}-((0[1-9])|(1[0-2]))-((0[1-9])|([1-2][0-9])|(3[0-1])) \\d{2}:\\d{2}:\\d{2}$";
    
    /**
     * 正则表达式校验,符合返回True
     * @param regex 正则表达式
     * @param content 校验的内容
     * @return
     */
    public static boolean isMatch(String regex, CharSequence content){
        return Pattern.matches(regex, content);
    }
    
    
    /**
     * 校验手机号码
     * @param mobile
     * @return
     */
    public static final boolean isMoblie(String mobile){
        boolean flag = false;
        if (null != mobile && !mobile.trim().equals("") && mobile.trim().length() == 11) {
            Pattern pattern = Pattern.compile(PHONE);
            Matcher matcher = pattern.matcher(mobile.trim());
            flag = matcher.matches();
        }
        return flag;
    }
    
    
    /**
     * 校验邮箱
     * @param value
     * @return
     */
    public static final boolean isEmail(String value){
        boolean flag = false;
        if (null != value && !value.trim().equals("")) {
            Pattern pattern = Pattern.compile(EMAIL);
            Matcher matcher = pattern.matcher(value.trim());
            flag = matcher.matches();
        }
        return flag;
    }
    
    
    /**
     * 校验密码
     * @param password
     * @return 长度符合返回true，不然为false
     */
    public static final boolean isPassword(String password){
        boolean flag = false;
        if (null != password && !password.trim().equals("")) {
            password = password.trim();
            if(password.length() >= 6 && password.length() <= 30){
                return true;
            }
        }
        return flag;
    }
    
    
    /**
     * 校验手机验证码
     * @param value
     * @return 符合正则表达式返回true，不然返回false
     */
    public static final boolean isPhoneValidateCode(String value){
        boolean flag = false;
        if (null != value && !value.trim().equals("")) {
            Pattern pattern = Pattern.compile("^8\\d{5}$");
            Matcher matcher = pattern.matcher(value.trim());
            flag = matcher.matches();
        }
        return flag;
    }

    
    /**
     * 判断是否所有大写字母
     * @param str
     * @return
     */
    public static boolean isUpperCase(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        String reg = "^[A-Z]$";
        return isMatch(reg,str);
    }
    
    
    /**
     * 判断是否所有小写字母
     * @param str
     * @return
     */
    public static boolean isLowercase(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        String reg = "^[a-z]$";
        return isMatch(reg,str);
    }
    
    
    /**
     * 是否ip地址
     * @param str
     * @return
     */
    public static boolean isIP(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(IP, str);
    }
    
    /**
     * 符合返回true，区分30、31天和闰年的2月份（最严格的校验），格式为2017-10-19
     * @param str
     * @return
     */
    public static boolean isDate(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(DATE_COMPLEX_LEAP_YEAR, str);
    }
    
    
    /**
     * 简单日期校验，不那么严格
     * @param str
     * @return
     */
    public static boolean isDateSimple(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(DATE, str);
    }
    
    
    /**
     * 区分30、31天，但没有区分闰年的2月份
     * @param str
     * @return
     */
    public static boolean isDateComplex(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(DATE_COMPLEX, str);
    }
    
    /**
     * 简单日期-带时间
     * @param str
     * @return
     */
    public static boolean isDateTime(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(DATE_TIME, str);
    }
    
    
    /**
     * 判断是否为数字字符串，如0011，10101，01
     * @param str
     * @return
     */
    public static boolean isNumberText(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(NUMBER_TEXT, str);
    }
    
    
    /**
     * 判断全部类型的数字，数字(整数、0、浮点数），能够判断是否金额，也能够是负数
     * @param str
     * @return
     */
    public static boolean isNumberAll(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(NUMBER_ALL, str);
    }
    
    
    /**
     * 是否为正整数数字，包括0（00，01非数字）
     * @param str
     * @return
     */
    public static boolean isIntegerWithZeroPos(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(INTEGER_WITH_ZERO_POS, str);
    }
    
    
    /**
     * 是否为整数，包括正、负整数，包括0（00，01非数字）
     * @param str
     * @return
     */
    public static boolean isIntegerWithZero(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(NUMBER_WITH_ZERO, str);
    }
    
    
    /**
     * 符合返回true,QQ，5-14位
     * @param str
     * @return
     */
    public static boolean isQQ(String str){
        if(StringUtils.isEmpty(str)){
            return false;
        }
        return isMatch(QQ, str);
    }
    
    
    public static void main(String[] args) {
        System.out.println(isMoblie("13430800244"));
        System.out.println(isMoblie("17730800244"));
        System.out.println(isMoblie("17630800244"));
        System.out.println(isMoblie("14730800244"));
        System.out.println(isMoblie("18330800244"));
        System.out.println(isMoblie("19330800244"));
        System.out.println(isMoblie("1333000244"));
    }
    

}

================================

https://www.cnblogs.com/fanshuyao/