將CachedRowSet中的數據轉儲到對象中

雖然還有很多bug，但湊合能用，就是將CachedRowSet中的數據轉換成對象或List。省去了繁瑣難看的一系列get/set方法。

先說調用：

注：

cachedRowSet是查詢的結果集

Student是對應於Student表的實體類

1. 從數據庫Student表中查詢出多行數據，要將其存入ArrayList<Student>中： 

ArrayList<Student> student = Convert.RStoList(cachedRowSet , Student.class ) ;

2. 從數據庫Student表中查詢出單行數據，並將其存入Student對象中：

cachedRowSet.next() ;

Student student = Convert.RStoObject(cachedRowSet , Student.class) ;

 

package util;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;

import javax.sql.rowset.CachedRowSet;

import com.sun.rowset.CachedRowSetImpl;

/**
 * 
 * @author caiyao 
 *
 * @function 類型轉換
 * 
 * @version 2.0 
 * 
 * @modifyTime : 2015-9-1
 */
public class Convert {
    /**
     * 將CachedRowSetImpl中的多條記錄存儲進List中
     * @param cachedRS CachedRowSetImpl結果集
     * @param c List中元素類型
     * @return ArrayList對象
     * @throws SQLException  cachedRS.next()導致的異常
     * @throws RuntimeException 
     * @throws InvocationTargetException 
     * @throws ClassNotFoundException 
     * @throws NoSuchMethodException 
     * @throws IllegalAccessException 
     * @throws InstantiationException 
     */
    public static <T> ArrayList<T> RStoList(CachedRowSet cachedRS , Class<T> c)
            throws SQLException, InstantiationException, IllegalAccessException, 
            NoSuchMethodException, ClassNotFoundException, InvocationTargetException, 
            RuntimeException{
        if(!cachedRS.next()){
            return null ;
        }
        cachedRS.previous() ;// 由於上面執行了next，所有這里需要將指針移動到上一行
        ArrayList<T> store = new ArrayList<T>() ;
        while(cachedRS.next()){
            T object = RStoObject(cachedRS , c ) ;
            store.add(object) ;
        }
        return store ;
    }
    
    /**
     * 將ResultSet類型的結果集轉換成Object類型的對象
     *  注： 
     * 1. 該方法只能轉換只有一條結果的CachedRowSet。 
     * 2.rs結果集中得到的值xxx，在類中要有相應的setXxx方法
     * 
     * @param rs
     *            結果集
     * @param c
     *            Class類型的值，可以通過Class.forName(類名)獲取，要確定該類有無參的構造方法，
     *            否則會出現InstantiationException異常
     * @return 轉換之后的對象
     * @throws InstantiationException
     * @throws IllegalAccessException
     * @throws SQLException
     * @throws RuntimeException
     * @throws NoSuchMethodException
     * @throws ClassNotFoundException
     * @throws InvocationTargetException
     *             注： 
     *                1. 該方法只能轉換只有一條結果的CachedRowSet。 
     *                2.rs結果集中得到的值xxx，在類中要有相應的setXxx方法
     *             3. 在單獨調用這個方法的時候（不是通過RStoList的間接調用）。
     *             需要在傳遞CachedRowSet這個參數之前調用rs的next()方法。否則會出現指針無效的錯誤
     *             4. 使用該方法將結果集中的數據轉儲到對象中時，要對象中屬性get/set方法要和數據庫中
     *             列名相對應。例如數據庫列名為user_name,那么對象的方法就應該是setUserName/getUserName
     */
    public static <T> T RStoObject(CachedRowSet rs , Class<T> c)
            throws InstantiationException, IllegalAccessException, 
            SQLException, NoSuchMethodException, RuntimeException, 
            ClassNotFoundException, InvocationTargetException{
         // 要確定該類有無參的構造方法
        T instance = c.newInstance() ;
        // 獲取元數據，以便得到列的信息
        ResultSetMetaData metaData = rs.getMetaData() ;
        // 獲取列數
        int columnNum = metaData.getColumnCount() ;
        
        for(int i = 1 ; i <= columnNum ; i ++ ){
            String columnName = getColumnName(metaData.getColumnName(i)) ;
            Class<?> columnClassType = SQLTypeToClass(metaData.getColumnType(i)) ;
            columnClassType = getColumnClassType(columnName , columnClassType , c ) ;
            String columnTypeName = columnTypeToGetter(metaData.getColumnTypeName(i)) ;
            // 反射獲取對象的set方法
            Method objectMethod = c.getMethod(
                            "set"+columnName.substring(0,1).toUpperCase()+columnName.substring(1), 
                            columnClassType
                            ) ;
            // 反射獲取CachedRowSetImpl的get方法
            Method RSGetter = CachedRowSetImpl.class.getMethod(
                            "get"+columnTypeName.substring(0,1).toUpperCase()+columnTypeName.substring(1), 
                             int.class) ;
            // 執行RS的get方法獲取屬性值
            Object value = RSGetter.invoke(rs,i) ;
            // 執行Object的set方法為對象賦值
            objectMethod.invoke(instance, value) ;
        }
        // 返回對象
        return instance ;
    }
    
