Spring實現(xiàn)iBATIS事務(wù)回滾

作者：佚名 2009-07-20 18:11:52

Spring 實現(xiàn)iBATIS事務(wù)回滾是怎么實現(xiàn)的呢？讓我們開始這篇文章的學(xué)習(xí)，這篇文章將會想你介紹Spring 實現(xiàn)iBATIS事務(wù)回滾的相關(guān)消息

Spring 實現(xiàn)ibatis事務(wù)回滾是怎么回事呢？

這兩天做一個網(wǎng)站需要在數(shù)據(jù)報錯時自動對數(shù)據(jù)進行回滾，在此期間遇到一些問題，現(xiàn)做下筆記

這里使用spring-Aop代理機制來實現(xiàn)事務(wù)的回滾：

配置如下：

Spring實現(xiàn)iBATIS事務(wù)回滾之Web.xml

﹤?xml version="1.0" encoding="UTF-8"?﹥  
 
﹤web-app xmlns="http://java.sun.com/xml/ns/j2ee" 
 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.4" 
 
    xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee   http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"﹥  
 
    ﹤context-param﹥  
 
       ﹤param-name﹥contextConfigLocation﹤/param-name﹥  
 
       ﹤param-value﹥classpath:applicationContext.xml﹤/param-value﹥  
 
    ﹤/context-param﹥  
 
    ﹤listener﹥  
 
       ﹤listener-class﹥  
 
           org.springframework.web.context.ContextLoaderListener  
 
       ﹤/listener-class﹥  
 
    ﹤/listener﹥  
 
   
 
    ﹤servlet﹥  
 
       ﹤servlet-name﹥AppConfigServlet﹤/servlet-name﹥  
 
       ﹤servlet-class﹥com.test.ConfigServlet﹤/servlet-class﹥  
 
       ﹤load-on-startup﹥2﹤/load-on-startup﹥  
 
    ﹤/servlet﹥  
 
   
 
    ﹤welcome-file-list﹥  
 
       ﹤welcome-file﹥index.jsp﹤/welcome-file﹥  
 
    ﹤/welcome-file-list﹥  
 
﹤/web-app﹥

Spring實現(xiàn)iBATIS事務(wù)回滾之ApplicationContext.xml

﹤bean id="transactionManager" 
 
class="org.springframework.jdbc.datasource.DataSourceTransactionManager"﹥  
 
       ﹤property name="dataSource" ref="dataSource" /﹥  
 
    ﹤/bean﹥  
 
﹤bean id="businessTarget" 
 
       class="com.test.BusinessInterfaceImpl" /﹥  
 
         
 
    ﹤bean id="businessBean" 
 
       class="org.springframework.aop.framework.ProxyFactoryBean"﹥  
 
       ﹤property name="singleton"﹥  
 
           ﹤value﹥true﹤/value﹥  
 
       ﹤/property﹥  
 
       ﹤property name="proxyInterfaces"﹥  
 
           ﹤value﹥com.test.BusinessInterface﹤/value﹥  
 
       ﹤/property﹥  
 
       ﹤property name="interceptorNames"﹥  
 
           ﹤list﹥  
 
              ﹤value﹥transactionInterceptor﹤/value﹥  
 
              ﹤value﹥businessTarget﹤/value﹥  
 
           ﹤/list﹥  
 
       ﹤/property﹥  
 
       ﹤property name="proxyTargetClass"﹥﹤value﹥true﹤/value﹥﹤/property﹥  
 
    ﹤/bean﹥  
 
      
 
    ﹤bean id="transactionInterceptor" 
 
       class="org.springframework.transaction.interceptor.TransactionInterceptor"﹥  
 
       ﹤property name="transactionManager"﹥  
 
           ﹤ref local="transactionManager" /﹥  
 
       ﹤/property﹥  
 
       ﹤property name="transactionAttributes"﹥  
 
           ﹤props﹥  
 
              ﹤prop key="*"﹥PROPAGATION_REQUIRED,-Exception﹤/prop﹥  
 
           ﹤/props﹥  
 
       ﹤/property﹥  
 
    ﹤/bean﹥  
 
    ﹤bean id="dataSource" 
 
       class="org.springframework.jndi.JndiObjectFactoryBean"﹥  
 
       ﹤property name="jndiName"﹥  
 
           ﹤value﹥gissys﹤/value﹥  
 
       ﹤/property﹥  
 
    ﹤/bean﹥  
 
