1. 程式人生 > >第十一講:11.spring宣告式事務管理-xml方式

第十一講:11.spring宣告式事務管理-xml方式

1,複製專案spring404 ,改名spring404-2,修改BankServiceImpl類,刪除宣告式事務的程式碼。宣告式事務管理的方式缺點是,事務程式碼嚴重嵌入邏輯程式碼中
package com.cruise.service.impl;

import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

import com.cruise.dao.BankDao;
import com.cruise.service.BankService;

public class BankServiceImpl implements BankService{

       private BankDao bankDao;
      
       public void setBankDao(BankDao bankDao) {
              this.bankDao = bankDao;
       }
      
       @Override
       public void transferAccount(int money, int userA, int userB) {
             
                            bankDao.OutMoney(money, userA);
                            bankDao.InMoney(money, userB);
       }
}
2,修改beans.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:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context"

    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop

        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/context    
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/tx 
        http://www.springframework.org/schema/tx/spring-tx.xsd">

<context:property-placeholder location="jdbc.properties"/>

<bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driverClassName}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
</bean>

<!--jdbc事物管理器-->
<bean id="transactionManager1"class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource1"></property>
</bean>

<tx:advice id="txAdvice1" transaction-manager="transactionManager1">
    <tx:attributes>
       <tx:method name="*"/>
    </tx:attributes>
</tx:advice>
<aop:config>
    <aop:pointcut id="serviceMethod1" expression="execution(* com.cruise.service.*.*(..))"/>
    <aop:advisor advice-ref="txAdvice1" pointcut-ref="serviceMethod1"/>
</aop:config>


<bean id="namedParameterJdbcTemplate1"class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
        <constructor-arg ref="dataSource1"></constructor-arg>
</bean>

<bean id="bankDao1" class="com.cruise.dao.impl.BankDaoImpl">
    <property name="namedParameterJdbcTemplate" ref="namedParameterJdbcTemplate1"></property>
</bean>

<bean id="bankService" class="com.cruise.service.impl.BankServiceImpl">
    <property name="bankDao" ref="bankDao1"></property>
</bean>

</beans>

3,BankDaoImpl程式碼
package com.cruise.dao.impl;

import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;

import com.cruise.dao.BankDao;

public class BankDaoImpl implements BankDao{

    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
   
    public void setNamedParameterJdbcTemplate(NamedParameterJdbcTemplate namedParameterJdbcTemplate) {
       this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
    }

    @Override
    public void InMoney(int money, int userid) {
       System.out.println(1/0);
       String sql ="update t_account set balance=balance+:money where id=:userid";
       MapSqlParameterSource msps= new MapSqlParameterSource();
       msps.addValue("money", money);
       msps.addValue("userid", userid);
       namedParameterJdbcTemplate.update(sql, msps);
      
    }

    @Override
    public void OutMoney(int money, int userid) {
       String sql ="update t_account set balance=balance-:money where id=:userid";
       MapSqlParameterSource msps= new MapSqlParameterSource();
       msps.addValue("money", money);
       msps.addValue("userid", userid);
       namedParameterJdbcTemplate.update(sql, msps);
    }
}

4,測試程式碼
package com.cruise.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.cruise.service.BankService;

public class T {
    public static void main(String[] args) {
       ClassPathXmlApplicationContext CPXAC=new ClassPathXmlApplicationContext("beans.xml");
       BankService  bankService = (BankService) CPXAC.getBean("bankService");
       bankService.transferAccount(120, 1, 2);
    }
}