关于使用Java后台导入excel文件，读取数据后，更新数据库，并返回数据给到前端的相关问题总结_excel 导入时第一条导入后将第一条的数据返回-程序员宅基地
技术标签： 经验分享 恰饭 各种插件的技能拓展 java 后端 上传下载和导入导出 程序人生
在之前的项目中，使用到了Java后台读取excel文件数据的功能点，本想着该功能点已经做过了，这一类的应该都大差不离，不过在刚结束的一个项目中，现实给我深深的上了一课，特此编写此片博客，以作记录，并给自己提个醒，Java真的是浩瀚如海呀，任何时候其实自己都是小白，懂得越多越发谨慎。
Java后台读取excel文件数据该功能点一般与Java导出excel文件这个功能点配合使用。实际上此次的问题与之前的最大区别在于，之前导出excel文件时，明确知道导出的数据每一列的字段详情，导入excel文件数据时，数据格式便是固定的，即一个excel文件中每一列的数据，都是提前已经了解的，都是导出时所使用的字段，因此在读取到excel文件数据后，对数据的处理便简单粗暴一些，以代码为例，如下：
controller控制层：
/**
* @author gr
* @version V1.0.0
* @Description 公告接口
* @ClassName PublicController
* @Copyright (c) All Rights Reserved, 2020.
* @since 2020/08/27 15:19
*/
@Api(tags = "公共接口")
@RestController
@RequestMapping("/qwc")
public class PublicController {
@Autowired
private PublicService publicSvc;
/**
* 从EXCEL文件读取数据返回前台
* @param file 要读取的EXCEL文件
* @return 文件读取结果
*/
@ApiOperation("读取excel文件数据")
@PostMapping("/readExcel")
public ResponseEntity<DataResult<List<AttYsjEntity>>> readExcel(@RequestParam("file") MultipartFile file){
List<AttYsjEntity> result = publicSvc.readExcel(file);
return new ResponseEntity<>(ResultUtils.resultObject(result), HttpStatus.OK);
}
}service服务层：
/**
* @author gr
* @version V1.0.0
* @Description 公共接口服务层
* @ClassName PublicService
* @Copyright (c) All Rights Reserved, 2020.
* @since 2020/08/27 15:24
*/
public interface PublicService {
/**
* 从EXCEL文件读取数据返回前台
* @param file 要读取的EXCEL文件
* @return 文件读取结果
*/
List<AttYsjEntity> readExcel(MultipartFile file);
}serviceImpl服务层实现类:
/**
* @author 郭瑞
* @version V1.0.0
* @Description 公共接口服务层实现类
* @ClassName PublicServiceImpl
* @Copyright (c) All Rights Reserved, 2020.
* @since 2020/08/27 15:25
*/
@Service
public class PublicServiceImpl implements PublicService {
/**
* 从EXCEL文件读取数据返回前台
* @param file 要读取的EXCEL文件
* @return 文件读取结果
*/
@Override
public List<AttYsjEntity> readExcel(MultipartFile file){
String filename = file.getOriginalFilename();
List<AttYsjEntity>attYsjList = new ArrayList<>();
assert filename != null;
if (!filename.matches("^.+\\.(?i)(xls)$") && !filename.matches("^.+\\.(?i)(xlsx)$")){
throw new RuntimeException("上传文件格式不正确");
}
boolean isExcel2003 = true;
if (filename.matches("^.+\\.(?i)(xlsx)$")) {
isExcel2003 = false;
}
try {
InputStream iss = file.getInputStream();
Workbook wbk;
if (isExcel2003) {
wbk = new HSSFWorkbook(iss);
} else {
wbk = new XSSFWorkbook(iss);
}
Sheet sheet = wbk.getSheetAt(0);
for (int r = 3; r <= sheet.getLastRowNum(); r++) {//r = 2 表示从第三行开始循环 如果你的第三行开始是数据
Row row = sheet.getRow(r);//通过sheet表单对象得到 行对象
if (row == null){
continue;
}
AttYsjEntity attYsj = new AttYsjEntity();
String mlid = getCell(row,2,String.class);
String mc = getCell(row,3,String.class);
String lx = getCell(row,4,String.class);
String xdlj = getCell(row,5,String.class);
Integer zt = getCell(row,6,Integer.class);
Integer ysjjxid = getCell(row,7,Integer.class);
Integer xqid = getCell(row,8,Integer.class);
String featuretype = getCell(row,9,String.class);
String featuretable = getCell(row,10,String.class);
String rkr = getCell(row,11,String.class);
Date rksj = getCell(row,12,Date.class);
String rkdw = getCell(row,13,String.class);
String xgr = getCell(row,14,String.class);
Date xgsj = getCell(row,15,Date.class);
String sjlx = getCell(row,16,String.class);
Integer nd = getCell(row,17,Integer.class);
String scdw = getCell(row,18,String.class);
String blc = getCell(row,20,String.class);
String fbl = getCell(row,21,String.class);
Integer yl = getCell(row,22,Integer.class);
String xq = getCell(row,24,String.class);
Float tlX = getCell(row,27,Float.class);
Float tlY = getCell(row,28,Float.class);
Float rbX = getCell(row,29,Float.class);
Float rbY = getCell(row,30,Float.class);
String dirname = getCell(row,31,String.class);
Integer state = getCell(row,32,Integer.class);
String ssdq = getCell(row,35,String.class);
// String datasource = getCell(row,36,String.class);
String province = getCell(row,37,String.class);
//完整的循环一次 就组成了一个对象
attYsj.setMlid(mlid);
attYsj.setMc(mc);
attYsj.setLx(lx);
attYsj.setXdlj(xdlj);
attYsj.setZt(zt);
attYsj.setYsjjxid(ysjjxid);
attYsj.setXqid(xqid);
attYsj.setFeaturetype(featuretype);
attYsj.setFeaturetable(featuretable);
attYsj.setRkr(rkr);
attYsj.setRksj((java.sql.Date) rksj);
attYsj.setRkdw(rkdw);
attYsj.setXgr(xgr);
attYsj.setXgsj((java.sql.Date) xgsj);
attYsj.setSjlx(sjlx);
attYsj.setNd(nd);
attYsj.setScdw(scdw);
attYsj.setBlc(blc);
attYsj.setFbl(fbl);
attYsj.setYl(yl);
attYsj.setXq(xq);
attYsj.setTl_x(tlX);
attYsj.setTl_y(tlY);
attYsj.setRb_x(rbX);
attYsj.setRb_y(rbY);
attYsj.setDirname(dirname);
attYsj.setState(state);
attYsj.setSsdq(ssdq);
// attYsj.setDatasource(datasource);
attYsj.setProvince(province);
attYsjList.add(attYsj);
}
} catch (IOException e) {
e.printStackTrace();
}
return attYsjList;
}
private <T> T getCell(Row row, int cellNum, Class<T> clazz) {
Cell cell = row.getCell(cellNum);
if (cell != null) {
String stringCellValue = cell.getStringCellValue();
boolean hasValue = StringUtils.isNotBlank(stringCellValue);
if (Double.class.equals(clazz)) {
return (T) (hasValue ? Double.valueOf(stringCellValue) : new Double(0));
} else if (Integer.class.equals(clazz)){
return (T) (hasValue ? Integer.valueOf(stringCellValue) : new Integer(0));
} else if (Float.class.equals(clazz)){
return (T) (hasValue ? Float.valueOf(stringCellValue) : new Float(0));
} else if (String.class.equals(clazz)){
return (T) stringCellValue;
} else if (Date.class.equals(clazz)){
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date;
try {
date = hasValue ? sdf.parse(stringCellValue.substring(0,19)) : null;
} catch (ParseException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
return (T) date;
} else {
return (T) stringCellValue;
}
} else {
return null;
}
}
}如此实现导入excel文档的功能，是可以用的，但是具有很多的局限性，excel文档中的数据以列显示时，必须对映AttYsjEntity 该实体类的字段排序以及字段类型，不然就会出现数据不对应的错误。
这次项目中需要实现的excel文档的功能地点，因为导出时数据不是通过后端导出，直接从前端导出的页面数据，并且会导出不同页面的数据，因此数据字段是否存在不确定，字段排序不确定，字段类型不确定。通过参考各种导入方式，实现了功能的解决方案为：在导出时，不仅仅只是导出数据，如同正常的excel表格数据一样，需要在首行先导出表头，即规定了该列的字段信息，先读取各字段即表头，再读取相关数据即可，上代码：
将数据读取的功能封装了一个工具类：
package com.ma.utils;
import org.apache.poi.ss.usermodel.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @Author gr
* @Version V1.0.0
* @Description excel文件处理工具类
* @ClassName ExcelUtils
* @Copyright (c) All Rights Reserved, 2020.
* @Since 2021/05/15 22:08
*/
public class ExcelUtils {
private static final Logger LOGGER = LoggerFactory.getLogger(ExcelUtils.class);
@SuppressWarnings("deprecation")
public static List<Map<String,Object>> excelToShopIdList(InputStream inputStream) {
List<Map<String,Object>> list = new ArrayList<>();
Workbook workbook;
try {
workbook = WorkbookFactory.create(inputStream);
inputStream.close();
//工作表对象
Sheet sheet = workbook.getSheetAt(0);
//总行数
int rowLength = sheet.getLastRowNum() + 1;
//工作表的列
Row row = sheet.getRow(0);
//总列数
int colLength = row.getLastCellNum();
//得到指定的单元格
Cell cell;
for (int i = 1; i < rowLength; i++) {
Map<String,Object> ydxxInfo = new HashMap<>();
//工作表的列
Row rowHead = sheet.getRow(0);
row = sheet.getRow(i);
for (int j = 0; j < colLength; j++) {
Cell cellHead = rowHead.getCell(j);
String dataHead = null;
String data = null;
if(cellHead!=null){
cellHead.setCellType(Cell.CELL_TYPE_STRING);
dataHead = cellHead.getStringCellValue();
dataHead = dataHead.trim();
}
cell = row.getCell(j);
if (cell!=null){
cell.setCellType(Cell.CELL_TYPE_STRING);
data = cell.getStringCellValue();
data = data.trim();
}
ydxxInfo.put(dataHead,data);
}
list.add(ydxxInfo);
}
} catch (Exception e) {
LOGGER.error("parse excel file error :", e);
}
return list;
}
}
controller控制层代码：
/**
* 控制器
* @author luyifa
* 工单办理
*/
@RestController
@RequestMapping("/gdbl")
public class GdblController {
private final static Logger logger = (Logger) LoggerFactory.getLogger(TestController.class);
/**
* 从任意excel文件读取数据返回前台(任意excel文件导入)
* 当前接口可导入携带表头的任意excel表格文件数据
* @param file 要读取的excel文件
* @return 文件读取结果
* @author gr 20210516
*/
@RequestMapping("/readExcel2")
public ResponseEntity<Object> readExcel(@RequestParam("file") MultipartFile file) throws IOException{
String name = file.getOriginalFilename();
if (name.length() < 6 || !name.substring(name.length() - 5).equals(".xlsx")) {
return new ResponseEntity<Object>("文件格式错误", HttpStatus.INTERNAL_SERVER_ERROR);
}
//TODO 业务逻辑，通过file.getInputStream()，处理Excel文件
List<Map<String,Object>> result = ExcelUtils.excelToShopIdList(file.getInputStream());
logger.info("导入成功");
return new ResponseEntity<Object>(result,HttpStatus.OK);
}
}导入的数据可以返回前端了，把接口返回前端的数据拿出来看看
到了这一步已经把该功能点的重点完成的差不多了，接下来需要将解析的数据拿到，更新数据库，更改controller中接口如下：
/**
* 从任意excel文件读取数据
* 并更新数据库中间表YDXXINFO后返回前台(任意excel文件导入)
* 当前接口可导入携带表头的任意excel表格文件数据
* @param file 要读取的excel文件
* @return 文件读取结果
* @author gr 20210517
*/
@RequestMapping("/readExcel")
public ResponseEntity<Object> readExcelAndUpdateBase(@RequestParam("file") MultipartFile file) throws IOException{
String name = file.getOriginalFilename();
if (name.length() < 6 || !name.substring(name.length() - 5).equals(".xlsx")) {
return new ResponseEntity<Object>("文件格式错误", HttpStatus.INTERNAL_SERVER_ERROR);
}
//TODO 业务逻辑，通过file.getInputStream()，处理Excel文件
List<Map<String,Object>> result = ExcelUtils.excelToShopIdList(file.getInputStream());
List<Map<String,Object>> ydxxIndoUpdateLists = new ArrayList<>();
for(Map<String,Object> ydxxInfos:result ){
Map<String,Object> ydxxIndoUpdate = new HashMap<String,Object>();
String ydxxId = "null";
String finish = "null";
String validYd = "null";
String remedyDl = "null";
String remedyDf = "null";
String causeYd = "null";
if(ydxxInfos.get("异动唯一标识")!=null&&StringUtils.isNotBlank(ydxxInfos.get("异动唯一标识").toString())){
ydxxId = ydxxInfos.get("异动唯一标识").toString();
}
if(ydxxInfos.get("是否办结")!=null&&StringUtils.isNotBlank(ydxxInfos.get("是否办结").toString())){
if(ydxxInfos.get("是否办结").equals("是")){
finish = "1";
}else {
finish = "0";
}
}
if(ydxxInfos.get("是否有效异动")!=null&&StringUtils.isNotBlank(ydxxInfos.get("是否有效异动").toString())){
if(ydxxInfos.get("是否有效异动").equals("是")){
validYd = "1";
}else {
validYd = "0";
}
}
if(ydxxInfos.get("追补电量")!=null&&StringUtils.isNotBlank(ydxxInfos.get("追补电量").toString())){
remedyDl = ydxxInfos.get("追补电量").toString();
}
if(ydxxInfos.get("追补电费")!=null&&StringUtils.isNotBlank(ydxxInfos.get("追补电费").toString())){
remedyDf = ydxxInfos.get("追补电费").toString();
}
if(ydxxInfos.get("异动原因")!=null&&StringUtils.isNotBlank(ydxxInfos.get("异动原因").toString())){
switch (ydxxInfos.get("异动原因").toString()) {
case "档案问题（无电量追补）":
causeYd = "01";
break;
case "用户责任":
causeYd = "02";
break;
case "企业责任":
causeYd = "03";
break;
case "用户企业均有责任":
causeYd = "04";
break;
}
}
ydxxIndoUpdate.put("finish", finish);
ydxxIndoUpdate.put("validYd", validYd);
ydxxIndoUpdate.put("remedyDl", remedyDl);
ydxxIndoUpdate.put("remedyDf", remedyDf);
ydxxIndoUpdate.put("causeYd", causeYd);
ydxxIndoUpdate.put("ydxxId", ydxxId);
ydxxIndoUpdateLists.add(ydxxIndoUpdate);
}
int updateResult = iGdblService.updataSheetInfoDept2(ydxxIndoUpdateLists);
logger.info("导入成功");
return new ResponseEntity<Object>(result,HttpStatus.OK);
}ok，大功告成！在返回前端数据之前，将重要数据提取，调用批量更新的方法，对这部分数据做数据库更新，至此该功能点完成所有需求。
先到这里，去撸代码了！
智能推荐
Docker 快速上手学习入门教程_docker菜鸟教程-程序员宅基地
文章浏览阅读2.5w次，点赞6次，收藏50次。官方解释是，docker 容器是机器上的沙盒进程，它与主机上的所有其他进程隔离。所以容器只是操作系统中被隔离开来的一个进程，所谓的容器化，其实也只是对操作系统进行欺骗的一种语法糖。_docker菜鸟教程
电脑技巧：Windows系统原版纯净软件必备的两个网站_msdn我告诉你-程序员宅基地
文章浏览阅读5.7k次，点赞3次，收藏14次。该如何避免的，今天小编给大家推荐两个下载Windows系统官方软件的资源网站，可以杜绝软件捆绑等行为。该站提供了丰富的Windows官方技术资源，比较重要的有MSDN技术资源文档库、官方工具和资源、应用程序、开发人员工具（Visual Studio 、SQLServer等等）、系统镜像、设计人员工具等。总的来说，这两个都是非常优秀的Windows系统镜像资源站，提供了丰富的Windows系统镜像资源，并且保证了资源的纯净和安全性，有需要的朋友可以去了解一下。这个非常实用的资源网站的创建者是国内的一个网友。_msdn我告诉你
vue2封装对话框el-dialog组件_<el-dialog 封装成组件 vue2-程序员宅基地
文章浏览阅读1.2k次。vue2封装对话框el-dialog组件_
MFC 文本框换行_c++ mfc同一框内输入二行怎么换行-程序员宅基地
文章浏览阅读4.7k次，点赞5次，收藏6次。MFC 文本框换行 标签： it mfc 文本框1.将Multiline属性设置为True2.换行是使用"\r\n" (宽字符串为L"\r\n")3.如果需要编辑并且按Enter键换行,还要将 Want Return 设置为 True4.如果需要垂直滚动条的话将Vertical Scroll属性设置为True,需要水平滚动条的话将Horizontal Scroll属性设_c++ mfc同一框内输入二行怎么换行
redis-desktop-manager无法连接redis-server的解决方法_redis-server doesn't support auth command or ismis-程序员宅基地
文章浏览阅读832次。检查Linux是否是否开启所需端口，默认为6379，若未打开，将其开启：以root用户执行iptables -I INPUT -p tcp --dport 6379 -j ACCEPT如果还是未能解决，修改redis.conf，修改主机地址：bind 192.168.85.**；然后使用该配置文件，重新启动Redis服务./redis-server redis.conf..._redis-server doesn't support auth command or ismisconfigured. try
实验四 数据选择器及其应用-程序员宅基地
文章浏览阅读4.9k次。济大数电实验报告_数据选择器及其应用
随便推点
灰色预测模型matlab_MATLAB实战|基于灰色预测河南省社会消费品零售总额预测-程序员宅基地
文章浏览阅读236次。1研究内容消费在生产中占据十分重要的地位，是生产的最终目的和动力，是保持省内经济稳定快速发展的核心要素。预测河南省社会消费品零售总额，是进行宏观经济调控和消费体制改变创新的基础，是河南省内人民对美好的全面和谐社会的追求的要求，保持河南省经济稳定和可持续发展具有重要意义。本文建立灰色预测模型，利用MATLAB软件，预测出2019年~2023年河南省社会消费品零售总额预测值分别为21881...._灰色预测模型用什么软件
log4qt-程序员宅基地
文章浏览阅读1.2k次。12.4-在Qt中使用Log4Qt输出Log文件，看这一篇就足够了一、为啥要使用第三方Log库，而不用平台自带的Log库二、Log4j系列库的功能介绍与基本概念三、Log4Qt库的基本介绍四、将Log4qt组装成为一个单独模块五、使用配置文件的方式配置Log4Qt六、使用代码的方式配置Log4Qt七、在Qt工程中引入Log4Qt库模块的方法八、获取示例中的源代码一、为啥要使用第三方Log库，而不用平台自带的Log库首先要说明的是，在平时开发和调试中开发平台自带的“打印输出”已经足够了。但_log4qt
100种思维模型之全局观思维模型-67_计算机中对于全局观的-程序员宅基地
文章浏览阅读786次。全局观思维模型，一个教我们由点到线，由线到面，再由面到体，不断的放大格局去思考问题的思维模型。_计算机中对于全局观的
线程间控制之CountDownLatch和CyclicBarrier使用介绍_countdownluach于cyclicbarrier的用法-程序员宅基地
文章浏览阅读330次。一、CountDownLatch介绍CountDownLatch采用减法计算；是一个同步辅助工具类和CyclicBarrier类功能类似，允许一个或多个线程等待，直到在其他线程中执行的一组操作完成。二、CountDownLatch俩种应用场景： 场景一：所有线程在等待开始信号(startSignal.await()),主流程发出开始信号通知，既执行startSignal.countDown()方法后;所有线程才开始执行；每个线程执行完发出做完信号，既执行do..._countdownluach于cyclicbarrier的用法
自动化监控系统Prometheus&Grafana_-自动化监控系统prometheus&grafana实战-程序员宅基地
文章浏览阅读508次。Prometheus 算是一个全能型选手，原生支持容器监控，当然监控传统应用也不是吃干饭的，所以就是容器和非容器他都支持，所有的监控系统都具备这个流程，_-自动化监控系统prometheus&grafana实战
React 组件封装之 Search 搜索_react search-程序员宅基地
文章浏览阅读4.7k次。输入关键字，可以通过键盘的搜索按钮完成搜索功能。_react search