2. 程式人生 > 程式設計 >Spring如何整合ibatis專案並實現dao層基類封裝

Spring如何整合ibatis專案並實現dao層基類封裝

阿新 • • 發佈：2020-09-28

Apache iBatis（現已遷至Google Code下發展，更名為MyBatis）是當前IT專案中使用很廣泛的一個半自動ORM框架，區別於Hibernate之類的全自動框架，iBatis對資料庫的操作擁有更加靈活的控制，對於那些經常需要呼叫本地資料庫函式自定義SQL語句，或是喜歡自己優化SQL執行效率的開發者來說，iBatis是一個非常不錯的選擇。

而得到廣泛應用的開源企業架構SpringFramework，也很好的將其進行了整合，使得iBatis在 SpringFramework中的使用更加便利、快捷。開發者所要做的就是繼承SpringFramework中提供的SqlMapClientDaoSupport類即可。下面將簡單介紹使用spring中整合的ibatis進行專案中dao層基類封裝，以方便開發。

1、SqlMapClientFactoryBean 的裝配

　　SqlMapClientFactoryBean是SqlMapClientTemplate使用的基礎，如果在SpringFramework應用中沒有裝配SqlMapClientFactoryBean，那麼SqlMapClientTemplate將不可用，報空指標錯誤。其配置資訊如下：

<bean id="sqlMapClient"
  class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
  <!-- iBatis sqlmap config 檔案位置 -->
  <property name="configLocation">
    <value>
      /WEB-INF/classes/org/bussiness/config/ibatis/SqlMapConfig.xml
    </value>
  </property>
  <!-- 在SpringFramework配置檔案中使用的資料來源 -->
  <property name="dataSource">
    <ref local="dataSource" />
  </property>
  <!-- 如果需要讀寫Lob欄位，需要注入在SpringFramework配置檔案中配置好的Handler，這裡是Oracle的資料庫 -->
  <property name="lobHandler" ref="oracleLobHandler"/>
</bean>

2、繼承使用SqlMapClientDaoSupport類

2.1）首先定義一個IBaseDao介面提供各種場景的查詢、修改、刪除、分頁查詢的各種抽象功能方法

package org.biframework.dao.ibatis;
import com.ibatis.common.util.PaginatedList;
import java.util.List;
import org.biframework.exception.DaoException;
public abstract interface IBaseDao
{
 public abstract Object getObject(String paramString,Object paramObject)
  throws DaoException;

 @SuppressWarnings("unchecked")
 public abstract List getList(String paramString,Object paramObject)
  throws DaoException;

 public abstract PaginatedList getPgntList(String paramString1,Object paramObject,String paramString2)
  throws DaoException;

 public abstract PaginatedList getPgntList(String paramString1,String paramString2,int paramInt)
  throws DaoException;

 @SuppressWarnings("unchecked")
 public abstract List getListUseSameStmt(String paramString,Object[] paramArrayOfObject)
  throws DaoException;

 public abstract int update(String paramString,Object paramObject)
  throws DaoException;

 public abstract int transUpdateSameOpt(String paramString,Object[] paramArrayOfObject)
  throws DaoException;

 public abstract int transUpdate(Object[][] paramArrayOfObject)
  throws DaoException;
 
 @SuppressWarnings("unchecked")
 public List getList(String statementName,Object parameterObject,int skipResults,int maxResults) throws DaoException;
}

備註：該層也可以不寫

2.2）繼承使用SqlMapClientDaoSupport類並實現IBaseDao介面

package org.biframework.dao.ibatis;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.biframework.exception.DaoException;
import org.springframework.orm.ibatis.support.SqlMapClientDaoSupport;

import com.ibatis.common.util.PaginatedList;

public class BaseDao extends SqlMapClientDaoSupport implements IBaseDao {

  @SuppressWarnings("unused")
  private static Log log;
  protected static final int PAGE_SIZE = 15;
  @SuppressWarnings("unchecked")
  static Class class$0; /* synthetic field */

