Mybatis Map保存到數據庫，Mybatis Map動態同步表，Mybatis Map Foreach插入數據庫

Mybatis Map保存到數據庫，Mybatis Map動態同步表，Mybatis  Map Foreach插入數據庫

Mybatis 保存Map<String, Object>

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

©Copyright 蕃薯耀 2021-01-29

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

 

一、情景描述

后台接口方式同步表數據。

為了讓表數據同步自動化，避免后面重復開發，采取通過接收List<Map<String, Object>>對象的方式，將數據保存到相應的表中去。

后台程序代碼自動將Map<String, Object>轉換成insert語句，將數據保存到數據庫中。其中Map<String, Object>的鍵為字段名，值為字段的內容。

 

二、相關代碼邏輯和配置

1、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 是值。

 

 

2、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，但可以忽略。

 

3、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 xxx.biz.st.dao.SyncDataDao;
import xxx.biz.st.service.SyncDataService;
import xxx.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);
        }
    }
    
    
}

 

4、調用方法（類似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 xxx.util.DateUtils;
import xxx.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"));
    }
    

}

 

三、數據同步，查詢數據的邏輯（2021-02-20補充）

設計思想：

• 通過字典表配置一個數據同步的開關，根據密鑰（設置密鑰更加安全，多個系統可以設置不同的密鑰）查詢開關，如果開關存在且允許同步，則下一步，否則返回錯誤信息
• 通過字典配置允許同步的表，其中包括表名（大寫）、表的查詢sql、表的過濾條件、關聯的數據同步開關id

　　表名：是為了匹配允許同步的表

　　表的查詢sql：如果為空，則取出表的所有字段，這個作為默認方式；如果不為空，則根據sql進行查詢，可以自定義返回的字段，也可以多表關聯查詢，如果sql過長，還可以寫成視圖

　　表的過濾條件：定義查詢的過濾條件，為空，則是全部；不為空，則根據條件查詢。

　　關聯的數據同步開關id：字典的parent_id設置成關聯的數據同步開關id，表示該開關下允許同步的表。根據開關的id和表名，確定該表是否允許同步

 

• 校驗通過，則查詢出數據返回；不通過，則返回錯誤提示

 

1、mybatis xml配置文件

<?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.biz.common.dao.SyncDataDao">

    <select id="getTable" parameterType="map" resultType="map">
        <if test="tableSelectSql == null">
            SELECT * from ${tableSelectName} 
        </if>
        <if test="tableSelectSql != null">
            ${tableSelectSql}
        </if>
        
        <if test="tableWhereSql != null">
             ${tableWhereSql}
        </if>
    </select>

</mapper>

 

2、Dao

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

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

public interface SyncDataDao extends BaseMapper<Object> {
    
    public List<Map<String, Object>> getTable(Map<String, Object> paramsMap);
}

 

3、service

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

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

@Service
public class SyncDataServiceImpl extends ServiceImpl<SyncDataDao, Object> implements SyncDataService {

    private static Logger log = Logger.getLogger(SyncDataServiceImpl.class);
    
    @Transactional(readOnly = true)
    @Override
    public List<Map<String, Object>> getTable(HttpServletRequest request, Map<String, String> requestMap){
        //校驗請求的參數
        String tableName = requestMap.get("tableName");//表名
        String xx = requestMap.get("xx");//密鑰
        log.info("tableName = " + tableName);
        log.info("xx = " + xx);
        
        if(StringUtils.isBlank(tableName)) {
            RunException.error("表名參數錯誤，請確認");
        }
        if(StringUtils.isBlank(xx)) {
            RunException.error("密鑰錯誤，請確認");
        }
        
        
        //先獲取字典，判斷有沒有開啟數據同步，密鑰可以配置在字典中，將密鑰作為查詢條件，如果查詢不到，證明密鑰不正確
        ……//省略部分代碼
        if(switch == null) {
            RunException.error("未配置數據同步");
        }

        
        //從字典表獲取同步的具體表，將具體的表和上面數據同步開關的id作為具體的parent_id，這樣直接能根據parent_id判斷系統配置需要同步的表，
        ……//省略部分代碼
        //查詢到根據parent_id和參數傳入的表名進行查詢，看表是否在同步的表配置中
        
        //查詢到表在同步表配置中，獲取表相應的數據，表名tableName一定要從配置表獲取，不是參數傳進來的表名，避免參數的表名有sql注入（雖然前面根據表名查詢，確認表名沒問題，但養成良好習慣沒什么不好）。
        Map<String, Object> paramsMap = new HashMap<String, Object>();
        paramsMap.put(TABLE_SELECT_NAME, tableName);
        
        if(!StringUtils.isBlank(tableSelectSql)) {
            paramsMap.put(TABLE_SELECT_SQL, tableSelectSql);
        }
        
        if(!StringUtils.isBlank(tableWhereSql)) {
            paramsMap.put(TABLE_WHERE_SQL, tableWhereSql);
        }
        
        return this.baseMapper.getTable(paramsMap);
    }
    
    
}

 

4、controller

@RestController
@RequestMapping("/api")
public class SyncDataController {

    @Autowired
    private SyncDataService syncDataService;
    
    
    /**
     * 同步數據
     * @param request
     * @param response
     * @param requestMap
     * @return
     * @throws Exception
     */
    @RequestMapping("/syncData")
    public Result syncData(HttpServletRequest request, HttpServletResponse response, 
            @RequestBody Map<String, String> requestMap) throws Exception {
        
        return Result.ok(syncDataService.getTable(request, requestMap));
        
    }
    
    
}

 

 

 

（如果文章對您有所幫助，歡迎捐贈，^_^）

 

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

©Copyright 蕃薯耀 2021-01-29

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