反射應用

来源:http://www.cnblogs.com/letben/archive/2016/02/07/5184760.html
-Advertisement-
Play Games

一大段很坑爹的代碼,總之我自己也不想看第二遍了,但是還是多少有些可取之處的。 對於單表的增刪改查做的基本上通用了,並且希望在多表操作的時候也一樣好用,只不過後來沒時間繼續做了。對於多表的部分,想盡辦法在避免了。當時遇到的一個 比較嚴重的bug就是 主鍵id 那塊兒,出了點兒問題,後來就單獨設置了一個


一大段很坑爹的代碼,總之我自己也不想看第二遍了,但是還是多少有些可取之處的。

對於單表的增刪改查做的基本上通用了,並且希望在多表操作的時候也一樣好用,只不過後來沒時間繼續做了。對於多表的部分,想盡辦法在避免了。當時遇到的一個 比較嚴重的bug就是 主鍵id 那塊兒,出了點兒問題,後來就單獨設置了一個主鍵的欄位用以標識。這樣的代價就是 要多傳遞 一個 參數 進來。

開始用反射寫出對於單表操作,甚至部分多表以後,還是 挺自大的,直到看見了hibernate 可以 對中間表操作以後就慫了。但是老實講,這些東西還是比較有可取之處的。至少很不錯的拼接了資料庫查詢語句。用了一些反射。如果有興趣歡迎探討,當時在製作的時候還是寫了一些註釋的,希望不會那麼難看,當然這套東西針對 的 mysql資料庫。

有興趣可以看看。

 

這個應用主要是針對,資料庫存取數據的,畢竟我們在操作的時候不希望每次都寫一個 死的東西,來單獨進行增刪改查,那麼為了實現通用就要傳一個 通用的東西,反射能夠最大限度的滿足我們這個 需要,也為了最終實現,可復用可擴展,可維護,靈活性好這個終極目標,對於增刪該查的操作,只要傳遞當前類的對象,其他的dao層繼承了baseDao,然後就可以直接調用通過 addItem(Object) 或者 deleteItem(Object)就可以實現了。

【剛想起來

但是這段程式,並跑不起來,因為 下麵還有一層封裝的是jdbc,這裡面調用了預狀態通道,也就是連接資料庫的部分。在jdbc裡面再把剩餘的部分發上來吧。下麵這段代碼,講真,前不著村後不著店,就是一個 baseDao。不能針對業務層封裝進行持久化,也不能連接資料庫完成存取任務】

 

package com.venushalo.dao;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.letben.tag.PageBean;
import com.venushalo.util.JDBCTemplate;
/**
 * v 1.0 有三個 查詢方法,查詢所有用戶,根據id查詢一個 用戶,根據用戶名和密碼 查詢一個用戶
 * v 2.0 增加了 增刪改三個 方法
 * v 3.0 不斷做了各種修改,忘記都做了什麼了
 * v 4.0 就算目前這個 版本吧。
 * v 5.0 jdbc模板裡面,不能關閉資源,要在 這裡面關閉。
 * v 5.1 真實關閉資源。
 * v 5.2 得到 表中元組數量判定是否是 子表。
 * v 5.21 修複了一個小bug。分頁查詢結果為零時,返回1避免報錯。//事實上這個 bug應該由分頁來實現,並且也已經實現了
 * 
 * javaBean名:User.
 * @author Letben 
 * TaughtBy Salmon
 *
 */
