已正常发布线上，暂无bug

之前由于工作需要，连接多台远程数据库，需要jdbc转查询切换，为了通用性，少改动不必要的复杂sql代码，就写了通用转换的类。
参数说明：
    1.传返回结果集对应的对象实体类，
    2.sql，
    3.map参数
    
根据3个条件来一步调用，返回list<map>或list<Object>对象的结果集封装。这样就不需要改动业务逻辑与前端展示。



package aero.sita.tm.utils;

import aero.sita.tm.object.FlaPojo;
import aero.sita.tm.tool.DESEncryptTools;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import net.sf.json.JSONArray;

import java.io.IOException;
import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.sql.*;
import java.util.*;
import java.util.Date;

public class FtpPool {
    private static ComboPooledDataSource dataSource;
    private static Connection conn = null;
    private static PreparedStatement st = null;
    private static ResultSet rs =null;

    public static void main(String[] args) {
        HashMap<String,Object> map=new HashMap<String,Object>();
        map.put("date","2019-08-21");
        map.put("seachaIrport","PVG");
        map.put("page",0);
        map.put("pageSize",1);
        List<FlaPojo> dataList= jdbcFtp(
                FlaPojo.class,
                "  SELECT t2.* FROM (SELECT t1.*, ROWNUM rownum_ FROM ( select otf.of_no as flight_no_disp,otf.of_td as pdate,sum(tr.pax_cnt) as cki_pax_count,sum(suc_pax_cnt) as prl_count,(ROUND(decode(sum(tr.pax_cnt),0,0,sum(suc_pax_cnt)/sum(tr.pax_cnt)),2)*100)||'%' as cki_count,sum(tr.pax_cnt)-sum(suc_pax_cnt) as cki_cancel_count from opmart_master.TF_DM_TFP tr left join opmart_master.TF_DM_ITF itf on itf.id=tr.if_id  left join opmart_master.TF_DM_OTF otf on otf.id=tr.of_id  where    otf.of_std >=       to_date(:date||' 02:00:00', 'yyyy-mm-dd hh24:mi:ss')   AND otf.of_std <       to_date(:date||' 02:00:00', 'yyyy-mm-dd hh24:mi:ss')+1  AND otf.of_airline in ('MU','FM')  and otf.airport=:seachaIrport group by otf.of_no,otf.of_td   ) t1) t2 WHERE  rownum_> :page and ROWNUM <= :pageSize ",
                map );
        System.out.println(JSONArray.fromObject(dataList));

    }

