Apache POI导入数据到数据库

1. Apache POI简介
2. 在Maven工程中导入依赖
3. 在页面添加上传文件组件，配置文件
4. 使用工具类将上传文件的数据导入到数据库

Apache POI简介

• Apache POI是用Java编写的免费开源的跨平台的Java API，Apache POI提供API给Java程序对Microsoft office格式档案读和写的功能，其中使用最多的就是使用POI操作Excel文件。
• POI结构：

HSSF － 提供读写Microsoft Excel XLS格式档案的功能
XSSF － 提供读写Microsoft Excel OOXML XLSX格式档案的功能
HWPF － 提供读写Microsoft Word DOC格式档案的功能
HSLF － 提供读写Microsoft PowerPoint格式档案的功能
HDGF － 提供读Microsoft Visio格式档案的功能
HPBF － 提供读Microsoft Publisher格式档案的功能
HSMF － 提供读Microsoft Outlook格式档案的功能

在Maven工程中导入依赖

<dependency>
	<groupId>org.apache.poi</groupId>
	<artifactId>poi</artifactId>
	<version>3.14</version>
</dependency>
<dependency>
	<groupId>org.apache.poi</groupId>
	<artifactId>poi-ooxml</artifactId>
	<version>3.14</version>
</dependency>

在页面添加上传文件组件，配置文件

• 在页面添加文件上传的组件，我这里使用的是Element的组件：

<div class="boxMain">
       <el-button style="margin-bottom: 20px;margin-right: 20px" type="primary" @click="downloadTemplate()">模板下载</el-button>
        <el-upload action="/ordersetting/upload"
                   name="excelFile"
                   :show-file-list="false"
                   :on-success="handleSuccess"
                   :before-upload="beforeUpload">
            <el-button type="primary">上传文件</el-button>
        </el-upload>
</div>

• 在上传文件之前得配置一个类到spring中，来指定文件的大小和字符编码，不然上传会报错或乱码。

<!--文件上传组件-->
    <bean id="multipartResolver"
          class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
        <property name="maxUploadSize" value="104857600" />
        <property name="maxInMemorySize" value="4096" />
        <property name="defaultEncoding" value="UTF-8"/>
    </bean>

• 组件绑定的事件

//上传之前进行文件格式校验
            beforeUpload(file){
    
                const isXLS = file.type === 'application/vnd.ms-excel';
                if(isXLS){
    
                    return true;
                }
                const isXLSX = file.type === 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet';
                if (isXLSX) {
    
                    return true;
                }
                this.$message.error('上传文件只能是xls或者xlsx格式!');
                return false;
            },
            //上传成功提示
            handleSuccess(response, file) {
    
                if(response.flag){
    
                    this.$message({
    
                        message: response.message,
                        type: 'success'
                    });
                }else{
    
                    this.$message.error(response.message);
                }
                // console.log(response, file, fileList);

            },
            //下载模板文件
            downloadTemplate(){
    
                window.location.href="../../template/ordersetting_template.xlsx";
            },

使用工具类将上传文件的数据导入到数据库

上传文件中的内容：

• 使用POIUtils工具类来将上传过来的文件解析：

 @RequestMapping("/upload")
    public Result upload(@RequestParam("excelFile") MultipartFile multipartFile) {
    
        try {
    
            List<String[]> excel = POIUtils.readExcel(multipartFile);
            List<OrderSetting> list = new ArrayList<>();
            //遍历解析后的集合，集合中的每个strings就是代表Excel中的一行数据。
            for (String[] strings : excel) {
    
                OrderSetting orderSetting = new OrderSetting();
                //将strings数组中的值取出来和实体类的属性一一对应，就可以保存到数据库中
                orderSetting.setOrderDate(new Date(strings[0]));
                orderSetting.setNumber(Integer.valueOf(strings[1]));
                orderSetting.setReservations(Integer.valueOf(strings[2]));
                list.add(orderSetting);
            }
            //将保存到集合中的数据保存到数据库中
            orderSettingService.addOrderSettings(list);
            return new Result(true, MessageConstant.UPLOAD_SUCCESS);
        } catch (Exception e) {
    
            e.printStackTrace();
            return new Result(false, "文件上传失败");
        }
    }

• POIUtils工具类

package com.ysdn.utils;

import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.web.multipart.MultipartFile;

public class POIUtils {
    
