2. 程式人生 > >手把手教你如何自定義DAO框架（重量級乾貨）（yet）

手把手教你如何自定義DAO框架（重量級乾貨）（yet）

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

https://mp.weixin.qq.com/s?__biz=MzI4Njc5NjM1NQ==&mid=2247484864&idx=2&sn=9721e840eab2b929e9523d82c45a1bb6&chksm=ebd63aecdca1b3fa998f27a185630f7e6b40564cf7cacec8e32818184fcf1d2e23d33757beee&mpshare=1&scene=1&srcid=0206Vt8xydSjEPcErB4rA2az&key=7a4fd26cfac6ce0520c3b75a31a96df31d4be437a8f3317af06cfc9c97b79ac5fbf1bdc6bd5d03aed3ab70644e57d1140efc6bdc63ad85edd4508daea3e8e113732c605adb68dc975c22022d8f989caf&ascene=0&uin=MTA2NzUxMDAyNQ%3D%3D&devicetype=iMac+MacBookAir6%2C2+OSX+OSX+10.10.5+build(14F2511)&version=11020012&lang=zh_CN&pass_ticket=EVZTeGFk8lco7QnbdQu1aVcnN2PUGDc58FC5tG6YJ74SpwFYT%2BA%2BC4MKrc8qeCV1

描述：本篇部落格，主要是對於目前實際web專案開發中，對於資料庫操作的一些基本方法的封裝，通過這樣的方式，可以使得開發更加簡單，減少程式碼量，也便於維護和閱讀。其中，主要是講解了三種不同情況的封裝方法，都是自身實際開發過程中，進行積累的，當然，還有很多不足之處，但是基本夠專案的基本開發。

一：非框架的DAO層封裝

其中包含的知識點：

1：連線池

2：資料來源

3：反射

4：資料庫元資料物件

5：基本的jdbc知識

封裝步驟：

（1）匯入dbcp資料來源包

（2）編寫properties檔案，並且命令為dbcpconfig.properties

#連線設定  
   driverClassName=com.mysql.jdbc.Driver  
   url=jdbc:mysql://localhost:3306/填寫要使用的資料庫  
   username=填寫自己的mysql賬號  
   password=填寫自己的mysql密碼  
     
   #<!-- 初始化連線 -->
 
 
   initialSize=10  
     
   #最大連線數量  
   maxActive=50  
     
   #<!-- 最大空閒連線 --> 
   maxIdle=20  
     
   #<!-- 最小空閒連線 --> 
   minIdle=5  
     
   #<!-- 超時等待時間以毫秒為單位 6000毫秒/1000等於60秒 --> 
   maxWait=60000  
     
     
   #JDBC驅動建立連線時附帶的連線屬性屬性的格式必須為這樣：[屬性名=property;]  
   #注意："user" 與 "password" 兩個屬性會被明確地傳遞，因此這裡不需要包含他們。  
   connectionProperties=useUnicode=true;characterEncoding=gbk  
     
   #指定由連線池所建立的連線的自動提交（auto-commit）狀態。  
   defaultAutoCommit=true  
     
   #driver default 指定由連線池所建立的連線的只讀（read-only）狀態。  
   #如果沒有設定該值，則“setReadOnly”方法將不被呼叫。（某些驅動並不支援只讀模式，如：Informix）  
   defaultReadOnly=false  
     
   #driver default 指定由連線池所建立的連線的事務級別（TransactionIsolation）。  
   #可用值為下列之一：（詳情可見javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE  
   defaultTransactionIsolation=READ_UNCOMMITTED

（3）編寫DBCP工具類

publicclassDBCPUtils{  
   privatestaticDataSource ds ;    
   static{  
       //將配置檔案載入進來  
       InputStreamin= DBCPUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties") ;  
       Properties props =newProperties() ;  
       try{  
           props.load(in) ;  
           ds = BasicDataSourceFactory.createDataSource(props) ;  
       }catch(Exception e) {  
           thrownewRuntimeException("伺服器忙") ;  
       }  
   }  
     
   //提供獲取連線的方法  
   publicstaticConnectiongetConnection(){  
       try{  
           returnds.getConnection() ;  
       }catch(SQLException e) {  
           thrownewRuntimeException("伺服器忙") ;  
       }  
   }  
}

