增加直接的Class类型导出

Author: MatrixSeven

ExcelReads.jar

@@ -10,6 +10,10 @@
 * 依赖POI，使用Maven构建
 
 ## 更新纪录
+### 更新2017/01/05
+* 修复据库查询的导出(Object)递归越栈问题
+* 增加新的xxx.Class定义类型导出，操作更新点
+* 导出注解支持
 
 ### 更新2017/01/04
 * 修复据库查询的导出(Map)空指针&下标越界问题
@@ -56,22 +60,45 @@
 |bar    | bar   | bar   |
 |baz    | baz   | baz   |
 
+
+## 数据库导出自定义Bean类型写法（xxx.Class类型）
+```java
+ExcelFactory.saveExcel(
+        UNPOOLED_DATA_SOURCE.getConnection().
+                prepareStatement("select * FROM  users_info limit 1000").executeQuery(),
+        "\u5317\u4eac__Excel.xlsx",
+         AS.class)
+    .FilterCol(() -> new String[]{"updatetime"})
+    .Filter((AS o) ->o.getA().length() > 3)
+    .Save();
+```
+## 数据库导出自定义Bean类型写法（自己实现包装）
+```java
+ExcelFactory.saveExcel(
+        UNPOOLED_DATA_SOURCE.getConnection().
+                prepareStatement("select * FROM  users_info limit 1000").executeQuery(),
+        "\u5317\u4eac__Excel.xlsx",
+            res -> {
+                AS a = new AS();
+                a.setA(res.getString("name"));
+                return a;
+            })
+    .FilterCol(() -> new String[]{"updatetime"})
+    .Filter((AS o) ->o.getA().length() > 3)
+    .Save();
+```
 ##  数据库直接导出到Excel例子
 ```java
- UnpooledDataSource UNPOOLED_DATA_SOURCE = new UnpooledDataSource("com.mysql.jdbc.Driver",
-                "jdbc:mysql://127.0.0.1:3306/zhihuspider",
-                "xxxx", "xxxxx"
-        );
-        ExcelFactory.saveExcel(
-                UNPOOLED_DATA_SOURCE.getConnection().
-                        prepareStatement("select * FROM  users_info limit 10000").
-                        executeQuery(), "知乎导出Excel.xlsx")
-                //过滤字段
-           .FilterCol(() -> new String[]{"updatetime"})
-                //过滤数据条件
-           .Filter((HashMap<String, String> o) ->
-                    o.get("address").equals("\u5317\u4eac"))
-           .Save();
+ExcelFactory.saveExcel(
+        UNPOOLED_DATA_SOURCE.getConnection().
+                prepareStatement("select * FROM  users_info limit 10000").
+                executeQuery(), "知乎导出Excel.xlsx")
+        //过滤字段
+   .FilterCol(() -> new String[]{"updatetime"})
+        //过滤数据条件
+   .Filter((HashMap<String, String> o) ->
+            o.get("address").equals("\u5317\u4eac"))
+   .Save();
 
 ```
 

README.md

@@ -57,5 +57,8 @@ public static SaveExcel saveExcel(ResultSet resultSet, String FilePath) throws E
     public static SaveExcel saveExcel(ResultSet resultSet, String FilePath, PackageDataInterface packageDataInterface) throws Exception {
         return new ResExprotDBObj(resultSet,FilePath,packageDataInterface);
     }
+    public static SaveExcel saveExcel(ResultSet resultSet, String FilePath, Class type) throws Exception {
+        return new ResExprotDBObj(resultSet,FilePath,type);
+    }
 
 }

src/main/java/seven/ExcelFactory.java

@@ -24,5 +24,4 @@
  */
 @FunctionalInterface
 public interface PackageDataInterface<T> {
-    T PackageDataProcess(ResultSet res);
-}
+    T PackageDataProcess(ResultSet res) throws Exception;}

src/main/java/seven/callBack/PackageDataInterface.java

@@ -16,7 +16,10 @@
 //=======================================================
 
 import seven.callBack.PackageDataInterface;
+import seven.savewapper.anno.ExcelAnno;
+import seven.util.ExcelTool;
 
+import java.lang.reflect.Field;
 import java.sql.ResultSet;
 import java.util.ArrayList;
 
@@ -25,12 +28,14 @@
  * [Github]https://github.com/MatrixSeven
  * Created by seven on 2017/1/1.
  */
-public class ResExprotDBObj extends ResExprotObj{
+public class ResExprotDBObj extends ResExprotObj {
     protected PackageDataInterface dataInterface;
-//    protected  T type;
+    protected Class clazz = null;
+
+    //    protected  T type;
     public ResExprotDBObj(ResultSet resultSet, String path, PackageDataInterface dataInterface) {
         super(resultSet, path);
-        this.dataInterface=dataInterface;
+        this.dataInterface = dataInterface;
 //        Type sType = getClass().getGenericSuperclass();
 //        Type[] generics = ((ParameterizedType) sType).getActualTypeArguments();
 //        Class<T> mTClass = (Class<T>) (generics[0]);
@@ -42,17 +47,49 @@ public ResExprotDBObj(ResultSet resultSet, String path, PackageDataInterface dat
 
     }
 
+    public ResExprotDBObj(ResultSet resultSet, String path, Class type) {
+        super(resultSet, path);
+        this.clazz = type;
+    }
+
     public ResExprotDBObj CreateList() throws Exception {
-        this.list=new ArrayList<>();
-//        T o= (T) type.getClass().newInstance();
-        while (resultSet.next()){
+        this.list = new ArrayList<>();
+//        Object o;
+//        Method[] methods= dataInterface.getClass().getDeclaredMethods();
+//        Class<?>[] type= methods[0].getParameterTypes();
+//        Class<?> clazz= type[type.length-1].getClass();
+        if (clazz != null) {
+            Field[] fields= ExcelTool.GetFilesDeep(clazz);
+            int len =fields.length;
+            String name[]=new String[len];
+            ExcelAnno anno=null;
+            for (int i = 0; i < len; i++) {
+                fields[i].setAccessible(true);
+                if((anno=fields[i].getAnnotation(ExcelAnno.class))!=null){
+                    name[i]=anno.value();
+                    continue;
+                }
+                name[i]=fields[i].getName();
+            }
+            Object o=null;
+            while (resultSet.next()) {
+                o=clazz.newInstance();
+                for (int i = 0; i < len; i++) {
+                    fields[i].set(o, resultSet.getString(name[i]));
+                }
+                list.add(o);
+            }
+            return this;
+        }
+        while (resultSet.next()) {
             list.add(dataInterface.PackageDataProcess(resultSet));
         }
         return this;
     }
 
     @Override
     public void Save() throws Exception {
-        CreateList().Save();
+        this.CreateList();
+        super.Save();
     }
 }

src/main/java/seven/savewapper/wapperRef/sysWppers/ResExprotDBObj.java

@@ -82,7 +82,7 @@ public static class Config {
 		Boolean is_loop_sheet = false;
 		Boolean error_log = true;
 		Integer Voc_size = 10000;
-		String Require[] = null;
+		String Require[] = new String[]{};
 		Integer start_sheet = 0;
 		Integer end_sheet = null;