利用java的反射機制實現通用dao

阿新 • • 發佈：2019-02-14

java的反射機制前面已經講過，這裡不再贅述，這篇文章將會利用反射，來實現一個通用的dao層。

1 一般情況下的dao層

我們先來看一下，通常，我們是如何寫dao的。

public class Person {
    public int pid;
    public String pname;
    public double psalary;
    public Date pbirthday;

    public int getPid() {
        return pid;
    }
    public void setPid(int pid) {
        this 
.pid = pid;
    }
    public String getPname() {
        return pname;
    }
    public void setPname(String pname) {
        this.pname = pname;
    }
    public double getPsalary() {
        return psalary;
    }
    public void setPsalary(double psalary) {
        this.psalary = psalary;
    }
    public 
 Date getPbirthday() {
        return pbirthday;
    }
    public void setPbirthday(Date pbirthday) {
        this.pbirthday = pbirthday;
    }
    public Person() {
        super();
    }
}

這是一個正常的javabean，這裡的變數寫成public不是我不專業。。。而是我比較懶，方便後面寫程式碼。。。

CREATE DATABASE reflect;

USE reflect;

CREATE 
 TABLE person(
    pid INT PRIMARY KEY,
    pname VARCHAR(255) NOT NULL,
    psalary FLOAT,
    pbirthday DATE
);

INSERT INTO person VALUES(
    1,'jack','1000','1995-11-27'
);

CREATE TABLE animal(
    aid INT PRIMARY KEY,
    aname VARCHAR(255) NOT NULL
);

INSERT INTO animal VALUES(
    1,'tom'
);

資料庫指令碼檔案，這裡採用mysql資料庫

package com.mystery.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.junit.Test;

import com.mystery.domain.Person;

public class PersonDao {
    public static List<Person> select() throws SQLException {  
        Connection conn = null;  
        Statement st = null;  
        ResultSet rs = null;  
        List<Person> list = null;  
        try {  
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/reflect","root","123456"); 

            st = conn.createStatement();  
            rs = st.executeQuery("select * from person");  

            list = new ArrayList<Person>();  

            while (rs.next()) {  
                Person p = new Person();  
                p.setPid(rs.getInt("pid"));  
                p.setPname(rs.getString("pname"));
                p.setPsalary(rs.getFloat("psalary"));
                p.setPbirthday(rs.getDate("pbirthday"));

                list.add(p);  
            }  
        } finally {  
            if (rs != null)  
                rs.close();  
            if (st != null)  
                st.close();  
            if (conn != null)  
                conn.close();  
        }  

        return list;  
    }  