（4）編寫基本DAO層方法封裝

//自定義框架  
publicclassBaseDao{  
 
   // 執行添改刪語句  
   publicbooleanupdate(String sql, Object...params){  
       // 拿到連線物件  
       Connection conn = DBCPUtils.getConnection();  
       intt =0;  
       try{  
           // 建立預處理命令物件  
           PreparedStatement pstmt = conn.prepareStatement(sql);  
           // 對?進行賦值  
           // 獲取ParameterMetaData物件  
           ParameterMetaData pmd = pstmt.getParameterMetaData();  
           // 拿到?的個數  
           intn = pmd.getParameterCount();  
           if(n >0) {  
               // sql語句裡有?號  
               if(params==null||params.length != n) {  
                   thrownewRuntimeException("引數的個數不匹配");  
               }  
               // 依次給每個?賦值  
               for(inti =0; i < n; i++) {  
                   pstmt.setObject(i +1,params[i]);  
               }  
           }  
 
           t = pstmt.executeUpdate();  
       }catch(SQLException e) {  
           e.printStackTrace();  
       }finally{  
           try{  
               conn.close();// 還回池中了  
           }catch(SQLException e) {  
               // TODO Auto-generated catch block  
               e.printStackTrace();  
           }  
       }  
       returnt >0?true:false;  
   }  
 
   // 執行查詢(返回的結果可能是一個或者多個，或者為null，這個就具體根據返回結果再進行處理即可)  
   publicObjectqueryOne(String sql,Class clazz, Object...params){  
       // 拿到連線物件  
       Connection conn = DBCPUtils.getConnection();  
       try{  
           // 建立預處理命令物件  
           PreparedStatement pstmt = conn.prepareStatement(sql);  
           // 對?進行賦值  
           // 獲取ParameterMetaData物件  
           ParameterMetaData pmd = pstmt.getParameterMetaData();  
           // 拿到?的個數  
           intn = pmd.getParameterCount();  
           if(n >0) {  
               // sql語句裡有?號  
               if(params==null||params.length != n) {  
                   thrownewRuntimeException("引數的個數不匹配");  
               }  
               // 依次給每個?賦值  
               for(inti =0; i < n; i++) {  
                   pstmt.setObject(i +1,params[i]);  
               }  
           }  
 
           ResultSet rs = pstmt.executeQuery();  
           //返回的結果可能是一個或者多個，或者為null  
           returnnewResultSetListenerHandlerImpl().handler(rs, clazz) ;  
       }catch(SQLException e) {  
           thrownewRuntimeException() ;  
       }finally{  
           try{  
               conn.close();// 還回池中了  
           }catch(SQLException e) {  
               // TODO Auto-generated catch block  
               e.printStackTrace();  
           }  
       }  
   }  
 
}

（5）查詢返回結果集與實體bean的封裝物件ResultSetListenerHandlerImpl

//只適用於結果集有多條記錄的情況  
//物件的屬性名和表中的欄位名應當一致  
publicclassResultSetListenerHandlerImpl{  
   publicObject handler(ResultSet rs,Classclazz){        
       List<Object>list=newArrayList<Object>() ;  
       //拿到結果集的元資料物件  
       try{  
           while(rs.next()){  
               ResultSetMetaData rsmd = rs.getMetaData() ;  
               //拿到公有多少列  
               int columnCount = rsmd.getColumnCount() ;  
               //先建立物件  
               Object obj = clazz.newInstance() ;  
               for(int i =0; i < columnCount; i++) {  
                   //拿到列名  
                   String columnName = rsmd.getColumnName(i+1) ;        
                   //拿到物件對應的屬性  
                   Field field = clazz.getDeclaredField(columnName) ;  
                   //設定私有屬性可以訪問  
                   field.setAccessible(true) ;  
                   //拿到此列對應的值  
                   Object objectValue = rs.getObject(i+1) ;  
                   //給屬性賦值  
                   field.set(obj, objectValue) ;  
               }  
               list.add(obj) ;  
           }  
           returnlist;  
       }catch(Exceptione) {  
           thrownewRuntimeException() ;  
       }  
   }  
 
}

