java处理Excel文档

摘要

对Excel文件的读取操作,读完数据,直接插入到数据库中。

package cn.ccb.odsbsx.common.util;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import org.apache.poi.hssf.usermodel.HSSFCell;
import org.apache.poi.hssf.usermodel.HSSFDateUtil;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
public class ExcelReader {
       
    // 创建文件输入流
    private BufferedReader reader = null;
    // 文件类型
    private String filetype;
    // 文件二进制输入流
    private InputStream is = null;
    // 当前的Sheet
    private int currSheet;
    // 当前位置
    private int currPosition;
    // Sheet数量
    private int numOfSheets;
    // HSSFWorkbook
    HSSFWorkbook workbook = null;
    // 设置Cell之间以空格分割
    private static String EXCEL_LINE_DELIMITER = " ";
    // 设置最大列数
    private static int MAX_EXCEL_COLUMNS = 64;
    private static File[] getFiles(String path) {
        File file = new File(path);
        // get the folder list
        File[] array = file.listFiles();
        return array;
    }
    public static void main(String[] args) throws IOException {
        // TODO code application logic here
        File[] files = getFiles("D:\\data\\");
        for (int i = 0; i < files.length; i++) {
            String filePath = files[i].getPath();
            String fileName = files[i].getName();
            String newFileName = fileName.substring(0, fileName.indexOf('.'));
            String s = "";
            try {
                ExcelReader er = new ExcelReader(filePath);
                String line = er.readLine();
                while (line != null) {
                    s = s + line + "\r\n";
                    line = er.readLine();
                }
                er.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            // System.out.println(s);
            File newFile = new File("D:\\backupfile\\" + newFileName + ".txt");
            FileOutputStream fops = new FileOutputStream(newFile);
            fops.write(s.getBytes());
        }
    }
       
    // 构造函数创建一个ExcelReader
    public ExcelReader(String inputfile) throws IOException, Exception {
        // 判断参数是否为空或没有意义
        if (inputfile == null || inputfile.trim().equals("")) {
            throw new IOException("no input file specified");
        }
        // 取得文件名的后缀名赋值给filetype
        this.filetype = inputfile.substring(inputfile.lastIndexOf(".") + 1);
        // 设置开始行为0
        currPosition = 0;
        // 设置当前位置为0
        currSheet = 0;
        // 创建文件输入流
        is = new FileInputStream(inputfile);
        // 判断文件格式
        if (filetype.equalsIgnoreCase("xls")) {
            // 如果是Excel文件则创建HSSFWorkbook读取
            workbook = new HSSFWorkbook(is);
            // 设置Sheet数
            numOfSheets = workbook.getNumberOfSheets();
        } else {
            throw new Exception("File Type Not Supported");
        }
    }
    // 函数readLine读取文件的一行
    public String readLine() throws IOException {
        // 如果是XLS文件则通过POI提供的API读取文件
        if (filetype.equalsIgnoreCase("xls")) {
            // 根据currSheet值获得当前的sheet
            HSSFSheet sheet = workbook.getSheetAt(currSheet);
            // 判断当前行是否到但前Sheet的结尾
            // System.out.println(sheet.getLastRowNum());
            if (currPosition > sheet.getLastRowNum()) {
                // 当前行位置清零
                currPosition = 0;
                // 判断是否还有Sheet
                if (currSheet != numOfSheets - 1) {
                    currSheet++;
                    // 得到下一张Sheet
                    sheet = workbook.getSheetAt(currSheet);
                } else {
                    return null;
                }
            }
            // 获取当前行数
            int row = currPosition;
            currPosition++;
            // 读取当前行数据
            return getLine(sheet, row);
        }
        return null;
    }
    // 函数getLine返回Sheet的一行数据
    private String getLine(HSSFSheet sheet, int row) {
        // 根据行数取得Sheet的一行
        HSSFRow rowline = sheet.getRow(row);
        // 创建字符创缓冲区
        StringBuffer buffer = new StringBuffer();
        // 获取当前行的列数
        int filledColumns;
        try {
            filledColumns = rowline.getLastCellNum();
        } catch (NullPointerException e) {
            return "";
        }
        HSSFCell cell = null;
        // 循环遍历所有列
        for (int i = 0; i < filledColumns; i++) {
            // 取得当前Cell
            cell = rowline.getCell((short) i);
            String cellvalue = null;
            if (cell != null) {
                // 判断当前Cell的Type
                switch (cell.getCellType()) {
                // 如果当前Cell的Type为NUMERIC
                case HSSFCell.CELL_TYPE_NUMERIC: {
                    // 判断当前的cell是否为Date
                    if (HSSFDateUtil.isCellDateFormatted(cell)) {
                        // 如果是Date类型则,取得该Cell的Date值
                        Date date = cell.getDateCellValue();
                        // 把Date转换成本地格式的字符串
                        cellvalue = cell.getDateCellValue().toString();
                    }
                    // 如果是纯数字
                    else {
                        // 取得当前Cell的数值
                        Integer num = new Integer((int) cell
                                .getNumericCellValue());
                        cellvalue = String.valueOf(num);
                    }
                    break;
                }
                    // 如果当前Cell的Type为STRIN
                case HSSFCell.CELL_TYPE_STRING:
                    // 取得当前的Cell字符串
                    cellvalue = cell.getRichStringCellValue().toString()
                            .replaceAll("'", "''");
                    break;
                // 默认的Cell值
                default:
                    cellvalue = "";
                }
            } else {
                cellvalue = "";
            }
            // 在每个字段之间插入分割符
            buffer.append(cellvalue).append(EXCEL_LINE_DELIMITER);
        }
        // 以字符串返回该行的数据
        return buffer.toString();
    }
    // close函数执行流的关闭操作
    public void close() {
        // 如果is不为空,则关闭InputSteam文件输入流
        if (is != null) {
            try {
                is.close();
            } catch (IOException e) {
                is = null;
            }
        }
        // 如果reader不为空则关闭BufferedReader文件输入流
        if (reader != null) {
            try {
                reader.close();
            } catch (IOException e) {
                reader = null;
            }
        }
    }
}


IT家园
IT家园

网友最新评论 (0)