public class BaseDao {
    /*
     * 得到列表,查詢某一個id都是十分必要的。
     * 可以做login的,
     * id的,
     * allObject全部列表的。
     * 修改的話,就aoe修改。
     * 刪除做一個@deprecated。表示不建議使用。
     * insert?
     * 
     * 用就用,不用就放裡面,他只是一個方法。
     * 
     * */
    protected JDBCTemplate jt;
    /**
     * 構造方法,得到JDBC模板
     */
    public BaseDao(){
        jt = new JDBCTemplate();
    }
    /**
     * 沒有實現
     * 因為不建議刪除所以我們這樣寫了一句話,以強調,你確定要刪除,但是我們仍然允許使用。
     * 最好提供一個重載,利用id
     * TODO
     * @param object
     * @return
     */
    @Deprecated
    public boolean deleteItem(Object object){
        return false;
    }
    /**
     * sql = "delete from c對應的表 where idInTable=id";
     * sql = "delete from user_tb where user_id=1";
     * 可是這樣都不知道從哪個表裡面刪,還需要傳一個Class
     * 因為不建議刪除所以我們這樣寫了一句話,以強調,你確定要刪除,但是我們仍然允許使用。
     * @param id
     * @return
     */
    @Deprecated
    public boolean deleteItem(Class c,String id,String primaryIdInTable){
        
        //sql = "delete from user_tb where user_id=?";
        String tableName = getTableName(c);
        String sql = "delete from "+tableName+" where "+primaryIdInTable+"=?";
        List params = new ArrayList();
        params.add(id);
        System.out.println(sql.toString());
        boolean flag = jt.updateData(sql, params);
        jt.closeRes();
        return flag;
    }
    /**
     * 更新一個對象,只要傳入一個對象。這是 那個 有bug的方法啊!!!,如果 id不重覆的話 這樣修改 是可以的。
     * 消除了外鍵關鍵字的bug。
     * 並未考慮到如果當前對象不存在的情況。
     * @param object
     * @return
     */
    public boolean updateItem(Object object){//傳一個對象,就能夠修改對象的值,當然前提是,這個對象是完整的。
        
        //update user_tb set user_name=?,user_password=?,user_type=?,user_age=?,user_address where user_id=?
        //看來需要修改addItem裡面的方法了。因為感覺這個不能,在用list一個一個添加了。  試試看
        StringBuffer sql = new StringBuffer("update ");
        Class c = object.getClass();
        String tableName = getTableName(c);
        sql.append(tableName+" set ");//update user_tb set 
        //拼出來需要屬性,這樣的話就得拿到 資料庫中的列名,也就是對應bean中的 屬性名。
        Method[] methods = c.getMethods();
        List fieldNames = new ArrayList();
        List fieldValues = new ArrayList();
        for (Method method : methods) {
            String methodName = method.getName();
            if(methodName.startsWith("get")&&!methodName.equalsIgnoreCase("getclass")){//從object屬性裡面取得值。不過是用get好還是 set好?針對於修改來講,我認為是set好,因為那個getAllPrice()方法,allPrice並非是一個可以被設置的值。一定要取到可以被設置的方法。
                String fieldName = methodName.substring(3);//屬性名
                fieldNames.add(fieldName);
                try {
                    fieldValues.add(method.invoke(object, new Object[]{}));//不過,還是有bug那就只能不允許getAllPrice()的出現或者 自定義標簽來實現,後面慢慢再想辦法。
                } catch (IllegalAccessException e) {
                    e.printStackTrace();
                } catch (IllegalArgumentException e) {
                    e.printStackTrace();
                } catch (InvocationTargetException e) {
                    e.printStackTrace();
                }
            }
        }
        String fieldId = null;
        String fieldIdValue = null;
        int commaCount=0;
        int fieldCount = fieldNames.size();
        for(int i=0;i<fieldCount;i++){
            {    
                // 拼接字元串方法一。
                //這個在不同的版本裡面這個 計數的方式 不一樣!!!,不是不一樣因為讀取的順序是隨機的
                //所以有時候就讀到了帶id的方法,有時候沒有讀到,結果是,有時候就多一個 有時候就少一個。
                if(!fieldNames.get(i).toString().contains("id")&&i<fieldNames.size()-2){//如果該欄位不包含id,前面的欄位,加","
                    sql.append(fieldNames.get(i)+"='"+fieldValues.get(i)+"',");
                }else if(!fieldNames.get(i).toString().contains("id")&&i==fieldNames.size()-2){//最後一個要被修改的欄位
                    sql.append(fieldNames.get(i)+"='"+fieldValues.get(i)+"'");
                }else{
                    //sql.append(" where "+fieldNames.get(i)+"='"+fieldValues.get(i)+"'");
                    //update user_tb set  where User_id='1'User_name='lifei',User_type='1',User_age='23',User_address='北京',User_password='111111'
                    fieldId=fieldNames.get(i).toString();
                    fieldIdValue = fieldValues.get(i).toString();
                    //本來在下麵想再遍歷一次的,但是覺得這樣的話,代價稍微小一點。減輕了一次遍歷。
                }
                /*update user_tb set User_address='北京',User_password='111111', where User_id='1'User_type='1',User_name='lifei' where User_age='23'
                如果直接上面那種寫法不穩定
                update user_tb set User_address='北京',User_password='111111',User_type='1',User_name='lifei',User_age='23'*/
                
            }
            //上面的方法不穩定,換一個可行的方法,這個 不靠譜的概率太大了。
            /*{//拼接字元串方法二
                //終於知道為啥了!!!這裡面有一個 posi_id這個 id是一個bug。所以 有必要傳一個idInTable
                if(!fieldNames.get(i).toString().equalsIgnoreCase(idInTable)){//不包含id就說明是普通的要被更改的屬性。
                    sql.append(fieldNames.get(i)+"='"+fieldValues.get(i)+"'");
                        if(commaCount<fieldCount-2){
                            //System.out.println("commaCount:"+commaCount+"  fieldCount: "+fieldCount);
                            sql.append(",");
                            //System.out.println(sql.toString());
                            commaCount++;
                        }
                    
                }else{
                    fieldId=fieldNames.get(i).toString();
                    fieldIdValue = fieldValues.get(i).toString();
                }
            }*/
        }
        sql.append(" where "+fieldId+"='"+fieldIdValue+"'");
        //穩定了
        String string = sql.toString();
        System.out.println(string);
        boolean flag = jt.updateData(string, null);
        jt.closeRes();
        return flag;
    }
    
