🐛 Fixing a bug.insertBatchSomeColumn是mysql特有语法,不支持跨数据库操作

2021-12-24 11:43:56 +08:00
1 parent 7d0e1ddfed
commit 6f9259dc9b
@@ -2,7 +2,6 @@ package com.pig4cloud.pigx.common.data.datascope;

 import com.baomidou.mybatisplus.core.injector.AbstractMethod;
 import com.baomidou.mybatisplus.core.injector.DefaultSqlInjector;
-import com.baomidou.mybatisplus.extension.injector.methods.InsertBatchSomeColumn;

 import java.util.List;

@@ -20,7 +19,6 @@ public class DataScopeSqlInjector extends DefaultSqlInjector {
 		methodList.add(new SelectListByScope());
 		methodList.add(new SelectPageByScope());
 		methodList.add(new SelectCountByScope());
-		methodList.add(new InsertBatchSomeColumn());
 		return methodList;
 	}

@@ -42,11 +42,4 @@ public interface PigxBaseMapper<T> extends BaseMapper<T> {
 	 */
 	Integer selectCountByScope(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper, DataScope scope);

-	/**
-	 * 批量插入 仅适用于 mysql
-	 * @param entityList 实体列表
-	 * @return 影响行数
-	 */
-	Integer insertBatchSomeColumn(List<T> entityList);
-
 }
@@ -63,7 +63,7 @@ public class SysDeptRelationServiceImpl extends ServiceImpl<SysDeptRelationMappe
 					return relation;
 				}).collect(Collectors.toList());
 		if (CollUtil.isNotEmpty(relationList)) {
-			baseMapper.insertBatchSomeColumn(relationList);
+			relationList.forEach(ele -> baseMapper.insert(ele));
 		}

 		// 自己也要维护到关系表中
@@ -74,8 +74,7 @@ public class SysRoleMenuServiceImpl extends ServiceImpl<SysRoleMenuMapper, SysRo

 		// 清空userinfo
 		cacheManager.getCache(CacheConstants.USER_DETAILS).clear();
-
-		baseMapper.insertBatchSomeColumn(roleMenuList);
+		roleMenuList.forEach(ele -> baseMapper.insert(ele));
 		return Boolean.TRUE;
 	}

@@ -167,7 +167,7 @@ public class SysTenantServiceImpl extends ServiceImpl<SysTenantMapper, SysTenant
 				roleMenu.setMenuId(menu.getMenuId());
 				return roleMenu;
 			}).collect(Collectors.toList());
-			roleMenuMapper.insertBatchSomeColumn(roleMenuList);
+			roleMenuList.forEach(ele -> roleMenuMapper.insert(ele));
 			// 插入系统字典
 			dictService.saveBatch(dictList.stream().peek(d -> d.setId(null)).collect(Collectors.toList()));
 			// 处理字典项最新关联的字典ID
@@ -11,20 +11,20 @@ import com.anjiplus.template.gaea.business.modules.dashboard.controller.dto.Char
 import com.anjiplus.template.gaea.business.modules.dashboard.controller.dto.ReportDashboardDto;
 import com.anjiplus.template.gaea.business.modules.dashboard.controller.dto.ReportDashboardObjectDto;
 import com.anjiplus.template.gaea.business.modules.dashboard.dao.ReportDashboardMapper;
+import com.anjiplus.template.gaea.business.modules.dashboard.dao.entity.ReportDashboard;
 import com.anjiplus.template.gaea.business.modules.dashboard.service.ChartStrategy;
 import com.anjiplus.template.gaea.business.modules.dashboard.service.ReportDashboardService;
-import com.anjiplus.template.gaea.business.modules.file.entity.GaeaFile;
-import com.anjiplus.template.gaea.business.modules.file.service.GaeaFileService;
-import com.anjiplus.template.gaea.business.modules.file.util.FileUtils;
-import com.anjiplus.template.gaea.business.util.DateUtil;
 import com.anjiplus.template.gaea.business.modules.dashboardwidget.controller.dto.ReportDashboardWidgetDto;
 import com.anjiplus.template.gaea.business.modules.dashboardwidget.controller.dto.ReportDashboardWidgetValueDto;