    @Test
    public void test(){
        try {
            List<Person> l = select();
            for (int i = 0; i < l.size(); i++) {
                System.out.println(l.get(i).getPname());
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }
}

通常，我們都是這麼寫的，程式碼量也不是很大，為了省事，我就只寫一個select方法了。但是，假如我們又多了一張表，也就是animal，怎麼辦呢？正常情況下，我們是這麼做的：

package com.mystery.domain;

public class Animal {
    public int aid;
    public String aname;

    public int getAid() {
        return aid;
    }
    public void setAid(int aid) {
        this.aid = aid;
    }
    public String getAname() {
        return aname;
    }
    public void setAname(String aname) {
        this.aname = aname;
    }

}

話不多說，直接javabean

package com.mystery.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.junit.Test;

import com.mystery.domain.Animal;

public class AnimalDao {
    public static List<Animal> select() throws SQLException {  
        Connection conn = null;  
        Statement st = null;  
        ResultSet rs = null;  
        List<Animal> list = null;  
        try {  
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/reflect","root","123456"); 

            st = conn.createStatement();  
            rs = st.executeQuery("select * from animal");  

            list = new ArrayList<Animal>();  

            while (rs.next()) {  
                Animal a = new Animal();  
                a.setAid(rs.getInt("aid"));  
                a.setAname(rs.getString("aname"));

                list.add(a);  
            }  
        } finally {  
            if (rs != null)  
                rs.close();  
            if (st != null)  
                st.close();  
            if (conn != null)  
                conn.close();  
        }  

        return list;  
    }  

    @Test
    public void test(){
        try {
            List<Animal> l = select();
            for (int i = 0; i < l.size(); i++) {
                System.out.println(l.get(i).getAname());
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }
}

然後很無恥的copy&paste一下，稍微做一些修改就好了。感覺也不是很費力。但是，假如又多了10張表呢？copy&paste是那些勤快的人的寫法，像我這種比較懶的，就喜歡一勞永逸的寫法。

一勞永逸的dao

    /**
     * 查詢功能
     * @param cls 要查詢的物件的class物件
     * @return
     * @throws Exception
     */
    public ArrayList<? extends Object> selectAll(Class<?> cls) throws Exception {  
        Connection conn = null;  
        Statement st = null;  
        ResultSet rs = null;  

        ArrayList<Object> list = null;
        Object obj = cls.newInstance();

        try {  
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/reflect","root","123456"); 
            st = conn.createStatement();
            rs = st.executeQuery(String.format(  
                     "select * from %s",cls.getSimpleName()  
                     )); 
            list = new ArrayList<Object>();  

            //這裡如果javabean的屬性是私有的會訪問不到，解決方案有三種
            //1.像我一樣改成public  （極其不推薦）
            //2.新增一句field.setAccessible(true);//設定允許訪問  
            //3.呼叫javabean裡的getset方法
            Field[] fields = cls.getFields(); // 獲得域列表  
            while (rs.next()) {  
                for (Field field : fields) {                
                    Object value = rs.getObject(field.getName());  
                    field.set(obj, value);  // 設定域值  
                }  
                list.add(obj);  
            }  
        } catch (Exception e) {
            e.printStackTrace();
        }finally {  
            if (rs != null)  
                rs.close();  
            if (st != null)  
                st.close();  
            if (conn != null)  
                conn.close();  
        }  

        return list;  
    }

做個測試：

    @Test
    public void testSelectAll(){
        try {
            @SuppressWarnings("unchecked")
            //List<Person> l = (List<Person>) selectAll(Person.class,new Person());
            List<Animal> l = (List<Animal>) selectAll(Animal.class);
            for (int i = 0; i < l.size(); i++) {
                System.out.println(l.get(i).getAname());
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

這樣，一個方法就可以查詢所有的物件，無論是animal還是person，一個dao就夠了，是不是方便了許多？

再寫一個插入和刪除

    /**
     * 插入功能
     * @param obj 要插入的物件
     * @throws Exception
     */
    public void insert(Object obj) throws Exception {  
        Connection conn = null;  
        PreparedStatement st = null;  
        try {  
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/reflect","root","123456"); 

            Class<?> cls = obj.getClass();
            Field[] fields = cls.getFields(); 

            // 下面一段程式碼準備SQL語句的兩部分。  
            StringBuilder sbForFieldName = new StringBuilder();  
            StringBuilder sbForQuestionMark = new StringBuilder();  

            for (int i = 0; i < fields.length; i++) {  
                if(i>0) {  
                    sbForFieldName.append(",");  
                    sbForQuestionMark.append(",");  
                }  
                sbForFieldName.append(fields[i].getName());  
                sbForQuestionMark.append("?");  
            }  

            String FieldNames = sbForFieldName.toString();  
            String QuestionMarks = sbForQuestionMark.toString();  

            // 安全起見，我們需要用prepareStatement處理使用者輸入。  
            // 但是因為類的名稱是可以由程式設計師控制的，我們用String.format生成語句  
            st = conn.prepareStatement(String.format(  
                        "INSERT INTO %s(%s) values(%s)",  
                        cls.getSimpleName(), FieldNames,  QuestionMarks));  

            //填充PreparedStatement  
            for (int i = 0; i < fields.length; i++) {  
                st.setObject(i + 1, fields[i].get(obj));  
            }  

            st.executeUpdate();  
        } finally {  
            if (st != null)  
                st.close();  
            if (conn != null) {  
                conn.close();  
            }  
        }  
    }

    /**
     * 根據id刪除物件  出入的物件必須已經對id賦值並且域名稱必須包含'id'
     * @param obj
     * @return
     * @throws Exception
     */
    public Boolean delete(Object obj) throws Exception {  
        Connection conn = null;  
        Statement st = null;  

        Class<?> cls = obj.getClass();

        try {  
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/reflect","root","123456"); 
            st = conn.createStatement();

            Field[] fields = cls.getFields();
            Object id = null;
            for (Field field : fields) {                
                if(field.getName().indexOf("id") != -1){
                    id = field.get(obj);
                    break;
                }
            } 

            st.executeUpdate(String.format(  
                     "DELETE FROM %s WHERE pid = %s;",cls.getSimpleName(),id  
                     )); 


        } catch (Exception e) {
            e.printStackTrace();
        }finally {   
            if (st != null)  
                st.close();  
            if (conn != null)  
                conn.close();  
        }  

        return true;  
    }


    @SuppressWarnings("deprecation")
    @Test
    public void testInsert(){
        Person p = new Person();
        p.setPid(2);
        p.setPbirthday(new Date(0,1,1));
        p.setPname("jery");
        p.setPsalary(1200);

        try {
            insert(p);
            System.out.println("ok");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @SuppressWarnings("deprecation")
    @Test
    public void testDelete(){
        Person p = new Person();
        p.setPid(2);
        p.setPbirthday(new Date(0,1,1));
        p.setPname("jery");
        p.setPsalary(1200);

        try {
            delete(p);
            System.out.println("ok");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

其他的功能就不貼出來了，原始碼我會放到我的github主頁（https://github.com/CleverFan）上，感興趣的可以去看一下。我也是個新手，有哪些地方不合理的歡迎大家批評指正，互相學習。

利用java的反射機制實現通用dao

java的反射機制前面已經講過，這裡不再贅述，這篇文章將會利用反射，來實現一個通用的dao層。 1 一般情況下的dao層我們先來看一下，通常，我們是如何寫dao的。 public class Person { public int p

利用JAVA反射機制實現調用私有方法

parse try ble cat 權限利用 enabled tde mod 1.fragment是AccessibilityFragment的對象。須要被調用的方法的類。 setAccessible(true)並非將方法的訪問權限改成了public。而是取

利用java反射機制實現List<Map<String, Object>>轉化為List<JavaBean>

tis one row 註解網上 span mybatis star mod 最近在用mybatis做項目，遇到將date格式化顯示到easyui的問題，需要將List<Map<String, Object>>轉化為List<JavaBean

利用Java反射機制實現物件相同欄位的複製

一、如何實現不同型別物件之間的複製問題？ 1、為什麼會有這個問題？近來在進行一個專案開發的時候，為了隱藏後端資料庫表結構、同時也為了配合給前端一個更友好的API介面文件（swagger API文件），我採用POJO來對應資料表結構，使用VO來給傳遞前端要展示的資料，同時使用DTO來進行請求

利用Java反射機制實現對象相同字段的復制

rop 對象復制 bject 不同的 turn 有一個運算符 mes 不讓一。如何實現不同類型對象之間的復制問題？ 1、為什麽會有這個問題？近來在進行一個項目開發的時候，為了隱藏後端數據庫表結構、同時也為了配合給前端一個更友好的API接口文檔（swagger API文

利用java反射機制實現讀取excel表格中的資料

如果直接把excel表格中的資料匯入資料庫，首先應該將excel中的資料讀取出來。為了實現程式碼重用，所以使用了Object,而最終的結果是要獲取一個list如List<User>、List<Book>等，所以需要使用泛型機制去實現。下面會給出程式

利用java反射機制實現javaweb自動呼叫類的方法

public class BookServlet extends HttpServlet { private static final long serialVersionUID = 1L; protected void doGet(HttpServletRequ

SpringBoot利用java反射機制，實現靈活讀取Excel表格中的資料和匯出資料至Excel表格

如果直接把固定Excel表格模板中的資料匯入資料庫，直接將Excel中的資料讀取出來，再存入資料庫中即可，將資料匯出至固定的Excel模板方法類似。但是，有時候，開發製作的模板與客戶需要的往往有些許差別（欄位排版、欄位數量等）。為了實現匯入匯出的靈活性，將利用java的反射機

（小工具）Java反射機制實現任意物件集合按指定任意欄位進行分組通用程式實踐

在應用開發的時候，我們有時候會遇到需要對一個給定集合進行分組的情況。如果該集合的資料記錄是從資料庫的獲取，通常我們最簡單的方案是直接在sql層面select後group by完成。但是，假如某些場景下該資料不是從資料庫獲取呢？那就需要在應用程式層面進行分

（小工具）Java反射機制實現任意物件集合排序並且獲取排列名次的通用程式實踐

在應用開發的時候，我們有時候會遇到需要對一個給定集合進行排序的情況。如果該集合的資料記錄是從資料庫的獲取，通常我們最簡單的方案是直接在sql層面select後order by完成。但是，假如某些場景下該資料不是從資料庫獲取呢？那就需要在應用程式層面進行排

利用java反射機制模擬spring IOC原理的實現

在Java中反射和動態代理機制很強大，通過反射機制在執行時獲取資訊。用於實現IOC。代理是Java基本的設計模式，提供向物件插入額外的或不同的操作。Java的動態代理能動態的建立代理物件，以及動態的呼叫代理方法。用於實現AOP。一、Java反射機制1、作用 (1)在執行時判斷任意一個物件所屬的類； (

利用java反射機制讀取配置檔案實現動態類載入以及動態型別轉換

作者：54dabang 在spring的學習過程之中，我們可以看出通過配置檔案來動態管理bean物件的好處（鬆耦合可以讓零散部分組成一個整體，而這些整體並不在意之間彼此的細節，從而達到了真正的物理上的疏散耦合，而非邏輯，有了IOC之後，我們可以讓SPRING充當各框架

利用java反射機制，實現對類的私有變數和私有方法的訪問

記得有一句很有名的話：No reflection ,no frameworks 這一句短短的話道出了java 反射機制的強大。 java關於反射機制的包主要在java.lang.reflect中，structs,hibernate,spring等框架都是基於java的反射機制。下面是一個關於利用j

java反射機制實現攔截器

tor 攔截 stat 重要 obj static interface 程序 bject 實現一個攔截器必須要實現一下幾個類： 1 目標類接口：目標類要實現的接口。 package com.lanvis.reflect; public interface ITarge

利用java反射機制對方法進行呼叫

轉自：http://blog.csdn.net/coolcoffee168/article/details/5835143 基本步驟：首先獲取Class物件，然後用該物件獲取方法。具體的就看程式碼吧。對照本文最後的結果，會更好的理解反射機制。

利用Java反射機制讀取註解

java程式碼： package ORM; @SxtTable("tb_student") public class SxtStudent { @SxtField(columnName="id", type="int", length=10) private i

php反射機制以及利用php反射機制實現可插拔可擴充套件的外掛架構

反射是什麼？它是指在PHP執行狀態中，擴充套件分析PHP程式，匯出或提取出關於類、方法、屬性、引數等的詳細資訊，包括註釋。這種動態獲取的資訊以及動態呼叫物件的方法的功能稱為反射API。反射是操縱面向物件範型中元模型的API，其功能十分強大，可幫助我們構建複雜，可擴充

javaWeb(十四）頁面向伺服器傳送請求的四個方式、通過反射機制實現通用Servlet

之前我們是頁面傳一個請求過來，我們就寫一個servlet，很麻煩，這次用反射機制直接實現通用BaseServlet，然後我們自己建立根據請求建立的servlet只要繼承BaseServlet，然後我們只要在頁面請求裡寫上我們需要處理的方法（增刪改查），直接在這個servlet裡實現就行了

利用Java反射機制呼叫含陣列引數的方法

–一個含有這種方法的Java類– public class Dao { public void Method2(String[] params){ //do something } } – 正確的方法– public class Test { public static void main

利用java反射機制一次性呼叫實體類get和set方法，簡化更多程式碼。

外部呼叫getProperty方法時只需要傳入實體物件即可；例如TestUtil.getProperty(new User()); 外部呼叫setProperty方法時只需要傳入實體物件和要set的值即可；例如TestUtil.setProperty(new User()

利用java的反射機制實現通用dao

1 一般情況下的dao層

一勞永逸的dao

相關推薦