    private final static String xls = "xls";
    private final static String xlsx = "xlsx";
    private final static String DATE_FORMAT = "yyyy/MM/dd";
    /**
     * 读入excel文件，解析后返回
     * @param file
     * @throws IOException
     */
    public static List<String[]> readExcel(MultipartFile file) throws IOException {
    
        //检查文件
        checkFile(file);
        //获得Workbook工作薄对象
        Workbook workbook = getWorkBook(file);
        //创建返回对象，把每行中的值作为一个数组，所有行作为一个集合返回
        List<String[]> list = new ArrayList<String[]>();
        if(workbook != null){
    
            for(int sheetNum = 0;sheetNum < workbook.getNumberOfSheets();sheetNum++){
    
                //获得当前sheet工作表
                Sheet sheet = workbook.getSheetAt(sheetNum);
                if(sheet == null){
    
                    continue;
                }
                //获得当前sheet的开始行
                int firstRowNum  = sheet.getFirstRowNum();
                //获得当前sheet的结束行
                int lastRowNum = sheet.getLastRowNum();
                //循环除了第一行的所有行
                for(int rowNum = firstRowNum+1;rowNum <= lastRowNum;rowNum++){
    
                    //获得当前行
                    Row row = sheet.getRow(rowNum);
                    if(row == null){
    
                        continue;
                    }
                    //获得当前行的开始列
                    int firstCellNum = row.getFirstCellNum();
                    //获得当前行的列数
                    int lastCellNum = row.getPhysicalNumberOfCells();
                    String[] cells = new String[row.getPhysicalNumberOfCells()];
                    //循环当前行
                    for(int cellNum = firstCellNum; cellNum < lastCellNum;cellNum++){
    
                        Cell cell = row.getCell(cellNum);
                        cells[cellNum] = getCellValue(cell);
                    }
                    list.add(cells);
                }
            }
            workbook.close();
        }
        return list;
    }

    //校验文件是否合法
    public static void checkFile(MultipartFile file) throws IOException{
    
        //判断文件是否存在
        if(null == file){
    
            throw new FileNotFoundException("文件不存在！");
        }
        //获得文件名
        String fileName = file.getOriginalFilename();
        //判断文件是否是excel文件
        if(!fileName.endsWith(xls) && !fileName.endsWith(xlsx)){
    
            throw new IOException(fileName + "不是excel文件");
        }
    }
    public static Workbook getWorkBook(MultipartFile file) {
    
        //获得文件名
        String fileName = file.getOriginalFilename();
        //创建Workbook工作薄对象，表示整个excel
        Workbook workbook = null;
        try {
    
            //获取excel文件的io流
            InputStream is = file.getInputStream();
            //根据文件后缀名不同(xls和xlsx)获得不同的Workbook实现类对象
            if(fileName.endsWith(xls)){
    
                //2003
                workbook = new HSSFWorkbook(is);
            }else if(fileName.endsWith(xlsx)){
    
                //2007
                workbook = new XSSFWorkbook(is);
            }
        } catch (IOException e) {
    
            e.printStackTrace();
        }
        return workbook;
    }
    public static String getCellValue(Cell cell){
    
        String cellValue = "";
        if(cell == null){
    
            return cellValue;
        }
        //如果当前单元格内容为日期类型，需要特殊处理
        String dataFormatString = cell.getCellStyle().getDataFormatString();
        if(dataFormatString.equals("m/d/yy")){
    
            cellValue = new SimpleDateFormat(DATE_FORMAT).format(cell.getDateCellValue());
            return cellValue;
        }
        //把数字当成String来读，避免出现1读成1.0的情况
        if(cell.getCellType() == Cell.CELL_TYPE_NUMERIC){
    
            cell.setCellType(Cell.CELL_TYPE_STRING);
        }
        //判断数据的类型
        switch (cell.getCellType()){
    
            case Cell.CELL_TYPE_NUMERIC: //数字
                cellValue = String.valueOf(cell.getNumericCellValue());
                break;
            case Cell.CELL_TYPE_STRING: //字符串
                cellValue = String.valueOf(cell.getStringCellValue());
                break;
            case Cell.CELL_TYPE_BOOLEAN: //Boolean
                cellValue = String.valueOf(cell.getBooleanCellValue());
                break;
            case Cell.CELL_TYPE_FORMULA: //公式
                cellValue = String.valueOf(cell.getCellFormula());
                break;
            case Cell.CELL_TYPE_BLANK: //空值
                cellValue = "";
                break;
            case Cell.CELL_TYPE_ERROR: //故障
                cellValue = "非法字符";
                break;
            default:
                cellValue = "未知类型";
                break;
        }
        return cellValue;
    }
}

• 上传到数据库之后的结果：
  
  以上就是本次分享的全部内容了，如果有不恰当的地方，欢迎指正。