-import com.anjiplus.template.gaea.business.modules.dashboard.dao.entity.ReportDashboard;
 import com.anjiplus.template.gaea.business.modules.dashboardwidget.dao.entity.ReportDashboardWidget;
 import com.anjiplus.template.gaea.business.modules.dashboardwidget.service.ReportDashboardWidgetService;
 import com.anjiplus.template.gaea.business.modules.dataset.controller.dto.DataSetDto;
 import com.anjiplus.template.gaea.business.modules.dataset.controller.dto.OriginalDataDto;
 import com.anjiplus.template.gaea.business.modules.dataset.service.DataSetService;
+import com.anjiplus.template.gaea.business.modules.file.entity.GaeaFile;
+import com.anjiplus.template.gaea.business.modules.file.service.GaeaFileService;
+import com.anjiplus.template.gaea.business.modules.file.util.FileUtils;
+import com.anjiplus.template.gaea.business.util.DateUtil;
 import com.anjiplus.template.gaea.business.util.FileUtil;
 import com.anjiplus.template.gaea.business.util.UuidUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -48,7 +48,6 @@ import org.springframework.web.multipart.MultipartFile;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.File;
-import java.net.URLEncoder;
 import java.text.SimpleDateFormat;
 import java.util.*;

@@ -84,7 +83,7 @@ public class ReportDashboardServiceImpl implements ReportDashboardService, Initi

 	private final static String JSON_PATH = "dashboard.json";

-	private Map<String, ChartStrategy> queryServiceImplMap = new HashMap<>();
+	private final Map<String, ChartStrategy> queryServiceImplMap = new HashMap<>();

 	private ApplicationContext applicationContext;

@@ -185,10 +184,7 @@ public class ReportDashboardServiceImpl implements ReportDashboardService, Initi

 			// 兼容底层，不采用批量插入
 			reportDashboardWidgetService.insert(reportDashboardWidget);
-
-			// reportDashboardWidgetList.add(reportDashboardWidget);
 		}
-		// reportDashboardWidgetService.insertBatch(reportDashboardWidgetList);

 	}

@@ -8,8 +8,8 @@ import com.anji.plus.gaea.curd.mapper.GaeaBaseMapper;
 import com.anji.plus.gaea.exception.BusinessExceptionBuilder;
 import com.anji.plus.gaea.utils.GaeaBeanUtils;
 import com.anjiplus.template.gaea.business.code.ResponseCode;
-import com.anjiplus.template.gaea.business.modules.dataset.controller.dto.OriginalDataDto;
 import com.anjiplus.template.gaea.business.modules.dataset.controller.dto.DataSetDto;
+import com.anjiplus.template.gaea.business.modules.dataset.controller.dto.OriginalDataDto;
 import com.anjiplus.template.gaea.business.modules.dataset.dao.DataSetMapper;
 import com.anjiplus.template.gaea.business.modules.dataset.dao.entity.DataSet;
 import com.anjiplus.template.gaea.business.modules.dataset.service.DataSetService;
@@ -296,9 +296,7 @@ public class DataSetServiceImpl implements DataSetService {
 			dataSetParam.setSetCode(setCode);
 			// 不采用批量
 			dataSetParamService.insert(dataSetParam);
-			// dataSetParamList.add(dataSetParam);
 		});
-		// dataSetParamService.insertBatch(dataSetParamList);

 	}

@@ -316,9 +314,7 @@ public class DataSetServiceImpl implements DataSetService {
 			dataSetTransform.setSetCode(setCode);
 			// 不采用批量
 			dataSetTransformService.insert(dataSetTransform);
-			// dataSetTransformList.add(dataSetTransform);
 		}
-		// dataSetTransformService.insertBatch(dataSetTransformList);
 	}

 }