  public BaseDao() {
  }
  /*
  使用spring中整合的ibatis實現資料的查詢、修改、刪除
  1）當請求引數被封裝為一個普通物件，查詢結果為List集合：
  使用queryForList返回List 原始碼方法如下：getSqlMapClientTemplate()，獲取SqlMapClientTemplate物件，
  引數說明：a、statementName sql宣告；b、parameterObject請求引數物件 queryForList方法原始碼如下
  public List queryForList(String statementName,Object parameterObject)
   throws DataAccessException
   {
    executeWithListResult(new SqlMapClientCallback()
    {
     private final String val$statementName;
     private final Object val$parameterObject;
     public Object doInSqlMapClient(SqlMapExecutor executor)
      throws SQLException
     {
      return executor.queryForList(this.val$statementName,this.val$parameterObject);
     }
    });
   }
  */
  @SuppressWarnings("unchecked")
  public List getList(String statementName,Object parameterObject)
      throws DaoException {
    List list = getSqlMapClientTemplate().queryForList(statementName,parameterObject);
    return list;
  }
  
  /*
  2）當請求引數被封裝為一個數組物件時：
    即使用陣列存放多個傳參物件(obj1、obj2...)而後使用相同sql,進行多次查詢，將多次查詢的結果list1、list2...放到結果集List中)
  使用queryForList返回List 封裝的方法如下：
  */
  @SuppressWarnings("unchecked")
  public List getListUseSameStmt(String statementName,Object objectParam[])
      throws DaoException {
    List list = null;
    List temp = null;
    if (statementName == null || objectParam == null|| objectParam.length == 0){
      return list;
    }else{
      for (int i = 0; i < objectParam.length; i++) {
        if (list == null){
          list = new ArrayList();
          temp = getSqlMapClientTemplate().queryForList(statementName,objectParam[i]);
        }  
        if (temp != null){
          list.addAll(temp);
        }  
      }
    }
    return list;
  }

  /*
  3）當請求引數被封裝為一個普通物件，查詢結果為Object物件
  */
  @SuppressWarnings("unchecked")
  public Object getObject(String statementName,Object parameterObject)
      throws DaoException {
    Object result = null;
    List list = getSqlMapClientTemplate().queryForList(statementName,parameterObject);
    if (list != null && list.size() > 0){
      result = list.get(0);
    }
    return result;
  }
  
  /*
  4）ibatis-common-2.jar、使用ibatis自身封裝的PaginatedList工具類進行分頁查詢，每頁15條資料。
  public PaginatedList queryForPaginatedList(String statementName,int pageSize)
  throws DataAccessException
   {
    if (((this.sqlMapClient instanceof ExtendedSqlMapClient)) && (((ExtendedSqlMapClient)this.sqlMapClient).getDelegate().getTxManager() == null)) {
     throw new InvalidDataAccessApiUsageException("SqlMapClient needs to have DataSource to allow for lazy loading - specify SqlMapClientFactoryBean's 'dataSource' property");
    }
    (PaginatedList)execute(new SqlMapClientCallback()
    {
     private final String val$statementName;
     private final Object val$parameterObject;
     private final int val$pageSize;
     
     public Object doInSqlMapClient(SqlMapExecutor executor)
      throws SQLException
     {
      return executor.queryForPaginatedList(this.val$statementName,this.val$parameterObject,this.val$pageSize);
     }
    });
   }
  */
  public PaginatedList getPgntList(String statementName,String pageDirection) throws DaoException {
    PaginatedList list = getSqlMapClientTemplate().queryForPaginatedList(
        statementName,parameterObject,15);
    if ("next".equals(pageDirection))
      list.nextPage();
    else if ("previous".equals(pageDirection))
      list.previousPage();
    else if ("first".equals(pageDirection))
      list.isFirstPage();
    else if ("last".equals(pageDirection))
      list.isLastPage();
    return list;
  }

  /*
  4）自己指定分頁查詢的數量
  */
  public PaginatedList getPgntList(String statementName,String pageDirection,int pageSize)
      throws DaoException {
    PaginatedList list = getSqlMapClientTemplate().queryForPaginatedList(
        statementName,pageSize);
    if ("next".equals(pageDirection)) {
      System.out.println("下一頁");
      list.nextPage();
    } else if ("previous".equals(pageDirection)) {
      System.out.println("上一頁");
      list.previousPage();
    } else if ("first".equals(pageDirection)) {
      System.out.println("首頁");
      list.isFirstPage();
    } else if ("last".equals(pageDirection)) {
      System.out.println("末頁");
      list.isLastPage();
    }
    return list;
  }
  
