/*** 读取转换异常

**/

public class DemoExceptionListener extends AnalysisEventListener{private static final Logger LOGGER = LoggerFactory.getLogger(DemoExceptionListener.class);/*** 每隔5条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收*/

private static final int BATCH_COUNT = 5;

List list = new ArrayList();//定义接收异常

private StringBuffer errorMsg;/*** 在转换异常 获取其他异常下会调用本接口。抛出异常则停止读取。如果这里不抛出异常则 继续读取下一行。

*

*@paramexception

*@paramcontext

*@throwsException*/@Overridepublic voidonException(Exception exception, AnalysisContext context) {

LOGGER.error("解析失败，但是继续解析下一行:{}", exception.getMessage());//如果是某一个单元格的转换异常 能获取到具体行号//如果要获取头的信息 配合invokeHeadMap使用

if (exception instanceofExcelDataConvertException) {

ExcelDataConvertException excelDataConvertException=(ExcelDataConvertException)exception;

LOGGER.error("第{}行，第{}列解析异常，数据为:{}", excelDataConvertException.getRowIndex(),

excelDataConvertException.getColumnIndex(), excelDataConvertException.getCellData());

String msg="第"+excelDataConvertException.getRowIndex()+"行，第"+excelDataConvertException.getColumnIndex()+"列解析异常，数据为:"+

excelDataConvertException.getCellData();

if(errorMsg==null){

errorMsg=new StringBuffer();

}

//拼接报错信息errorMsg.append(msg).append(System.lineSeparator());

}

}/*** 这里会一行行的返回头

*

*@paramheadMap

*@paramcontext*/@Overridepublic void invokeHeadMap(MapheadMap, AnalysisContext context) {

LOGGER.info("解析到一条头数据:{}", JSON.toJSONString(headMap));

}

@Overridepublic voidinvoke(ExceptionDemoData data, AnalysisContext context) {

LOGGER.info("解析到一条数据:{}", JSON.toJSONString(data));if (list.size() >=BATCH_COUNT) {//操作数据之前统一判断异常信息,可以直接抛异常

if (errorMsg != null && errorMsg.length() > 0) {

// throw new RuntimeException("解析数据异常!!信息:"+errorMsg.toString());

LOGGER.error("解析数据异常!!信息:" +errorMsg.toString());

}

saveData();

list.clear();

}

}

@Overridepublic voiddoAfterAllAnalysed(AnalysisContext context) {操作数据之前统一判断异常信息

/*if (errorMsg != null && errorMsg.length() > 0) {

// throw new RuntimeException("解析数据异常!!信息:"+errorMsg.toString());

LOGGER.error("解析数据异常!!信息:" + errorMsg.toString());

}else{

LOGGER.info("所有数据解析完成！");

//解析完成无错误保存数据

saveData();

}*/}/*** 加上存储数据库*/

private voidsaveData() {

LOGGER.info("{}条数据，开始存储数据库！", list.size());

LOGGER.info("存储数据库成功！");

}

}