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;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;

import com.alibaba.excel.ExcelReader;
import com.alibaba.excel.ExcelWriter;
import com.alibaba.excel.metadata.Sheet;
import com.alibaba.excel.support.ExcelTypeEnum;

/**
 * 读取Excel
 * 
 * @author Tele
 *
 */

public class Demo {

    /**
     * 读取excel并插入mysql中 sheet第一个参数为sheetNo代表sheet的编号,第二个参数表示从第几行开始读,最小是1, new
     * Sheet(1,0,Student.class)发现无输出结果
     * 
     * @throws FileNotFoundException
     */
    @SuppressWarnings("deprecation")
    @Test
    public void readExcel() throws FileNotFoundException {
        InputStream inputStream = new FileInputStream("d:/excelTest/test.xlsx");
        try {
            // 解析每行结果在listener中处理
            ExcelListener listener = new ExcelListener();

            ExcelReader excelReader = new ExcelReader(inputStream, ExcelTypeEnum.XLSX, null, listener);
            excelReader.read(new Sheet(1, 1, Student.class));
        } catch (Exception e) {

        } finally {
            try {
                inputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 查询测试
     */
    @Test
    public void queryByGroup() {
        QueryRunner runner = new QueryRunner(JdbcUtils.getDS());
        String sql = "SELECT * from student group by teacher,id";
        try {
            List<Student> query = runner.query(sql, new BeanListHandler<Student>(Student.class));
            for (Student student : query) {
                System.out.println(student.getName() + "----" + student.getTeacher());
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 将查询结果写出到excel中 在写excel的过程中,含有模型的写入,对于sheet的第二个参数是忽略的,全部从左侧第一行进行读写
     */
    @Test
    public void writeExcel() {
        try {
            OutputStream os = new FileOutputStream(new File("d:/excelTest/new.xlsx"));
            ExcelWriter writer = new ExcelWriter(os, ExcelTypeEnum.XLSX, true);

            // 2代表sheetNo,不可以重复,如果两个sheet的sheetNo相同则输出时只会有一个sheet
            Sheet sheet1 = new Sheet(1, 5, Student.class);
            sheet1.setSheetName("第一个sheet");

            Sheet sheet2 = new Sheet(2, 1, Student.class);
            sheet2.setSheetName("第二个sheet");

            QueryRunner runner = new QueryRunner(JdbcUtils.getDS());
            String sql = "SELECT * from student group by teacher,id";

            List<Student> result = runner.query(sql, new BeanListHandler<Student>(Student.class));
            writer.write(result, sheet1);
            // writer.write(result,sheet2);

            writer.finish();
            System.out.println("数据已写出");
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

}