    /**
     * 更新一個對象,只要傳入一個對象。
     * 消除了外鍵關鍵字的bug。
     * 一定要使用這個 方法!!!!!!!!!!!!!!
     * 並未考慮到如果當前對象不存在的情況。
     * @param object
     * @return
     */
    public boolean updateItem(Object object,String primaryIdInTable){//傳一個對象,就能夠修改對象的值,當然前提是,這個對象是完整的。
        
        //update user_tb set user_name=?,user_password=?,user_type=?,user_age=?,user_address where user_id=?
        //看來需要修改addItem裡面的方法了。因為感覺這個不能,在用list一個一個添加了。  試試看
        StringBuffer sql = new StringBuffer("update ");
        Class c = object.getClass();
        String tableName = getTableName(c);
        sql.append(tableName+" set ");//update user_tb set 
        //拼出來需要屬性,這樣的話就得拿到 資料庫中的列名,也就是對應bean中的 屬性名。
        Method[] methods = c.getMethods();
        List fieldNames = new ArrayList();
        List fieldValues = new ArrayList();
        for (Method method : methods) {
            String methodName = method.getName();
            if(methodName.startsWith("get")&&!methodName.equalsIgnoreCase("getclass")){//從object屬性裡面取得值。不過是用get好還是 set好?針對於修改來講,我認為是set好,因為那個getAllPrice()方法,allPrice並非是一個可以被設置的值。一定要取到可以被設置的方法。
                String fieldName = methodName.substring(3);//屬性名
                fieldNames.add(fieldName);
                try {
                    fieldValues.add(method.invoke(object, new Object[]{}));//不過,還是有bug那就只能不允許getAllPrice()的出現或者 自定義標簽來實現,後面慢慢再想辦法。
                } catch (IllegalAccessException e) {
                    e.printStackTrace();
                } catch (IllegalArgumentException e) {
                    e.printStackTrace();
                } catch (InvocationTargetException e) {
                    e.printStackTrace();
                }
            }
        }
        String fieldId = null;
        String fieldIdValue = null;
        int commaCount=0;
        int fieldCount = fieldNames.size();
        for(int i=0;i<fieldCount;i++){
            /*{    
                // 拼接字元串方法一。
                //這個在不同的版本裡面這個 計數的方式 不一樣!!!,不是不一樣因為讀取的順序是隨機的
                //所以有時候就讀到了帶id的方法,有時候沒有讀到,結果是,有時候就多一個 有時候就少一個。
                if(!fieldNames.get(i).toString().contains("id")&&i<fieldNames.size()-2){//如果該欄位不包含id,前面的欄位,加","
                    sql.append(fieldNames.get(i)+"='"+fieldValues.get(i)+"',");
                }else if(!fieldNames.get(i).toString().contains("id")&&i==fieldNames.size()-2){//最後一個要被修改的欄位
                    sql.append(fieldNames.get(i)+"='"+fieldValues.get(i)+"'");
                }else{
                    //sql.append(" where "+fieldNames.get(i)+"='"+fieldValues.get(i)+"'");
                    //update user_tb set  where User_id='1'User_name='lifei',User_type='1',User_age='23',User_address='北京',User_password='111111'
                    fieldId=fieldNames.get(i).toString();
                    fieldIdValue = fieldValues.get(i).toString();
                    //本來在下麵想再遍歷一次的,但是覺得這樣的話,代價稍微小一點。減輕了一次遍歷。
                }
                update user_tb set User_address='北京',User_password='111111', where User_id='1'User_type='1',User_name='lifei' where User_age='23'
                如果直接上面那種寫法不穩定
                update user_tb set User_address='北京',User_password='111111',User_type='1',User_name='lifei',User_age='23'
                
            }*/
            //上面的方法不穩定,換一個可行的方法,這個 不靠譜的概率太大了。
            {//拼接字元串方法二
                //終於知道為啥了!!!這裡面有一個 posi_id這個 id是一個bug。所以 有必要傳一個idInTable
                if(!fieldNames.get(i).toString().equalsIgnoreCase(primaryIdInTable)){//不包含id就說明是普通的要被更改的屬性。
                    sql.append(fieldNames.get(i)+"='"+fieldValues.get(i)+"'");
                        if(commaCount<fieldCount-2){
                            //System.out.println("commaCount:"+commaCount+"  fieldCount: "+fieldCount);
                            sql.append(",");
                            //System.out.println(sql.toString());
                            commaCount++;
                        }
                    
                }else{
                    fieldId=fieldNames.get(i).toString();
                    fieldIdValue = fieldValues.get(i).toString();
                }
            }
        }
        sql.append(" where "+fieldId+"='"+fieldIdValue+"'");
        //穩定了
        String string = sql.toString();
        //System.out.println(string);
        boolean flag = jt.updateData(string, null);
        jt.closeRes();
        return flag;
    }
    /**
     * 向資料庫中添加一個對象。添加對象的時候id一定要重新獲取對嘛?對的!
     * @param object
     * @return
     */
    public boolean addItem(Object object){
        
        
        Class c = object.getClass();
        /*String className = c.getName();
        String tableName = className.substring(className.lastIndexOf(".")+1);*/
        String tableName = getTableName(object.getClass());
        //insert into user_tb () values ();
        StringBuffer sql = new StringBuffer("insert into ");//後置空格
        sql.append(tableName+" ");
        List fieldsNames =new ArrayList();
        List fieldsValues = new ArrayList();
        //對應添加值
        Method[] methods = c.getMethods();
        for (Method method : methods) {
            String methodName = method.getName();
            if(methodName.startsWith("get")&&!methodName.equalsIgnoreCase("getClass")){
                String fieldName = methodName.substring(3);
                fieldsNames.add(fieldName);
                try {
                fieldsValues.add(method.invoke(object, new Object[]{}));
                } catch (IllegalAccessException e) {
                    e.printStackTrace();
                } catch (IllegalArgumentException e) {
                    e.printStackTrace();
                } catch (InvocationTargetException e) {
                    e.printStackTrace();
                }
            }
        }
        //組拼
        sql.append("(");
        //value
        for(int i=0;i<fieldsNames.size();i++){//前面這裡還不能加"'"
            if(i==fieldsNames.size()-1){
                sql.append(fieldsNames.get(i));
            }else{
                sql.append(fieldsNames.get(i)+",");
            }
        }
        sql.append(")");
        sql.append(" values ");
        sql.append("(");
        for(int i=0;i<fieldsValues.size();i++){//這裡記得加"'"
            //Unknown column '北京' in 'field list'
            //sql:insert into user_tb (User_address,User_password,User_id,User_name,User_type,User_age) values (北京,111111,3,shenxiuhua,1,23)
            //這是一個多正常的語句。看都不知道哪裡出了問題。所以不管怎麼樣,一定要讓這句話首先在資料庫裡面跑一遍,如果能跑說明沒有問題。
            if(i==fieldsNames.size()-1){
                sql.append("'"+fieldsValues.get(i)+"'");
            }else {
                sql.append("'"+fieldsValues.get(i)+"',");
            }
            
        }
        /*
         *TODO
         * 這種方式是行得通的,上面獲得參數個數,然後每添加一個,就計數+1,然後拼對應數量的"?",上面這種方式,也是可取的。 
        List params = new ArrayList(); 
        for (Object fieldValue : fieldsValues) {
            params.add(fieldValue);
        }*/
        sql.append(")");
        String sqlString = sql.toString();
        System.out.println(sqlString);
        boolean flag = jt.updateData(sqlString, null);
        jt.closeRes();
        return flag;
    }
    