    /**
     * jdbc查询
     * @param dataSql
     * @param map
     * @param clazz
     * @return
     */
    public static List jdbcFtp(Class clazz,String dataSql,Map map){
        try{
            // 注册 JDBC 驱动
            Class.forName(getValue("user_operct.dbDriver", "oracle.jdbc.driver.OracleDriver"));
            conn = DriverManager.getConnection(
                    new String("ftp.url"),
                    new String("ftp.username"),
                    new String("ftp.password");
            // 执行查询
            st = conn.prepareStatement(setQueryParam(dataSql,map));
            rs=st.executeQuery();
            return selectAll(rs,clazz);
        }catch(Exception e){
            e.printStackTrace();
        }  finally{
            close(st,conn, rs);
        }
        return null;
    }

    /**
     * rs结果集转list<Map>
     * @param rs
     * @return
     */
    public static List<Map<String, Object>> selectAll(ResultSet rs) {
        List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
        try {
            // 获取结果集结构（元素据）
            ResultSetMetaData rmd = rs.getMetaData();
            int columnCount = rmd.getColumnCount();
            while (rs.next()) {
                // 保存记录中的每个<字段名-字段值>
                Map<String, Object> rowData = new HashMap<String, Object>();
                for (int i = 1; i <= columnCount; ++i) {
                    // <字段名-字段值>
                    rowData.put(rmd.getColumnName(i), rs.getObject(i));
                    //System.out.println(rmd.getColumnName(i)+":"+ rs.getObject(i));
                }
                list.add(rowData);
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return list;
    }

    /**
     * rs结果集转对象
     * @param rs
     * @return
     */
    public static List selectAll(ResultSet rs, Class clazz) throws SQLException, IllegalAccessException, InstantiationException {
        //结果集的元素对象
        ResultSetMetaData rsmd = rs.getMetaData();
        //获取结果集的元素个数
        int colCount = rsmd.getColumnCount();
        //返回结果的列表集合
        List list = new ArrayList();
        //业务对象的属性数组
        Field[] fields = clazz.getDeclaredFields();
        while(rs.next()){//对每一条记录进行操作
            Object obj = clazz.newInstance();//构造业务对象实体
            //将每一个字段取出进行赋值
            for(int i = 1;i<=colCount;i++){
                Object value = rs.getObject(i);
                //寻找该列对应的对象属性
                for(int j=0;j<fields.length;j++){
                    Field f = fields[j];
                    //如果匹配进行赋值,并替换预编译占位符
                    if(f.getName().equalsIgnoreCase(getName(rsmd.getColumnName(i),rsmd.getColumnName(i)))){
                        boolean flag = f.isAccessible();
                        f.setAccessible(true);
                        try{
                            f.set(obj,value);
                        }catch (Exception e){
                            try{
                                BigDecimal b= (BigDecimal) value;
                                f.set(obj,b.longValue());
                            }catch (Exception ex){
                                BigDecimal b= (BigDecimal) value;
                                f.set(obj,b.intValue());
                            }
                        }
                        f.setAccessible(flag);
                    }
                }
            }
            list.add(obj);
        }
        return list;
    }

    /**
     * 去下划线后字母大写
     * @param name
     * @param anotherName
     * @return 例子：getName("of_terminal","of_terminal")
     */
    private static String getName(String name,String  anotherName) {
        name=anotherName;
        //如果最后一个是_ 不做转换
        if(name.indexOf("_")>0&&name.length()!=name.indexOf("_")+1){
            int lengthPlace=name.indexOf("_");
            name=name.replaceFirst("_", "");
            String s=name.substring(lengthPlace, lengthPlace+1);
            s=s.toUpperCase();
            anotherName=name.substring(0,lengthPlace)+s+name.substring(lengthPlace+1);
        }else{
            return  anotherName;
        }
        return getName(name,anotherName);
    }

    /**
     * 预编译
     * @param sql
     * @param params
     */
    public static String setQueryParam( String sql,Map<String, ?> params) {
        if (null != params) {
            Iterator i$ = params.keySet().iterator();
            while(i$.hasNext()) {
                String key = (String)i$.next();
                if(params.get(key) instanceof Integer){
                    sql=sql.replaceAll(":"+key+"+[\\s]", params.get(key).toString()+" ");
                }else if((params.get(key) instanceof String)){
                    sql=sql.replaceAll(":"+key, "'"+params.get(key).toString()+"'");
                }else if((params.get(key) instanceof Double)){
                    sql=sql.replaceAll(":"+key, "'"+params.get(key).toString()+"'");
                }else if((params.get(key) instanceof Date)){
                    sql=sql.replaceAll(":"+key, "'"+params.get(key).toString()+"'");
                }
            }
        }
        return sql;
    }

    /**
     * 关闭资源
     * @param st
     * @param conn
     * @param rs
     */
    public static void close(PreparedStatement st,Connection conn,ResultSet rs){
        // 关闭资源
        try{
            if(st!=null) st.close();
        }catch(SQLException se2){
        }// 什么都不做
        try{
            if(conn!=null) conn.close();
        }catch(SQLException se){
            se.printStackTrace();
        }
        try{
            if(rs!=null) conn.close();
        }catch(SQLException se){
            se.printStackTrace();
        }
    }

    public static String getValue(String s, String defaultValue)
            throws IOException {
        return new DbPropertiesUtil().getValue(s, defaultValue);
    }
}