    /**
     * 判斷類c是否存在set'columnName'('columnClassType' x)方法。
     * 如果不存在，再尋找是否存在set'columnName'('cloumnClassType的父類' x)方法，如果存在返回cloumnClassType的父類。
     * 如果存在，則返回cloumnClassType原值。
     * @param columnName 類c的屬性名
     * @param columnClassType 類c set方法的參數類型
     * @param c 類c
     * @return set方法的屬性類型
     */
    private static Class<?> getColumnClassType(String columnName , Class<?> columnClassType , Class<?> c ){
        /*
         * 寫該方法的原因：
         * int/double 在oracle數據庫中都是用Number表示。
         * 所以從數據庫中查詢出來的數據無法辨別是int還是double， 也就導致無法正確通過反射獲取對象的set方法，因為方法參數無法確定。
         * 例如： Student表中有兩個屬性 int a , double b ;
         * 存入數據庫中就是都是Number，從數據庫中取出也都是Number。
         * 如果將Number對應於java的int，那么SQLTypeToClass（）方法返回的就是int.class,
         * 無論從數據庫中查詢出來的是int還是double，因此，下面獲取set方法就只能獲取以int為參數的方法。 所以就無法獲取到double
         * b 的set方法。 反射獲取方法是確定的，不會在找不到int參數方法時轉而去找double參數方法。
         * 該方法為了在找不到int為參數的方法時，繼而找以double類型參數的方法。
         * 或者以后會添加找不到子類類型為參數的方法繼而找以其父類為參數的方法。
         */
            try {
                c.getMethod("set"+columnName.substring(0,1).toUpperCase()+columnName.substring(1), columnClassType).getName() ;
            } catch (NoSuchMethodException e) {
                return getSuperColumnClassType(columnClassType) ;
            } catch (SecurityException e) {}
            return columnClassType ;
    }
    /**
     * 獲取columnClassType的父類
     * @param columnClassType 
     * @return
     */
    private static Class<?> getSuperColumnClassType(Class<?> columnClassType){
        if(columnClassType.equals(int.class)){
            return double.class ;
        }else{
            return columnClassType.getSuperclass() ;
        }
        
    }
    /**
     * 獲取與數據庫列名對應的屬性名。
     * 例如：
     *         數據庫列名                屬性名
     *         user_name/username        userName
     * @param rawColumnName 數據庫列名
     * @return 與數據庫列名對應的對象屬性名
     */
    public static String getColumnName(String rawColumnName ){
        if(rawColumnName.matches(".*_.*")){
            String[] words = rawColumnName.split("_") ;
            String firstWord = words[0].toLowerCase() ;
            String lastWord = words[1].substring(0, 1).toUpperCase() + words[1].substring(1).toLowerCase() ;
            String attributeName = firstWord + lastWord ;
            return attributeName ;
        }else{
            /*
             * 如果數據庫列名不包含下划線，有可能只有一個單詞，那么將首字母大寫然后直接返回就行。
             * 如果不止一個單詞那就沒轍了： 怎樣讓第二個單詞首字母大寫？
             * 這里就暫時讓其直接返回吧 
             * TODO : 怎樣讓第二個單詞首字母大寫
             */
            return rawColumnName.substring(0,1).toUpperCase() + rawColumnName.substring(1).toLowerCase() ;
        }
    }
    public static String columnTypeToGetter(String columnType){
        /**
         * mysql數據庫中存儲字符串只有varchar，但是ResultSet接口中沒有定義getVarchar（）方法所以將varchar轉換成String即可，
         */
        if(columnType.equals("VARCHAR")){
            return "String" ;
        }
        if(columnType.equals("NVARCHAR2")){
            return "String" ;
        }
        // oracle數據庫NUMBER字段類型對應Java中int
        if(columnType.equals("NUMBER")){
            return "int" ;
        }
        if(columnType.toLowerCase().equals("timestamp")){
            return "object" ;
        }
        return columnType.toLowerCase() ;
    }
    /**
     * 將封裝后的原始類型名稱轉換成原始類型的class
     * @param columnType 封裝后的對象名稱例如"java.lang.Integer" , "java.lang.Float" , "java.lang.Double"
     * @return 原始類型class類型 例如int.class float.class double.class
     * @throws ClassNotFoundException 
     */
    public static Class<?> getColumnClassType(String columnType) throws ClassNotFoundException{
        /**
         * 數據庫中的int、float、double等原始列類型當通過getColumnClassName()方法獲取時，會將原始類型打包成其基礎類型封裝對象 
         * 例如 int --> Integer float --> Float double --> Double
         * 該方法是為了將獲取的基礎類型封裝類名轉換成原始類型的class
         */
        if(columnType.equals("java.lang.Integer")){
             return int.class ;
        }
        if(columnType.equals("java.lang.Float")){
            return float.class ;
        }
        if(columnType.equals("java.lang.Double")){
             return double.class ;
        }
        return Class.forName(columnType) ;
    }
    /**
     * 將java.sql.Types類型轉化成相應的Java中對應的Class
     * @param SQLType java.sql.Types類型
     * @return Class類型的實例例如 int.class
     */
    public static  Class<?> SQLTypeToClass(int SQLType){
        switch(SQLType){
        case java.sql.Types.ARRAY : return String.class ;
        
        case java.sql.Types.BIGINT : return int.class ;
        
        case java.sql.Types.BIT : return byte.class ;
        
        case java.sql.Types.BOOLEAN : return boolean.class ;
        
        case java.sql.Types.CHAR : return char.class ;
        
        case java.sql.Types.DOUBLE : return double.class ;
        
        case java.sql.Types.FLOAT : return float.class ;
        
        case java.sql.Types.INTEGER : return int.class ;
        
        case java.sql.Types.LONGNVARCHAR : return String.class ;
        
        case java.sql.Types.LONGVARCHAR : return String.class ;
        
        case java.sql.Types.NCHAR : return String.class ;
        
        case java.sql.Types.NVARCHAR :return String.class ;
        
        case java.sql.Types.VARCHAR : return String.class ;
        // 通過rs.getDate()獲取到的java.sql.Date能夠直接將其賦值到java.util.Date會進行自動轉換
        case java.sql.Types.DATE : return Date.class ;
        // oracle數據庫的Number字段類型對應NUMERIC類型，
        //但是在數據庫中整數和浮點數都是Number，
        //所以在應用中無法判斷從數據庫中取出的是整數還是浮點數.
        //處理方法是：在應用中都使用浮點數
        case java.sql.Types.NUMERIC : return int.class ;
        // 由於sun包中提供的CachedRowSetImpl類存在bug，當getTimestamp()字段時會出現類轉換異常。
        // 解決方案有：
        // 1. 換類。oracle驅動包oracle.jdbc.rowset.OracleCachedRowSet類（大概是這個名字）可以正確執行。
        // 2. 換oracle驅動版本。10.0以上，這個我沒有試過，有些人說可以。
        // 3. 如果使用sun提供的這個類，獲取Timestamp時使用getObject()。然后再轉換。
        // 因為考慮到該類的通用性，所以采用第三種解決方案。
        case java.sql.Types.TIMESTAMP : return Object.class ;
        
        default :return String.class ;
        }
    }
    public static Date StringTodate(String dateString , String format ) throws ParseException{
        SimpleDateFormat sdf = new SimpleDateFormat(format);  
          // 將時間字符串轉換成java.util.Date對象  
        Date date = sdf.parse(dateString);  
        return date ;
    }
    public static java.sql.Date utildateTosqldate(Date date){
        return new java.sql.Date(date.getTime());
    }
}