上面這個是返回一個List的情況，如果只想是返回單個物件，那麼很簡單，稍微處理一下就可以用下面這個類來實現：

//只適用於結果集只有一條記錄的情況  
//物件的屬性名和表中的欄位名應當一致  
publicclassResultSetHandlerImpl{  
   publicObjecthandler(ResultSet rs, Class clazz){  
       //拿到結果集的元資料物件  
       try{  
           if(rs.next()){  
               ResultSetMetaData rsmd = rs.getMetaData() ;  
               //拿到公有多少列  
               intcolumnCount = rsmd.getColumnCount() ;  
               //先建立物件  
               Object obj = clazz.newInstance() ;  
               for(inti =0; i < columnCount; i++) {  
                   //拿到列名  
                   String columnName = rsmd.getColumnName(i+1) ;        
                   //拿到物件對應的屬性  
                   Field field = clazz.getDeclaredField(columnName) ;  
                   //設定私有屬性可以訪問  
                   field.setAccessible(true) ;  
                   //拿到此列對應的值  
                   Object objectValue = rs.getObject(i+1) ;  
                   //給屬性賦值  
                   field.set(obj, objectValue) ;  
               }  
               returnobj ;  
           }else 
               returnnull;  
       }catch(Exception e) {  
           thrownewRuntimeException() ;  
       }  
   }  
 
}

二：Mybatis的DAO層封裝

（1）一般先寫介面：

publicinterfaceDAO{  
   /**  
    * 儲存物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObject save(String str, Object obj) throwsException;  
 
   /**  
    * 修改物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObject update(String str, Object obj) throwsException;  
 
   /**  
    * 刪除物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObject delete(String str, Object obj) throwsException;  
 
   /**  
    * 查詢物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObject findForObject(String str, Object obj) throwsException;  
 
   /**  
    * 查詢物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObject findForList(String str, Object obj) throwsException;  
 
   /**  
    * 查詢物件封裝成Map  
    *  
    *@params  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObject findForMap(String sql, Object obj, String key, String value) throwsException;  
}

（2）再寫實現層：

@Repository("daoSupport")  
publicclassDaoSupportimplementsDAO{  
 
   @Resource(name ="sqlSessionTemplate")  
   privateSqlSessionTemplate sqlSessionTemplate;  
 
   /**  
    * 儲存物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectsave(String str, Object obj)throwsException{  
       returnsqlSessionTemplate.insert(str, obj);  
   }  
 
   /**  
    * 批量更新  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectbatchSave(String str, List objs)throwsException{  
       returnsqlSessionTemplate.insert(str, objs);  
   }  
 
   /**  
    * 修改物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectupdate(String str, Object obj)throwsException{  
       returnsqlSessionTemplate.update(str, obj);  
   }  
 
   /**  
    * 批量更新  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicvoidbatchUpdate(String str, List objs)throwsException{  
       SqlSessionFactory sqlSessionFactory = sqlSessionTemplate.getSqlSessionFactory();  
       // 批量執行器  
       SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);  
       try{  
           if(objs !=null) {  
               for(inti =0, size = objs.size(); i < size; i++) {  
                   sqlSession.update(str, objs.get(i));  
               }  
               sqlSession.flushStatements();  
               sqlSession.commit();  
               sqlSession.clearCache();  
           }  
       }finally{  
           sqlSession.close();  
       }  
   }  
 
   /**  
    * 批量更新  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectbatchDelete(String str, List objs)throwsException{  
       returnsqlSessionTemplate.delete(str, objs);  
   }  
 
   /**  
    * 刪除物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectdelete(String str, Object obj)throwsException{  
       returnsqlSessionTemplate.delete(str, obj);  
   }  
 
   /**  
    * 查詢物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectfindForObject(String str, Object obj)throwsException{  
       returnsqlSessionTemplate.selectOne(str, obj);  
   }  
 
   /**  
    * 查詢物件  
    *  
    *@paramstr  
    *@paramobj  
    *@return 
    *@throwsException  
    */ 
   publicObjectfindForList(String str, Object obj)throwsException{  
       returnsqlSessionTemplate.selectList(str, obj);  
   }  
 
   publicObjectfindForMap(String str, Object obj, String key, String value)throwsException{  
       returnsqlSessionTemplate.selectMap(str, obj, key);  
   }  
}

​


相關推薦

拒絕第三方--手把手教你自定義進度條

還在為了一個小小的效果，依賴一個一個的第三方？ 看著別人隨隨便便寫了一個自定義效果，自己卻除了666啥也做不了？ 如果你認為自己就是這樣，那麼，你要好好看一下這篇文章了！ 進度條作為移動開發的一個常用功能，相信你一定不陌生。本篇，我們要手動編寫一個簡單的進度條，模擬一下

手把手教你如何自定義DAO框架（重量級乾貨）（yet）

https://mp.weixin.qq.com/s?__biz=MzI4Njc5NjM1NQ==&mid=2247484864&idx=2&sn=9721e840eab2b929e9523d82c45a1bb6&chksm=ebd63aec

Android 手把手教您自定義ViewGroup（一）

最近由於工作的變動，導致的部落格的更新計劃有點被打亂，希望可以儘快脈動回來~今天給大家帶來一篇自定義ViewGroup的教程，說白了，就是教大家如何自定義ViewGroup，如果你對自定義ViewGroup還不是很瞭解，或者正想學習如何自定義，那麼你可以好好看看這篇部落格。1、概述在寫程式碼之前，我必須得

[C#] （原創）一步一步教你自定義控制元件——02，ScrollBar（滾動條）

一、前言 技術沒有先進與落後，只有合適與不合適。 本篇的自定義控制元件是：滾動條（ScollBar）。 我們可以在網上看到很多自定義的滾動條控制元件，它們大都是使用UserControl去做，即至少使用一個Panel或其它控制元件作滑塊，使用UserControl本身或另一個控制元件作為背景條，而有的複雜的還

[C#] （原創）一步一步教你自定義控制元件——03，SwitchButton（開關按鈕）

一、前言 技術沒有先進與落後，只有合適與不合適。 本篇的自定義控制元件是：開關按鈕（SwitchButton）。 開關按鈕非常簡單，實現方式也多種多樣，比如常見的：使用兩張不同的按鈕圖片，代表開和關，然後在點選時切換這兩張圖片。 而本篇和前兩篇一脈相承，都是繼承Control，使用GDI+去實現。因為都是相同

[C#] （原創）一步一步教你自定義控制元件——04，ProgressBar（進度條）

一、前言 技術沒有先進與落後，只有合適與不合適。 本篇的自定義控制元件是：進度條（ProgressBar）。 進度條的實現方式多種多樣，主流的方式有：使用多張圖片去實現、使用1個或2個Panel放到UserControl上去實現、過載系統進度條去實現等等。 本次所實現的進度條仍是使用GDI+去實現。當然，如果

[C#] （原創）一步一步教你自定義控制元件——05，Label（原生控制元件）

一、前言 技術沒有先進與落後，只有合適與不合適。 自定義控制元件可以分為三類： 一類是“無中生有”。就如之前文章中的的那些控制元件，都是繼承基類Control，來實現特定的功能效果； 一類是“有則改之”。是對原生控制元件的改造，以達到特定的功能效果； 一類是“使用者控制元件”。是將多個控制元件進行組合，以實現

[C#] （原創）一步一步教你自定義控制元件——06，MaskLayer（遮罩層）

一、前言 技術沒有先進與落後，只有合適與不合適。 本篇的自定義控制元件是：遮罩層（MaskLayer）。 遮罩層對軟體的美觀與易用性上的提高是很大的，在日常使用過程中也會經常看到各種遮罩層，雖然WinForm本身沒有原生的遮罩層控制元件，但實現起來並不麻煩。 遮罩層的實現方式一般有兩種：一種是基於自定義控制元

手把手教你實現Java許可權管理系統 後端篇（十三）：系統備份還原

系統備份還原 在很多時候，我們需要系統資料進行備份還原。我們這裡就使用MySql的備份還原命令實現系統備份還原的功能。 新建工程 新建一個maven專案，並新增相關依賴，可以用Spring boot腳手架生成。 新建 kitty-bakcup 工程，這是一個獨立運行於後臺系統的應用程式，可以分開部署。 po

Android 手把手教您自定義ViewGroup 一

                最近由於工作的變動，導致的部落格的更新計劃有點被打亂，希望可以儘快脈動回來~今天給大家帶來一篇自定義ViewGroup的教程，說白了，就是教大家如何自定義ViewGroup，如果你對自定義ViewGroup還不是很瞭解，或者正想學習如何自定義，那麼你可以好好看看這篇部落格。1、

手把手教你如何玩轉外掛：分頁外掛（Pagehelper）

情景引入：小白：起床起床，，，快起床！！！我：怎麼怎麼了，小白你到底又怎麼了。。小白：我發現在Web系統中，分頁是一種很常見的功能，可是，我之前寫的方法都比較麻煩，移植性不是很高，有沒有什麼好辦法可以快速實現分頁的呢？我：確實是的，分頁功能幾乎在每個系統中都是存在的，它的實現

用Python手把手教你搭建一個web框架-flask微框架！

如果大家在學習Python的路上，或者打算學習Python需要學習資料，可以加群571799375，小編將群裡學習資料免費贈送大家喔！ 在之前的文章當中，小編已經教過大家怎麼搭建一個Django框架，今天我們來探索另外的一種框架的搭建，這個框架就是web框架-flask微框架啦！首先我們帶著以下

IOS-一步一步教你自定義評分星級條RatingBar

//  RatingBar.m // //  Created by HailongHan on 15/1/1. //  Copyright (c) 2015年 cubead. All rights reserved. // #import "RatingBar.h" @interface RatingBar

手把手教你用C++ 寫ACM自動刷題神器（衝入HDU首頁）

少年，作為苦練ACM，通宵刷題的你 是不是想著有一天能夠榮登各大OJ榜首，俯瞰芸芸眾生，唔....要做到這件事情可是需要一定天賦的哦！ 博主本身也搞過一段時間的acm，對刷題深有感觸，不信可以去看我部落格的acm題解（哈哈）。 不過，先給各位辛苦刷題的ACMer賠個不是，畢

手把手教你仿一個知乎日報Android客戶端（一）多圖

本文為作者原創，轉載請註明出處@大蘑菇的部落格 圖片託管服務由貼相簿提供 作為一隻網蟲，肯定是經常泡在網路的海洋裡，有一天偶然看到了知乎日報的API，各方面介面都還挺全面，於是本著“不用白不用”的真理，我決定仿一個知乎日報Adnroid客戶端。

手把手教你仿一個知乎日報Android客戶端（三）主頁面設計

各位朋友，從本篇文章和開始，手把手教你仿一個Android客戶端就要正式開始探究怎樣實現我們前面的那些需求了。在此開發我們將會使用git作為版本控制工具，並且將程式碼託管到github，好啦，廢話少說，咱們開工。 一、建立專案 怎麼建立專案大家應該都知道

手把手教你用Python抓取熱門景點熱力圖!（附程式碼）

手把手教你基於SqlSugar4編寫一個視覺化程式碼生成器（生成實體，以SqlServer為例，文末附原始碼）

　　在開發過程中免不了建立實體類，欄位少的表可以手動編寫，但是欄位多還用手動建立的話不免有些浪費時間，假如一張表有100多個欄位，手寫有些不現實。 這時我們會藉助一些工具，如：動軟程式碼生成器、各種ORM框架自帶的程式碼生成器等等，都可以使用。 我們現在就基於SqlSugar（ORM框架）自己動手製造一個輪子

【專案實踐】手把手教你自建高效能物件儲存伺服器

![物件儲存.png](https://img2020.cnblogs.com/blog/1496775/202103/1496775-20210310095045009-259334496.jpg) > 以專案驅動學習，以實踐檢驗真知 物件儲存的應用範圍非常廣泛，小至圖床、檔案服務，大至大資料應用。無論

手把手教你ExtJS從入門到放棄——篇五(示例1：點選按鈕開啟一個自定義視窗)

 例1:點選按鈕開啟一個window，window重複建立的問題 重點分析：這個問題是初學者經常會犯錯的地方，一般來說簡單的程式碼不會產生此問題，但是如果以後程式碼複雜以後，這個問題如果發生除錯起來會非常麻煩！！ 不多說，JSP部分程式碼如下 003wind