forked from fanruan/easyexcel
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
80 lines
2.6 KiB
80 lines
2.6 KiB
package com.alibaba.easyexcel.test.demo.read; |
|
|
|
import java.util.ArrayList; |
|
import java.util.List; |
|
import java.util.Map; |
|
|
|
import org.slf4j.Logger; |
|
import org.slf4j.LoggerFactory; |
|
|
|
import com.alibaba.excel.context.AnalysisContext; |
|
import com.alibaba.excel.event.AnalysisEventListener; |
|
import com.alibaba.excel.exception.ExcelDataConvertException; |
|
import com.alibaba.fastjson.JSON; |
|
|
|
/** |
|
* 读取转换异常 |
|
* |
|
* @author Jiaju Zhuang |
|
*/ |
|
public class DemoExceptionListener extends AnalysisEventListener<ExceptionDemoData> { |
|
private static final Logger LOGGER = LoggerFactory.getLogger(DemoExceptionListener.class); |
|
/** |
|
* 每隔5条存储数据库,实际使用中可以3000条,然后清理list ,方便内存回收 |
|
*/ |
|
private static final int BATCH_COUNT = 5; |
|
List<ExceptionDemoData> list = new ArrayList<ExceptionDemoData>(); |
|
|
|
/** |
|
* 在转换异常 获取其他异常下会调用本接口。抛出异常则停止读取。如果这里不抛出异常则 继续读取下一行。 |
|
* |
|
* @param exception |
|
* @param context |
|
* @throws Exception |
|
*/ |
|
@Override |
|
public void onException(Exception exception, AnalysisContext context) { |
|
LOGGER.error("解析失败,但是继续解析下一行:{}", exception.getMessage()); |
|
// 如果是某一个单元格的转换异常 能获取到具体行号 |
|
// 如果要获取头的信息 配合invokeHeadMap使用 |
|
if (exception instanceof ExcelDataConvertException) { |
|
ExcelDataConvertException excelDataConvertException = (ExcelDataConvertException)exception; |
|
LOGGER.error("第{}行,第{}列解析异常", excelDataConvertException.getRowIndex(), |
|
excelDataConvertException.getColumnIndex()); |
|
} |
|
} |
|
|
|
/** |
|
* 这里会一行行的返回头 |
|
* |
|
* @param headMap |
|
* @param context |
|
*/ |
|
@Override |
|
public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) { |
|
LOGGER.info("解析到一条头数据:{}", JSON.toJSONString(headMap)); |
|
} |
|
|
|
@Override |
|
public void invoke(ExceptionDemoData data, AnalysisContext context) { |
|
LOGGER.info("解析到一条数据:{}", JSON.toJSONString(data)); |
|
if (list.size() >= BATCH_COUNT) { |
|
saveData(); |
|
list.clear(); |
|
} |
|
} |
|
|
|
@Override |
|
public void doAfterAllAnalysed(AnalysisContext context) { |
|
saveData(); |
|
LOGGER.info("所有数据解析完成!"); |
|
} |
|
|
|
/** |
|
* 加上存储数据库 |
|
*/ |
|
private void saveData() { |
|
LOGGER.info("{}条数据,开始存储数据库!", list.size()); |
|
LOGGER.info("存储数据库成功!"); |
|
} |
|
}
|
|
|