java代码实现excel文件数据导入

因业务需求要实现数据的批量导入，给了指定的excel模板上传文件，用java代码实现导入excel文件。

重新复习下。

下面是源码，仅供参考。

controller层代码，创建临时目录后，使用DiskFileItemFactory类来实现文件上传，List parseRequest(HttpServletRequest request)方法来解析request对象，并把表单中的每一个输入项包装成一个fileItem 对象，并返回一个保存了所有FileItem的list集合。

 @RequestMapping("/doImport")@ResponseBody@Transactional(rollbackFor = Exception.class, isolation = Isolation.DEFAULT, propagation = Propagation.REQUIRED)public Map<String, Object> doImport(HttpServletRequest request, HttpSession session) throws Exception{Map<String, Object> map = new HashMap<>();String path = System.getProperty("web.root");//创建临时文件目录String tempPath = path + File.separator + "attach" + File.separator;//创建File类实例File tempFile = new File(tempPath + "temp");int userId = PubFunc.parseInt(session.getAttribute("user_id"));try {//创建FileItem 对象的工厂DiskFileItemFactory diskFileItemFactory = new DiskFileItemFactory();//指定临时文件目录diskFileItemFactory.setRepository(tempFile);//负责处理上传的文件数据，并将表单中每个输入项封装成一个FileItem 对象中ServletFileUpload servletFileUpload = new ServletFileUpload(diskFileItemFactory);//解析request对象，把表单中的每一个输入项包装成一个fileItem 对象List<FileItem> lists = servletFileUpload.parseRequest(request);int len = lists.size();for (int n = 0; n < len; n++) {FileItem item = lists.get(n);if (!item.isFormField()) {if (item.getName().length() > 0) {InputStream inputStream = item.getInputStream();unabledService.doImportExl(item.getName(), inputStream, userId);map.put("code",0);map.put("msg", "文件上传中，稍后自动跳转" );}}}}catch (FileNotFoundException e) {map.put("code",1);map.put("msg", "文件未找到或文件格式错误！");} catch (IOException e) {map.put("code",2);map.put("msg", "文件内容读取失败");} catch (IllegalAccessException e) {map.put("code",3);map.put("msg", "用户信息写入失败");} catch (NoSuchFieldException e) {map.put("code",4);map.put("msg", "找不到该属性值");} catch (NullPointerException e) {map.put("code",5);map.put("msg", "文件未上传");} catch (InvalidFormatException e) {map.put("code",6);map.put("msg", "文件格式错误");} catch (Exception e) {e.printStackTrace();map.put("code",7);map.put("msg", e.getMessage());}return map;}

service层代码，里面有两个方法需要注意，一个是readExcel(fileName,inputStream)方法，通过流来读取excel数据，并对excel里面的数据做重复校验。另一个是insert_batch(unableds,userId)方法，用来将数据批量插入，

  /*** 执行导入数据操作** @param fileName    文件名* @param inputStream 数据流* @throws NoSuchFieldException* @throws IllegalAccessException*/@Overridepublic int doImportExl(String fileName, InputStream inputStream, int userId) throws Exception {//读取数据List<Map<String, Object>> list = readExcel(fileName, inputStream);if (list == null || list.isEmpty()) {throw new Exception("导入数据存在相同手机号");}//插入数据条数记录int i = 0;//迭代器Iterator<Map<String, Object>> iterator = list.iterator();Map<String, Object> fieldMap = getFieldsMap(122);List<Unabled> unableds = new ArrayList<>();while (iterator.hasNext()) {Map<String, Object> map = iterator.next();Unabled unabled = new Unabled();//反射获取所有属性Class<? extends Unabled> clazz = unabled.getClass();for (String key : fieldMap.keySet()) {String value = PubFunc.toString(map.get(PubFunc.toString(fieldMap.get(key))));if (!PubFunc.isNullStr(value)) {Field field = clazz.getDeclaredField(key);//设置私有属性允许更改field.setAccessible(true);field.set(unabled, value);}}unableds.add(unabled);}int res = insert_batch(unableds, userId);return res;}

readExcel(fileName,inputStream)方法代码

 private List<Map<String, Object>> readExcel(String fileName, InputStream inputStream) throws IOException, InvalidFormatException {//校验文件boolean ret = isXls(fileName);Workbook wb = null;//根据后缀新建对应的工作簿if (ret) {wb = new HSSFWorkbook(inputStream);} else {wb = WorkbookFactory.create(inputStream);}//获取第一个sheetSheet sheet = wb.getSheetAt(0);//标题行Row titleRow = sheet.getRow(0);//获取最大行数及列数int max_row = sheet.getLastRowNum();int max_cell = titleRow.getLastCellNum() - 1;//存放数据List<Map<String, Object>> list = new ArrayList<>();//存放手机号做重复校验for (int i = 1; i <= max_row; i++) {Map<String, Object> map = new HashMap<>();Row row = sheet.getRow(i);if (row == null) {break;}for (int j = 0; j < max_cell; j++) {String cellTitle = titleRow.getCell(j).getStringCellValue();Cell cell = row.getCell(j);String cellValue;//对空值进行处理if (cell == null) {cellValue = "";} else {cell.setCellType(Cell.CELL_TYPE_STRING);cellValue = cell.getStringCellValue();}map.put(cellTitle, cellValue);}list.add(map);}wb.close();return list;}

insert_batch(unableds,userId)方法代码，newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。

   @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class, isolation = Isolation.DEFAULT)public int insert_batch(List<Unabled> unableds, int userId) throws Exception {//创建一个线程安全的ConcurrentHashMap集合ConcurrentHashMap<String, Object> map = new ConcurrentHashMap<>();//创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程ExecutorService threadPoolExecutor = Executors.newCachedThreadPool();// 主线程等待子线程执行完成再执行final CountDownLatch countDownLatch = new CountDownLatch(unableds.size() / 500 == 0 ? 1 : unableds.size() / 500);for (int i = 0; i < unableds.size(); i += 500) {if (i > unableds.size()) {break;}int j = i + 500;List<Unabled> list = j > unableds.size() ? unableds.subList(i, unableds.size()) : unableds.subList(i, j);threadPoolExecutor.execute(new Runnable() {@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + ":" + System.currentTimeMillis());for (int k = 0; k < list.size(); k++) {Unabled unabled = list.get(k);int res = 0;try {//插入数据res = insert(unabled, userId);System.out.println("用户添加/更新成功：" + unabled.getF_1402() + ":" + unabled.getF_1403());} catch (Exception e) {System.out.println("用户添加失败：" + unabled.getF_1402() + ":" + unabled.getF_1403());}if (res == 0) {map.put(unabled.getF_1402(), unabled);}}//如果计数到达零，则释放所有等待的线程countDownLatch.countDown();System.out.println(Thread.currentThread().getName() + ":" + System.currentTimeMillis());}});}countDownLatch.await();threadPoolExecutor.shutdown();for (String key : map.keySet()) {log.info("导入失败：" + key);System.out.println("导入失败：" + key);throw new Exception("导入失败: " + key+",该用户手机号可能被占用");}return 0;}

java代码实现excel文件数据导入相关推荐

java代码实现excel文件转换为csv文件
java代码实现excel文件转换为csv文件 pom文件导入 <dependencies><dependency><groupId>org.springframe ...
Excel文件数据导入到MySQL数据库
这里以Navicat客户端工具为例,当然版本也有关系这里我用的是16. 1.把Excel文件数据第一行改成对应的数据库字段 2.右键目标表-->导入向导-->选择excel文件格式 3.注 ...
net以execl做数据库_C#.NET Excel文件数据导入SQL Server数据库完整代码
展开全部在日常的项目中,Excel,Word,txt等格式的数62616964757a686964616fe58685e5aeb931333337626235据导入到数据库中是很常见这里将分为.n ...
Java POI实现Excel文件批量导入（兼容xls,xlsx）
1.POI使用详解 1.1.什么是Apache POI? POI是Apache软件基金会用Java编写的免费开源的跨平台的 Java API,Apache POI提供API给Java程序对Micros ...
java代码将excel文件中的内容列表转换成JS文件输出
思路分析我们想要把excel文件中的内容转为其他形式的文件输出,肯定需要分两步走: 1.把excel文件中的内容读出来: 2.将内容写到新的文件中. 举例一张excel表中有一个表格: 我们需要将 ...
java代码读取excel文件_Java 读取excel 文件流代码实例
这篇文章主要介绍了Java 读取excel 文件流代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下代码如下 public static vo ...
java代码读取excel文件，同时兼容2003和2007
后台服务器需要一个读取excel文件的工具,查了些资料,很多不能同时兼容2003和2007,整理了一下,加了一个判断,现在能同时兼容2003和2007,并且可以选择从表格的第几行开始读取.主要用到了a ...
excel文件数据导入mysql数据库中_将excel里面的数据导入mysql数据库中
展开全部条件:PC端已经安装Navicat工具,并636f70793231313335323631343130323136353331333363386161且已经成功连接至数据库. 1.点击鼠标右 ...
Python批量Excel文件数据导入SQLite数据库的优化方案
说明:1)需要安装扩展库openpyxl:2)随着数据库的增大,导入速度可能会有所下降:3)本文只考虑Python代码优化,没有涉及数据库的优化:4)本文要点在于使用executemany实现批量数据 ...

java代码实现excel文件数据导入

java代码实现excel文件数据导入相关推荐

最新文章

热门文章