﹤bean id="sqlMapClient" 
 
       class="org.springframework.orm.ibatis.SqlMapClientFactoryBean"﹥  
 
       ﹤property name="configLocation"﹥  
 
           ﹤value﹥  
 
              classpath:com/emaptech/persistence/SqlMapConfig.xml  
 
           ﹤/value﹥  
 
       ﹤/property﹥  
 
       ﹤property name="dataSource" ref="dataSource"﹥﹤/property﹥  
 
    ﹤/bean﹥

Spring實現(xiàn)iBATIS事務(wù)回滾之Ibatis.xml

﹤insert id="testInsert" parameterClass="string"﹥  
 
   insert into corebase.cc select 6,#value# from dual  
 
﹤/insert﹥  
 
 
 
﹤insert id="testInsertWrong" parameterClass="string"﹥  
 
   insert into corebase.cc select 6,#value#,7 from dual  
 
﹤/insert﹥

Spring實現(xiàn)iBATIS事務(wù)回滾之ConfigServlet.java

package com.test;  
 
import javax.servlet.ServletException;  
 
import javax.servlet.http.HttpServlet;  
 
import org.springframework.context.ApplicationContext;  
 
import org.springframework.web.context.support.WebApplicationContextUtils;  
public class ConfigServlet extends HttpServlet {  
 
    /**  
 
     * UID  
 
     */ 
 
    private static final long serialVersionUID = 5118794568550751611L;  
 
    public void init() throws ServletException {  
 
       ApplicationContext ctx = WebApplicationContextUtils.getRequiredWebApplicationContext(this.getServletContext());  
 
       BaseService.getInstance().init(ctx);  
       super.init();  
    }  
}

Spring實現(xiàn)iBATIS事務(wù)回滾之BaseService.java

package com.test;  
 
import org.springframework.beans.BeansException;  
 
import org.springframework.beans.factory.xml.XmlBeanFactory;  
 
import org.springframework.context.ApplicationContext;  
import org.springframework.context.ApplicationContextAware;  
 
import org.springframework.core.io.ClassPathResource;  
import com.ibatis.sqlmap.client.SqlMapClient;  
   
public class BaseService implements ApplicationContextAware {  
 
    private static ApplicationContext ctx;  
 
    private static SqlMapClient sqlMapClient;  
 
    private static SqlMapClient sqlMapClientProxy;  
 
    private static BusinessInterface businessBean;  
      
    private static BaseService instance = new BaseService();  
    
 
    /**  
 
     * @return 返回 靜態(tài)類  
 
     */ 
 
    public static BaseService getInstance(){  
 
       return instance;  
 
    }  
 
    /**  
 
     * @return 返回 初始化BaseService,存于內(nèi)存  
 
     */ 
 
    public void init(ApplicationContext ctx) {  
 
       setApplicationContext(ctx);  
 
       setSqlMapClient(ctx);  
 
       setBusinessBean(ctx);  
 
//     setSqlMapClientProxy(ctx);  
 
       System.out.println(" INFO - 初始化baseservice成功");  
 
    }  
    public void setSqlMapClient(ApplicationContext ctx){  
 
       sqlMapClient = (SqlMapClient) ctx.getBean("sqlMapClient");  
 
    }      
 
    /**  
 
     * @return 返回 sqlMapClient。  
 
     */ 
 
    public SqlMapClient getInstanceSqlMapClient() {  
      return this.sqlMapClient;  
    }  
 
    /**  
 
     * 通過spring注入ApplicationContext  
     *   
     * @param ApplicationContext  
 
     * @return null  
 
     */ 
 
    public void setApplicationContext(ApplicationContext arg0) throws BeansException {  
 
       ctx = arg0;  
 
    }  
 