  /*
  5）該方法暫時未理解其主要是處於何種場景使用
  */
  public int update(String statementName,Object parameterObject)
  throws DataAccessException
   {
    Integer result = (Integer)execute(new SqlMapClientCallback()
    {
     private final String val$statementName;
     private final Object val$parameterObject;
     public Object doInSqlMapClient(SqlMapExecutor executor)
      throws SQLException
     {
      return new Integer(executor.update(this.val$statementName,this.val$parameterObject));
     }
    });
    return result.intValue();
   }  
  */
  public int transUpdate(Object statementAndparameter[][])
      throws DaoException {
    Object statements[] = statementAndparameter[0];
    Object parameters[] = statementAndparameter[1];
    int result = 0;
    for (int i = 0; i < statements.length; i++) {
      String name = (String) statements[i];
      Object param = parameters[i];
      result += getSqlMapClientTemplate().update(name,param);
    }
    return result;
  }

  /*
  6）請求引數被封裝為一個數組物件，返回結果為成功更新的記錄數使用spring封裝的update方法進行更新操作
  */
  public int transUpdateSameOpt(String statementName,Object objectParam[])
      throws DaoException {
    int result = 0;
    if (statementName == null || objectParam == null
        || objectParam.length == 0)
      return result;
    for (int i = 0; i < objectParam.length; i++)
      result += getSqlMapClientTemplate().update(statementName,objectParam[i]);
    return result;
  }
  /*
  7）請求引數被封裝為一個普通物件，返回結果為成功更新的記錄數
  */
  public int update(String statementName,Object parameterObject)
      throws DaoException {
    int result = getSqlMapClientTemplate().update(statementName,parameterObject);
    return result;
  }

  static {
    log = LogFactory.getLog(org.biframework.dao.ibatis.BaseDao.class);
  }
  
  /*
  8）請求引數被封裝為一個普通物件，並對查詢的結果記錄指定跳躍數和最大結果集
  */
  @SuppressWarnings("unchecked")
  public List getList(String statementName,int maxResults) throws DaoException {
    return getSqlMapClientTemplate().queryForList(statementName,skipResults,maxResults);
  }
}

3、進行dao層配置，並進行查詢等操作

3.1）所有的dao層都繼承BaseDao類

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.biframework.dao.ibatis.BaseDao;
import org.biframework.exception.DaoException;
import org.bussiness.product.detailquery.bo.StPolicyBean;

public class StPolicyDao extends BaseDao {
  protected static Log log = LogFactory.getLog(StPolicyDao.class);
  
  @SuppressWarnings("unchecked")
  public List getStPerm(StPBean param) throws DaoException{
    return super.getList("getShortPrem",param);
  }

  public Object getStPermCount(StPBean param) throws DaoException{
    return super.getObject("getShortPremCount",param);
  }
  }
}

3.2）進行dao裝配 detailQuery-applicationContext.xml

<bean id="nstpDao" class="org.bussiness.product.detailquery.dao.NstPolicyDao">
  <property name="dataSource">
    <ref bean="dataSource" />
  </property>
  <property name="sqlMapClient">
    <ref bean="sqlMapClient" />
  </property>
</bean>

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。

相關推薦

Spring如何整合ibatis專案並實現dao層基類封裝

Apache iBatis（現已遷至Google Code下發展，更名為MyBatis）是當前IT專案中使用很廣泛的一個半自動ORM框架，區別於Hibernate之類的全自動框架，iBatis對資料庫的操作擁有更加靈活的控制，對於那些經常需要呼叫本地資

利用SQLAlchemy和反射實現DAO的基類

在使用SQLAlchemy時，要根據每一個類的情況寫對應增刪改查，習慣了JAVA的虛類、反射，抽象出daobase類，如果python也有就會少很多重複程式碼，於是有了下面的簡單實現。

MyBatis介面代理方式實現Dao層

目錄MyBatis介面代理方式實現Dao層區別1、selectlist和getMapper區別2、namespace的作用介面代理方式 - 實現規則介面代理方式 - 程式碼實現· MyBatisConfig.xml· StudentMapper.xml· controller - studentControl

寫一個自己的platEntity模組-自定義加密註解實現dao層和資料庫互動時對指定屬性進行加解密

技術標籤：mybatis自定義註解RSA 文章目錄 一，引入platEntity模組為什麼要寫一個這個模組？它的作用是什麼？如何使用？首先在pom.xml配置私服

Spring整合Mybatis方式(MapperScannerConfigurer實現)

環境準備請看：https://www.cnblogs.com/SweetheartAndPeaches/p/15468527.html 資料庫準備 根據資料庫建立entity包放一個VoteUser類

SpringBoot整合Mybatis-plus並實現自動生成相關檔案

Mybatis-Plus是一個優秀的Mybatis增強工具，目前更新到3.1.1。Mybatis-Plus原生提供了很多單表操作的方法，極大簡化了繁瑣的curd的操作，同時又支援xml配置、自定義sql的編寫。這篇文章介紹SpringBoot2整合Mybatis-

Spring Boot整合MyBatis及generater自動生成DAO並實現RESTful API

1.在專案的POM.XML檔案的build標籤中，增加如下內容： <plugin> <groupId>org.mybatis.generator</groupId>

spring 整合 mybatis 開發時 dao 層介面的一系列報錯問題彙總

spring 整合 mybatis 時出了三個異常 1. accountDao 爆紅, 本來 dao 層介面實現類由 spring 自動裝配, 不需要我們自己宣告實現類, 但是寫的時候爆紅

spring boot專案可通過Result類或者自定返回類實現controller層返回資料

一.通過Result類實現返回資料 //使用者註冊 @PostMapping(\"/registerUser\") public Result registerUser(@RequestBody User user){

01 整合IDEA+Maven+SSM框架的高併發的商品秒殺專案之業務分析與DAO層

專案原始碼：https://github.com/nnngu/nguSeckill 這是一個整合IDEA+Maven+SSM框架的高併發的商品秒殺專案。我們將分為以下幾篇文章來進行詳細的講解：

通過idea建立Spring Boot專案並配置啟動過程圖解

一、操作步驟 ①使用idea新建一個Spring Boot專案 ②修改pom.xml ③修改application.properties

基於Spring的Maven專案實現傳送郵件功能的示例

問題分析 現在我們有這樣一個需求，就是當我們系統出現問題或bug的時候，讓系統通過郵件傳送日誌資訊給相關人員，那麼此時，我們就需要實現一個讓系統傳送郵件的功能

在django專案中匯出資料到excel檔案並實現下載的功能

依賴模組 xlwt下載：pip install xlwt 後臺模組 view.py # 匯出Excel檔案 def export_excel(request):

新版Flutter整合到已有Android專案的實現

FlutterSDK升級後，我們發現不能按照原來的方式整合到已有Android專案中了，因為沒有了Flutter這個類，通過閱讀原始碼我找到了新的使用方式。

VsCode搭建Spring Boot專案並進行建立、執行、除錯

原始碼地址：https://github.com/YANGKANG01/Spring-Boot-Demo 安裝擴充套件 安裝如下兩個主要擴充套件即可，這兩個擴充套件已關聯java專案開發主要使用的maven、springboot等所需要的擴充套件。

Android 整合 google 登入並獲取性別等隱私資訊的實現程式碼

前言 公司做海外產品的，整合的是 google 賬號登入，賬號資訊、郵箱等這些不涉及隱私的按 google 的正常登入流程可以輕鬆實現 。但是一旦需要獲取涉及隱私的資訊就比較麻煩，文件也不是十分清晰，非常難找，很多坑。

Spring Boot基於Active MQ實現整合JMS

我們使用jms一般是使用spring-jms和activemq相結合，通過spring Boot為我們配置好的JmsTemplate傳送訊息到指定的目的地Destination。本文以點到點訊息模式為例，演示如何在Spring Boot中整合 JMS 和 Active MQ ，實現

IDEA+Maven建立Spring專案的實現步驟

這篇隨筆搭建的工程是普通的Spring工程，用於學習Spring框架，如果要搭建SpringMVC工程，可以參考另一篇

Spring整合mybatis實現過程詳解

增加了用於處理MyBatis的兩個bean：SqlSessionFactoryBean、MapperFactoryBean 1、註冊SqlSessionFactoryBean：

JAVA實現DAO基本層CRUD操作（轉）

轉載：https://www.cnblogs.com/yxwkf/p/4643483.html 以下詳細講講通過我自己的方式對有關DAO層資料庫基本CRUD操作的JAVA實現（此處已MySQL為例，其它資料庫僅僅需做部分改動就可以）。