Spring在xml配置里配置事務


事先准備:
配置數據源對象
用<bean>實例化各個業務對象。

1.配置事務管理器。

<bean id="transactionManager" class="org.springframework.jdbc.datasourceManager">
  <property name="datasource" ref="datasource"></property>
</bean>

 

2.配置事務屬性

復制代碼
<tx:advice id="txAdvice" transaction-manager="transactionManager">
    <tx:attributes>
        <tx:method name="方法名" propagation="REQUIRES_NEW"/>    <!--新開事務-->
        <tx:method name="*"/>                                    <!--使用原有事務-->
    </tx:attributes>
</tx:advice>
復制代碼

 

3.配置事務切入點,注入事務屬性

<aop:config>
    <aop:pointcut expression="execution(.......)" id="txPointCut"/>
    <aop:advisor advice-ref="txtAdvice" pointcut-ref="txtPointCut"/>
</aop:config>

實例:

准備工作:導入c3p0、Spring框架、Mysql、AOP的jar包,並配置好。

db.properties 

復制代碼
driverClass=com.mysql.jdbc.Driver
jdbcUrl=jdbc:mysql://localhost:3306/mydb
user=root
password=
minPoolSize=5
maxPoolSize=20
initialPoolSize=5
復制代碼

三個接口

package com.itnba.maya.dao;

public interface IInfoDao {
    public void delete(String code);
}
package com.itnba.maya.dao;

public interface IWorkDao {
    public void deleteInfocode(String code);
}
復制代碼
package com.itnba.maya.dao;

public interface IInfoService {
    public void delete(String code);

}
復制代碼

接口的實現類

復制代碼
package com.itnba.maya.daoimp;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import com.itnba.maya.dao.IInfoDao;

public class InfoDao implements IInfoDao {

    private JdbcTemplate j;
    public JdbcTemplate getJ() {
        return j;
    }
    public void setJ(JdbcTemplate j) {
        this.j = j;
    }
    @Override
    public void delete(String code) {
        // 故意設置一個錯誤
        if(code.equals("p008")){
            int n=1/0;
        }
        
        String sql="delete from info where code=?";
        j.update(sql,code);
    }


}
復制代碼
復制代碼
package com.itnba.maya.daoimp;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import com.itnba.maya.dao.IWorkDao;

public class WorkDao implements IWorkDao {
    
    private JdbcTemplate j;

    public JdbcTemplate getJ() {
        return j;
    }

    public void setJ(JdbcTemplate j) {
        this.j = j;
    }

    public void deleteInfocode(String code) {
    
        String sql="delete from work where infocode=?";
        j.update(sql,code);
    }

}
復制代碼
復制代碼
package com.itnba.maya.daoimp;

import com.itnba.maya.dao.IInfoDao;
import com.itnba.maya.dao.IInfoService;
import com.itnba.maya.dao.IWorkDao;

public class InfoService implements IInfoService {
    
    private IInfoDao infoDao; 
    public IInfoDao getInfoDao() {
        return infoDao;
    }
    public void setInfoDao(IInfoDao infoDao) {
        this.infoDao = infoDao;
    }
    public IWorkDao getWorkdao() {
        return workdao;
    }
    public void setWorkdao(IWorkDao workdao) {
        this.workdao = workdao;
    }
    private IWorkDao workdao;
    public void delete(String code) {
        
        infoDao.delete(code);
        workdao.deleteInfocode(code);
        
    }

}
復制代碼

XML配置文件

復制代碼
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:tx="http://www.springframework.org/schema/tx"
    default-autowire="byName"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd">
        
        <!-- 引入db.properties文件 -->
        <context:property-placeholder location="classpath:db.properties"/>
        <!-- 生成連接池 -->
        <bean class="com.mchange.v2.c3p0.ComboPooledDataSource" id="dataSource">
            <property name="driverClass" value="${driverClass}"></property>
            <property name="jdbcUrl" value="${jdbcUrl}"></property>
            <property name="user" value="${user}"></property>
            <property name="password" value="${password}"></property>
            <property name="minPoolSize" value="${minPoolSize}"></property>
            <property name="maxPoolSize" value="${maxPoolSize}"></property>
            <property name="initialPoolSize" value="${initialPoolSize}"></property>
        </bean>
        <!-- 生成JdbcTemplate -->
        <bean class="org.springframework.jdbc.core.JdbcTemplate" id="j">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        <!-- 配置實體類 -->
        <bean class="com.itnba.maya.daoimp.InfoDao" id="infoDao">
            <property name="j" ref="j"></property>
        </bean>    
        <bean class="com.itnba.maya.daoimp.WorkDao" id="workDao">
            <property name="j" ref="j"></property>
        </bean>
            <bean class="com.itnba.maya.daoimp.InfoService" id="service">
            <property name="infoDao" ref="infoDao"></property>
            <property name="workdao" ref="workDao"></property>
        </bean>
        
        
        <!-- 配置事務管理器 -->
        <bean class="org.springframework.jdbc.datasource.DataSourceTransactionManager" id="transactionManager">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        <tx:advice id="advice"     transaction-manager="transactionManager">
            <tx:attributes>
                <tx:method name="*" propagation="REQUIRED"/><!-- *是對所有方法都加 -->
            </tx:attributes>
        </tx:advice>
        <!-- 用切點把事務切進去 -->
        <aop:config>
            <aop:pointcut expression="execution(* com.itnba.maya.daoimp..*.*(..))" id="pointcut"/>
            <aop:advisor advice-ref="advice" pointcut-ref="pointcut"/>
        </aop:config>
        
</beans>
復制代碼

mian函數測試事務有沒有生效:

復制代碼
package com.itnba.maya.daoimp;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.itnba.maya.dao.IInfoService;

public class Test {
    private static ApplicationContext context=null;

    private static IInfoService infoservice=null;

    
    
    static{
        context=new ClassPathXmlApplicationContext("beans.xml");
        infoservice=(IInfoService) context.getBean("service");
        
    }
    
    public static void main(String[] args) {
        
        infoservice.delete("p008");


    }

}
復制代碼

結果除0錯誤,數據回滾,數據庫並沒有刪除。說明配置的事務生效了。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM