easyexcel 讀寫demo

<dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>easyexcel</artifactId>
            <version>1.1.1</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.9</version>
        </dependency>

        <!-- jdbc -->
        <dependency>
            <groupId>commons-dbutils</groupId>
            <artifactId>commons-dbutils</artifactId>
            <version>1.7</version>
        </dependency>

        <dependency>
            <groupId>com.mchange</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.5.2</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.40</version>
        </dependency>

</dependencies>

工具類

package cn.tele.demo;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;

/** 
 *
 *@author Tele
 *
 */

public class JdbcUtils {
    private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
    
    
    public static Connection getConnection() throws SQLException {
        return dataSource.getConnection();
    }
    
    public static DataSource getDS() {
        return dataSource;
    }
    
    // 關閉數據庫連接
    public static void close(ResultSet rs, Statement stat, Connection conn) {
            try {
                if (rs != null)
                    rs.close();
                if (stat != null)
                    stat.close();
                if (conn != null)
                    conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            
     }
    
}

實體類(模型)

package cn.tele.demo;

import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.metadata.BaseRowModel;

/** 
 *
 *@author Tele
 *
 */

public class Student extends BaseRowModel{
    @ExcelProperty(value="學號",index=0)
    private Integer id;
    
    @ExcelProperty(value= {"姓名","name","xxx","xxx"},index=1)
    private String name;
    
    @ExcelProperty(value="指導老師",index=2)
    private String teacher;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getTeacher() {
        return teacher;
    }

    public void setTeacher(String teacher) {
        this.teacher = teacher;
    }

    @Override
    public String toString() {
        return "Student [id=" + id + ", name=" + name + ", teacher=" + teacher + "]";
    }
}

監聽器

package cn.tele.demo;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;

import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;

/** 
 *
 *@author Tele
 *
 */

public class ExcelListener extends AnalysisEventListener<Student>{

    //自定義用於暫時存儲data。
    //可以通過實例獲取該值
    private List<Student> datas = new ArrayList<Student>();
    
    //每解析一行調用一次invoke方法
    public void invoke(Student object, AnalysisContext context) {
        System.out.println("當前行："+context.getCurrentRowNum());
        System.out.println(object);
        datas.add(object);//數據存儲到list，供批量處理，或后續自己業務邏輯處理。
        doSomething(datas);//根據自己業務做處理
    }
    
    private void doSomething(List<Student> list) {
      
    }
    
    //解析結束后自動調用
    public void doAfterAllAnalysed(AnalysisContext context) {
       // datas.clear();//解析結束銷毀不用的資源
          //1、入庫調用接口
        QueryRunner runner = new  QueryRunner(JdbcUtils.getDS());
        String sql = "insert into student values(?,?,?)";
        for(Student student:datas) {
            try {
                runner.update(sql, new Object[] {student.getId(),student.getName(),student.getTeacher()});
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        System.out.println("數據更新完成");
        try {
            JdbcUtils.close(null,null,JdbcUtils.getConnection());
        } catch (SQLException e) {
            e.printStackTrace();
        }
        
    }
    public List<Student> getDatas() {
        return datas;
    }
    public void setDatas(List<Student> datas) {
        this.datas = datas;
    }

}

Demo

package cn.tele.demo;  2 
import java.io.File;  4 import java.io.FileInputStream;  5 import java.io.FileNotFoundException;  6 import java.io.FileOutputStream;  7 import java.io.IOException;  8 import java.io.InputStream;  9 import java.io.OutputStream;  10 import java.sql.SQLException;  11 import java.util.List;  12 
import org.apache.commons.dbutils.QueryRunner;  14 import org.apache.commons.dbutils.handlers.BeanHandler;  15 import org.apache.commons.dbutils.handlers.BeanListHandler;  16 import org.junit.Test;  17 
import com.alibaba.excel.ExcelReader;  19 import com.alibaba.excel.ExcelWriter;  20 import com.alibaba.excel.metadata.Sheet;  21 import com.alibaba.excel.support.ExcelTypeEnum;  22 
/**
 * 讀取Excel  25  *  26  * @author Tele  27  *  28  */

public class Demo {  31 
    /**
 * 讀取excel並插入mysql中 sheet第一個參數為sheetNo代表sheet的編號,第二個參數表示從第幾行開始讀,最小是1, new  34  * Sheet(1,0,Student.class)發現無輸出結果  35  *  36  * @throws FileNotFoundException  37      */
    @SuppressWarnings("deprecation")  39  @Test  40     public void readExcel() throws FileNotFoundException {  41         InputStream inputStream = new FileInputStream("d:/excelTest/test.xlsx");  42         try {  43             // 解析每行結果在listener中處理
            ExcelListener listener = new ExcelListener();  45 
            ExcelReader excelReader = new ExcelReader(inputStream, ExcelTypeEnum.XLSX, null, listener);  47             excelReader.read(new Sheet(1, 1, Student.class));  48         } catch (Exception e) {  49 
        } finally {  51             try {  52  inputStream.close();  53             } catch (IOException e) {  54  e.printStackTrace();  55  }  56  }  57  }  58 
    /**
 * 查詢測試  61      */
 @Test  63     public void queryByGroup() {  64         QueryRunner runner = new QueryRunner(JdbcUtils.getDS());  65         String sql = "SELECT * from student group by teacher,id";  66         try {  67             List<Student> query = runner.query(sql, new BeanListHandler<Student>(Student.class));  68             for (Student student : query) {  69                 System.out.println(student.getName() + "----" + student.getTeacher());  70  }  71 
        } catch (SQLException e) {  73  e.printStackTrace();  74  }  75  }  76 
    /**
 * 將查詢結果寫出到excel中 在寫excel的過程中,含有模型的寫入,對於sheet的第二個參數是忽略的,全部從左側第一行進行讀寫  79      */
 @Test  81     public void writeExcel() {  82         try {  83             OutputStream os = new FileOutputStream(new File("d:/excelTest/new.xlsx"));  84             ExcelWriter writer = new ExcelWriter(os, ExcelTypeEnum.XLSX, true);  85 
            // 2代表sheetNo,不可以重復,如果兩個sheet的sheetNo相同則輸出時只會有一個sheet
            Sheet sheet1 = new Sheet(1, 5, Student.class);  88             sheet1.setSheetName("第一個sheet");  89 
            Sheet sheet2 = new Sheet(2, 1, Student.class);  91             sheet2.setSheetName("第二個sheet");  92 
            QueryRunner runner = new QueryRunner(JdbcUtils.getDS());  94             String sql = "SELECT * from student group by teacher,id";  95 
            List<Student> result = runner.query(sql, new BeanListHandler<Student>(Student.class));  97  writer.write(result, sheet1);  98             // writer.write(result,sheet2);

 writer.finish(); 101             System.out.println("數據已寫出"); 102         } catch (FileNotFoundException e) { 103  e.printStackTrace(); 104         } catch (SQLException e) { 105  e.printStackTrace(); 106  } 107 
 } 109 
}