``` /** * @author 张跃帅 * @Description: 数据库DML-执行器 * @date 2020/08/12 */ public class DmlRun { private static final DmlMapper dmlMapper = SpringUtil.getBean(DmlMapper.class); /** * 通用查询-获取List列表 */ public static List<Dict> selectList(String sql) { // 变量创建ArrayList List<Dict> resultDictList = CollectionUtil.newArrayList(); // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL resultDictList = dmlMapper.selectList(sql); } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return resultDictList; } /** * 通用查询-获取一条数据 */ public static Dict selectOne(String sql) { // 变量创建Dict Dict resultDict = Dict.create(); // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL resultDict = dmlMapper.selectOne(sql); } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return resultDict; } /** * 通用查询-获取总记录数 */ public static long selectCount(String sql) { // 变量 long resultCount = 0L; // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL resultCount = dmlMapper.selectCount(sql); } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return resultCount; } /** * 通用新增 */ public static boolean insert(String sql) { // 执行结果 boolean result = false; // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL result = dmlMapper.insert(sql); } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return result; } /** * 通用-批量新增 */ public static void saveBatch(String tableName, List<Dict> formDataList) { // 判断 if (StrUtil.isNotBlank(tableName) && formDataList != null && formDataList.size() > 0) { // 获取List第一条数据 Dict tableDcit = formDataList.get(0); // 判断 if (MapUtil.isNotEmpty(tableDcit)) { // 变量参数 String tableColumnStr = ""; // Dict转set集合 Set<String> tableSet = tableDcit.keySet(); // 遍历 for (String key : tableSet) { // 添加 tableColumnStr += StrUtil.toUnderlineCase(key) + StrUtil.COMMA + StrUtil.SPACE; } // 判断 if (StrUtil.isNotBlank(tableColumnStr)) { // 参数截取 String tableColumn = tableColumnStr.substring(0, tableColumnStr.length() - 2); // 创建Dict Dict tableDataMap = Dict.create(); // 添加 tableDataMap.put("tableName", tableName); tableDataMap.put("tableColumn", tableColumn); tableDataMap.put("tableDataList", formDataList); // 执行SQL dmlMapper.saveBatch(tableDataMap); } } } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } } /** * 通用更新 */ public static boolean update(String sql) { // 执行结果 boolean result = false; // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL result = dmlMapper.update(sql); } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return result; } /** * 通用删除 */ public static boolean delete(String sql) { // 执行结果 boolean result = false; // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL result = dmlMapper.delete(sql); } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return result; } /** * 通用执行任意Sql-返回true或false */ public static boolean runAnySql(String sql) { // 执行结果 Boolean result = false; // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL Boolean currentResult = dmlMapper.runAnySql(sql); // 判断 if (null == currentResult) { // 赋值 result = true; } else { // 赋值 result = currentResult; } } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return result; } /** * 通用执行任意Sql-返回String */ public static String runAnySqlToStr(String sql) { // 执行结果 String result = null; // 判断 if (StrUtil.isNotBlank(sql)) { // 执行SQL String currentResult = dmlMapper.runAnySqlToStr(sql); // 判断 if (StrUtil.isNotBlank(currentResult)) { // 赋值 result = currentResult; } } else { // 抛出异常 throw new MyException(DmlExceptionEnum.SQL_NOT_NULL); } // 返回 return result; } }