    public Object getBean(String beanName) {  
 
       return ctx.getBean(beanName);  
 
    }  
    /**  
 
     * @return 返回 sqlMapClient。  
 
     */ 
 
    public SqlMapClient getSqlMapClient() {  
 
       return (SqlMapClient) ctx.getBean("sqlMapClient");  
 
    }  
 
    public void setSqlMapClientProxy(ApplicationContext ctx) {  
 
       sqlMapClientProxy= (SqlMapClient) ctx.getBean("sqlMapClientProxy");  
 
    }  
    public SqlMapClient getSqlMapClientProxy() {  
       return sqlMapClientProxy;  
 
    }  
    public static BusinessInterface getBusinessBean() {  
       return businessBean;  
    }  
 
    public static void setBusinessBean(ApplicationContext ctx) {  
 
       businessBean = (BusinessInterface) ctx.getBean("businessBean");  
 
    }  
 
}

Spring實現(xiàn)iBATIS事務(wù)回滾之BusinessInterface.java

package com.test;  
import java.sql.SQLException;  
 
public interface BusinessInterface {  
 
    public void hello() throws SQLException;  
 
}

Spring實現(xiàn)iBATIS事務(wù)回滾之BusinessInterfaceImpl.java

package com.test;  
 
   
 
import java.sql.SQLException;  
import com.ibatis.sqlmap.client.SqlMapClient;  
 
public class BusinessInterfaceImpl implements BusinessInterface {  
    public void hello() throws SQLException {  
       System.out.println("hello Spring AOP.");  
       SqlMapClient sqlMapClient = BaseService.getInstance().getInstanceSqlMapClient();  
           sqlMapClient.startTransaction();  
 
           sqlMapClient.insert("testInsert","7");  
 
           System.out.println("1");  
 
           sqlMapClient.insert("testInsert","8");  
 
           System.out.println("2");  
 
           sqlMapClient.insert("testInsert","9");  
 
           System.out.println("3");  
 
           sqlMapClient.insert("testInsertWrong","10");  
 
           sqlMapClient.commitTransaction();   
 
    }  
 
}

Spring實現(xiàn)iBATIS事務(wù)回滾之測試頁面

﹤%@ page language="java" import="java.util.*" pageEncoding="ISO-8859-1"%﹥  
 
﹤%  
 
String path = request.getContextPath();  
 
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";  
 
%﹥  
 
﹤!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"﹥  
 
﹤html﹥  
 
  ﹤head﹥  
 
    ﹤base href="﹤%=basePath%﹥"﹥  
 
    ﹤title﹥My JSP 'index.jsp' starting page﹤/title﹥  
 
    ﹤meta http-equiv="pragma" content="no-cache"﹥  
 
    ﹤meta http-equiv="cache-control" content="no-cache"﹥  
 
    ﹤meta http-equiv="expires" content="0"﹥      
 
    ﹤meta http-equiv="keywords" content="keyword1,keyword2,keyword3"﹥  
 
    ﹤meta http-equiv="description" content="This is my page"﹥  
 
    ﹤!--  
 
    ﹤link rel="stylesheet" type="text/css" href="styles.css"﹥  
 
    --﹥  
 
  ﹤/head﹥  
 
  ﹤body﹥  
 
    This is my JSP page. ﹤br﹥  
 
  ﹤/body﹥  
 
﹤/html﹥

Spring實現(xiàn)iBATIS事務(wù)回滾的相關(guān)信息就向你介紹到這里，希望對你了解Spring實現(xiàn)iBATIS事務(wù)回滾有所幫助。

【編輯推薦】

Struts2.0+ibatis2.3完美整合實例之映射淺析
Struts2.0+ibatis2.3整合實例實現(xiàn)服務(wù)層及Struts
Struts2.0+ibatis2.3整合實例實現(xiàn)UI層淺析
iBATIS入門程序六大步詳解
iBATIS DAO事務(wù)淺析

責任編輯：仲衡來源： yesky

iBATIS事務(wù)Spring