    /**
     * 再添加新用戶的時候,得到 這個對象應該得到的id。
     * @param object 
     */
    protected int getObjectId(Object object,String primaryIdInTable) {
        Class c = object.getClass();
        String tableName = getTableName(c);
        String sql = "select max("+primaryIdInTable+") from "+tableName;
        System.out.println(sql);
        ResultSet resultSet = jt.query(sql, null);
        int lastId = 1;
        try {
            if(resultSet.next()){
                lastId = resultSet.getInt(1);
            }
        } catch (SQLException e) {
            System.out.println("獲得 當前表最後一個對象的id時 出現異常");
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return lastId+1;
    }
    
    /**
     * 通過 用戶名和密碼得到對象
     * sql = "select * from "+tableName+" where "+nameInTable+"=? and "+passwordInTable+"=?";
     * sql = "select * from user_tb where user_name=? and user_password=?";
     * 
     * @param c 對應的 javaBean的名字
     * @param name 用戶名
     * @param password 密碼
     * @param nameInTable 對應資料庫表中name的欄位名稱
     * @param passwordInTable 對應資料庫表中password的欄位名稱
     * @return
     */
    public Object loginByNAP(Class c,String name,String password,String nameInTable,String passwordInTable){
        String tableName = getTableName(c);
        String sql = "select * from "+tableName+" where "+nameInTable+"=? and "+passwordInTable+"=?";
        //System.out.println(sql);
        List params = new ArrayList();
        params.add(name);
        params.add(password);
        ResultSet resultSet = jt.query(sql, params);
        Object object = null;
        try {
            if(resultSet.next()){
                    object = setValueForObject(object, c, resultSet);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (IllegalArgumentException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }
        jt.closeRes();
        return object;
    }
    
    /**
     * 通過一個 字元串形式表現的 表,得到  對應 類  對象的所有信息。 
     * @param string
     * @param c
     * @return
     */
    public List getAllObjectsInfoByClass(String string, Class c){
        
        ResultSet resultSet = jt.query(string, null);
        List list = new ArrayList();//被返回的對象。
        Object object = null;//得到的每一個對象存儲在這裡。
        try {
            //得到該類的對象,並給該類的對象賦值。
            while(resultSet.next()){//如果查到一條結果,報出sql異常
                object = setValueForObject(object, c, resultSet);
                list.add(object);
                object= null;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return list;
    }
    /**
     * 得到資料庫中的所有元素
     * @param c
     * @return
     */
    public List getAllObjects(Class c){
        String tableName = getTableName(c);
        String sql="select * from "+tableName;
//        List params = new ArrayList();
//        params.add(tableName);
        //無論怎麼樣都要用預狀態通道,因為安全性更高(能夠防止sql註入),執行效率更高。
        ResultSet resultSet = jt.query(sql, null);
        List list = new ArrayList();//被返回的對象。
        Object object = null;//得到的每一個對象存儲在這裡。
        try {
            //得到該類的對象,並給該類的對象賦值。
            while(resultSet.next()){//如果查到一條結果,報出sql異常
                object = setValueForObject(object, c, resultSet);
                list.add(object);
                object= null;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return list;
    }
    
    public List getAllObjects(Class c,String whereClause){
        String tableName = getTableName(c);
        String sql="select * from "+tableName+" "+whereClause;
//        List params = new ArrayList();
//        params.add(tableName);
        //無論怎麼樣都要用預狀態通道,因為安全性更高(能夠防止sql註入),執行效率更高。
        ResultSet resultSet = jt.query(sql, null);
        List list = new ArrayList();//被返回的對象。
        Object object = null;//得到的每一個對象存儲在這裡。
        try {
            //得到該類的對象,並給該類的對象賦值。
            while(resultSet.next()){//如果查到一條結果,報出sql異常
                object = setValueForObject(object, c, resultSet);
                list.add(object);
                object= null;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return list;
    }
    /**
     * 通過id查找到對應用戶,
     * sql ="select * from "+tableName+" where "+idInTable+"=?";
     * sql ="select * from user_tb where user_id=?";
     * @param c javaBean.class
     * @param id  要被查找的id
     * @param idInTable 在資料庫表中id對應的名字。
     * @return
     */
    public Object getObjectById(Class c,String id,String primaryIdInTable){
        String tableName = getTableName(c);
        String sql ="select * from "+tableName+" where "+primaryIdInTable+"=?";
        List params = new ArrayList();
        params.add(id);
        ResultSet resultSet = jt.query(sql, params);
        Object object = null;
        try {
            if(resultSet.next()){
                //為屬性添加值
                object = setValueForObject(object, c, resultSet);
            }else{
                System.out.println("該記錄不存在");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return object;
    }
    
    /**
     * 根據類型名獲得表名,私有方法不對外暴露
     * @param c
     * @return
     */
    private String getTableName(Class c) {
        String tableName=null;
        //這個名稱轉換做一個私有的函數。給如一個類名,給出一個表名
        String className = c.getName();
        //先實現,在優化!寫多了自然優化了
        //先考慮一個單詞的情況,切詞技術~還更麻煩
        //System.out.println("類全名,大概是一個:com.letben.bean.User 的形式:"+className);
        //字元串兒這裡的操作大都是包含頭的不包含尾的操作,所以取得最後一個“.”的位置後,+1,就能渠道對應的javaBean的名字。
        String beanName = className.substring(className.lastIndexOf(".")+1);//User
        //全部變小寫
        beanName = beanName.toLowerCase();//user
        //字元串兒拼接
        tableName = beanName+"_tb";//user_tb
        return tableName;
    } 
    
    
    /**
     * 內部方法,用來實現對象參數的設置。
     * @param object
     * @param c
     * @param resultSet
     * @return
     * @throws InstantiationException
     * @throws IllegalAccessException
     * @throws IllegalArgumentException
     * @throws InvocationTargetException
     * @throws SQLException
     */
    private Object setValueForObject(Object object,Class c,ResultSet resultSet) throws InstantiationException, IllegalAccessException, IllegalArgumentException, InvocationTargetException, SQLException {
        //就新建一個c類對象的實例
        object= c.newInstance();//初始化異常,非法許可權異常
        //註意體會c.getDeclaredMethods();與c.getMethods();的區別。
        Method[] methods = c.getMethods();//得到所有public的方法。
        for (Method method : methods) {//遍歷所有方法
            String methodName = method.getName();//得到當前遍歷的方法的名字
            if(methodName.startsWith("set")){//如果方法是以set開頭的。說明這個類的對象在初始化時需要這麼一個對象的設置
                //這裡跟取值那個地方有點兒不同,在取值的時候註意排除,getClass的方法
                //記不記得後面有通過反射,拿到根本不需要設置的屬性的名比如allPrice,我們只是寫了一個getAllPrice的方法。
                //後面跟的必然是屬性名:
                String fieldName = methodName.substring(3);//把前面3個截掉。
                Class[] parameterTypes = method.getParameterTypes();//得到當前方法,所需參數的名字們。
//                System.out.println(methodName);
                if(parameterTypes[0] == String.class){
                    method.invoke(object, new Object[]{resultSet.getString(fieldName)});//會報非法參數異常和調用目標異常
                    /*String s =null;
                    s="";
                    System.out.println(s.getClass());
                    System.out.println(String.class);
                    這兩個結果是一致的。
                    */
                }else if(parameterTypes[0]==int.class){//註意int.class!=Integer.class
                    //int.class         ->        int
                    //Integer.class     ->        class java.lang.Integer
                    method.invoke(object, new Object[]{resultSet.getInt(fieldName)});
                }else if(parameterTypes[0]==double.class){
                    method.invoke(object, new Object[]{resultSet.getDouble(fieldName)});
                }else{
                    System.out.println("還有屬性沒有考慮到。屬性名稱為:   "+method.getName()+"   。參數類型為:   "+parameterTypes[0]);
                }
            }
        }//for完一圈兒,說明對象已經完整賦過值了
        return object;
        /*
         * 
        簡體版
        object = c.newInstance();//初始化異常,非法許可權異常
                    //接下來就是對應賦值
                    //跟c.getDeclaredMethods()的區別?
                    Method[] methods = c.getMethods();
                    for (Method method : methods) {
                        String methodName = method.getName();
                        if(methodName.startsWith("set")){
                            String fieldName = methodName.substring(3);
                            Class[] parameterTypes = method.getParameterTypes();//我們的get就都只有一個參數
                            if(parameterTypes[0]==String.class){
                                method.invoke(object, new Object[]{resultSet.getString(fieldName)});
                            }else if(parameterTypes[0]==int.class){
                                method.invoke(object, new Object[]{resultSet.getInt(fieldName)});
                            }else{
                                System.out.println("未考慮到的屬性");
                            }
                        }
                    }
         */
    }
    
    /**
     * 為了邏輯刪除後面加一個 whereClause,也可以傳 null
     * 單表傳遞類名,得到數量。
     * @param c
     * @param whereClause
     * @return
     */
    public int getAllObjectsCount(Class c,String whereClause) {
        String tableName = getTableName(c);
        String sql=null;
        if(whereClause==null){
            sql = "select count(*) from "+tableName;
        }else {
            sql = "select count(*) from "+tableName+" "+whereClause;
        }
        System.out.println(sql);
        ResultSet resultSet = jt.query(sql, null);
        int count = 0;
        try {
            if(resultSet.next()){
                count = resultSet.getInt(1);
            }
        } catch (SQLException e) {
            System.out.println("查詢所有元組數量時,出現異常");
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return count;
    }
    
    
    /**
     * 多表查詢元組總數量。
     * @param childTableName
     * @param whereClause
     * @param isChildTable
     * @return
     */
    public int getAllObjectsCount(String childTableName,String whereClause,boolean isChildTable) {
        String sql =null;
        if(isChildTable){
            sql = "select count(*) from ("+childTableName+") alias "+whereClause;
        }else {
            sql = "select count(*) from "+childTableName+" "+whereClause;
        }
        System.out.println(sql);
        ResultSet resultSet = jt.query(sql, null);
        int count = 0;
        try {
            if(resultSet.next()){
                count = resultSet.getInt(1);
            }
        } catch (SQLException e) {
            System.out.println("查詢所有元組數量時,出現異常");
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return count;
    }
    
    /** 
     * 分頁得到條目信息。 select alias.* from ( "+childTableName+" ) alias limit 0,3
     * @param childTableName  子表
     * @param c    子表對應的javabean
     * @param pageBean 分頁情況
     * @param isChildName 是否是子表
     * @return
     */
    public List getAllInfosByPage(String childTableName,
            Class c, PageBean pageBean,boolean isChildTable) {
        String sql=null;
        if(isChildTable){
            sql = "select alias.* from ( "+childTableName+" ) alias limit "+(pageBean.getCurrentPage()-1)*pageBean.getPageSize()+" ,"+pageBean.getPageSize()+" ";
        }else{
            sql = "select alias.* from  "+childTableName+"  alias limit "+(pageBean.getCurrentPage()-1)*pageBean.getPageSize()+" ,"+pageBean.getPageSize()+" ";
        }
        System.out.println(sql);
        ResultSet resultSet = jt.query(sql, null);
        Object object=null;
        try {
            object = c.newInstance();
        } catch (InstantiationException | IllegalAccessException e1) {
            System.out.println("分頁查詢時 創建對象出現異常");
            e1.printStackTrace();
        }
        List objects = new ArrayList();
        try {
            while(resultSet.next()){
                object = setValueForObject(object, c, resultSet);
                objects.add(object);
                object = null;    
            }
        } catch (Exception e) {
            System.out.println("分頁獲取信息時 出現異常");
            e.printStackTrace();
        }finally{
            jt.closeRes();
        }
        return objects;
    }
}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 丙申年把真假美猴王囚禁在容器中跑 ASP.NET Core 1.0¶警告您當前查看的頁面是未經授權的轉載! 如果當前版本排版錯誤,請前往查看最新版本:http://www.cnblogs.com/qin-nz/p/aspnetcore-run-on-mono-in-year-of-monkey.ht...
  • 之前就是說過“一個項目有很多重要的步驟以及功能”,那我們現在就來看看對於KTV項目來說;後臺是處於什麼樣的重要作用! 首先就得瞭解KTV後臺的一些功能了: 1.歌曲管理 、歌手管理 、設置資源路徑 2.新增歌手、歌手查詢、新增歌曲、歌曲查詢、更改歌曲路徑以及退出點歌系統 一.後臺登錄界面 01.判斷
  • continue和break可以改變迴圈的執行流程,但在多重迴圈中,這兩條語句無法直接從內層迴圈跳轉到外層迴圈。在C語言中,可以通過goto語句實現多重迴圈的跳轉,但在非迴圈結構中使用goto語句會使程式的結構紊亂,可讀性變差。因此Java就發明瞭一種帶標簽的continue和break語句,實際上...
  • 數據類型內置函數用法int 關於內置方法是非常的多這裡呢做了一下總結 (1)__abs__(...)返回x的絕對值 #返回x的絕對值!!!都是雙下劃線 x.__abs__() <==> abs(x) 例如: #!/usr/bin/python print "abs(-45) : ", abs(-45
  • pycharm開發django工程(二) 項目需求: 1. 從mongodb中讀取數據,並顯示到網頁中 2. 在網頁顯示的每一頁加入分頁符 首先使用pycharm的企業版新建一個django的虛擬工程(參考我的上一個博客),這是初始的顯示效果 這是原始的html文件,css文件在本文的最後,至於圖片...
  • 1.continue 語句的作用 終止本次迴圈的執行,即跳過當前一次迴圈中continue語句後尚未執行的語句,然後進行下一次迴圈條件的判斷。 2.break 語句的作用 (1)當break在迴圈體內時,強行終止整個迴圈的執行,即結束整個迴圈過程,不再判斷執行迴圈的條件是否成立,直接轉向迴圈體下麵的
  • 《微型電腦原理與介面技術(第2版)》馮博琴 吳寧 主編-清華大學出版社——做筆記用 一、8088/8086的14個16位寄存器: //----------------------------------------------------------------------------------
  • 1、定位系統問題 依據 GC日誌 堆轉儲快照(heapdump/hprof文件) 線程快照(threaddump/javacore文件) 運行日誌 異常堆棧 分析依據的工具 jps:顯示指定系統內的所有JVM進程 jstat:收集JVM各方面的運行數據 jinfo:顯示JVM配置信息 jmap:形成
一周排行
    -Advertisement-
    Play Games
  • 基於.NET Framework 4.8 開發的深度學習模型部署測試平臺,提供了YOLO框架的主流系列模型,包括YOLOv8~v9,以及其系列下的Det、Seg、Pose、Obb、Cls等應用場景,同時支持圖像與視頻檢測。模型部署引擎使用的是OpenVINO™、TensorRT、ONNX runti... ...
  • 十年沉澱,重啟開發之路 十年前,我沉浸在開發的海洋中,每日與代碼為伍,與演算法共舞。那時的我,滿懷激情,對技術的追求近乎狂熱。然而,隨著歲月的流逝,生活的忙碌逐漸占據了我的大部分時間,讓我無暇顧及技術的沉澱與積累。 十年間,我經歷了職業生涯的起伏和變遷。從初出茅廬的菜鳥到逐漸嶄露頭角的開發者,我見證了 ...
  • C# 是一種簡單、現代、面向對象和類型安全的編程語言。.NET 是由 Microsoft 創建的開發平臺,平臺包含了語言規範、工具、運行,支持開發各種應用,如Web、移動、桌面等。.NET框架有多個實現,如.NET Framework、.NET Core(及後續的.NET 5+版本),以及社區版本M... ...
  • 前言 本文介紹瞭如何使用三菱提供的MX Component插件實現對三菱PLC軟元件數據的讀寫,記錄了使用電腦模擬,模擬PLC,直至完成測試的詳細流程,並重點介紹了在這個過程中的易錯點,供參考。 用到的軟體: 1. PLC開發編程環境GX Works2,GX Works2下載鏈接 https:// ...
  • 前言 整理這個官方翻譯的系列,原因是網上大部分的 tomcat 版本比較舊,此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎,輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • 1、jQuery介紹 jQuery是什麼 jQuery是一個快速、簡潔的JavaScript框架,是繼Prototype之後又一個優秀的JavaScript代碼庫(或JavaScript框架)。jQuery設計的宗旨是“write Less,Do More”,即倡導寫更少的代碼,做更多的事情。它封裝 ...
  • 前言 之前的文章把js引擎(aardio封裝庫) 微軟開源的js引擎(ChakraCore))寫好了,這篇文章整點js代碼來測一下bug。測試網站:https://fanyi.youdao.com/index.html#/ 逆向思路 逆向思路可以看有道翻譯js逆向(MD5加密,AES加密)附完整源碼 ...
  • 引言 現代的操作系統(Windows,Linux,Mac OS)等都可以同時打開多個軟體(任務),這些軟體在我們的感知上是同時運行的,例如我們可以一邊瀏覽網頁,一邊聽音樂。而CPU執行代碼同一時間只能執行一條,但即使我們的電腦是單核CPU也可以同時運行多個任務,如下圖所示,這是因為我們的 CPU 的 ...
  • 掌握使用Python進行文本英文統計的基本方法,並瞭解如何進一步優化和擴展這些方法,以應對更複雜的文本分析任務。 ...
  • 背景 Redis多數據源常見的場景: 分區數據處理:當數據量增長時,單個Redis實例可能無法處理所有的數據。通過使用多個Redis數據源,可以將數據分區存儲在不同的實例中,使得數據處理更加高效。 多租戶應用程式:對於多租戶應用程式,每個租戶可以擁有自己的Redis數據源,以確保數據隔離和安全性。 ...