使用Spring的事务注解管理事务

使用Spring的事务注解管理事务

添加约束

<beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:context="http://www.springframework.org/schema/context"
        xmlns:aop="http://www.springframework.org/schema/aop"
        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/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
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd">

   </beans>

service添加注解

package com.hk.springdao.serviceimpl;

import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.hk.springdao.dao.IAccountDao;
import com.hk.springdao.dao.IStockDao;
import com.hk.springdao.exception.BuyStockException;
import com.hk.springdao.service.IBuyStockService;

public class BuyStockServiceImpl implements IBuyStockService {

private IAccountDao accountDao;
private IStockDao stockDao;

public void setAccountDao(IAccountDao accountDao) {
this.accountDao = accountDao;
    }

public void setStockDao(IStockDao stockDao) {
this.stockDao = stockDao;
    }
@Transactional(isolation=Isolation.DEFAULT,propagation=Propagation.REQUIRED)
@Override
public void openAccount(String aname, double money) {
        accountDao.insertAccount(aname, money);
    }
@Transactional(isolation=Isolation.DEFAULT,propagation=Propagation.REQUIRED)
@Override
public void openStock(String sname, int count) {
        stockDao.insertStock(sname, count);
    }
@Transactional(isolation=Isolation.DEFAULT,propagation=Propagation.REQUIRED,rollbackFor=BuyStockException.class)
@Override
public void buyStock(String aname, double money, String sname, int count) throws BuyStockException{
boolean isBuy = true;
        stockDao.updateStock(sname, count,isBuy);
if(1==1){
throw new BuyStockException("股票没买上，明儿起早");
        }
        accountDao.updateAccount(aname, money,isBuy);

    }

}

完整配置文件

<?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:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
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/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
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd">

<!-- ==================== 数据源的注册 ==========================================-->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name= "driverClass" value="${jdbc.driver}"></property>
<property name="jdbcUrl" value="${jdbc.url}"></property>
<property name="user" value="${jdbc.username}"></property>
<property name="password" value="${jdbc.password}"></property>
</bean>
<!-- 注册jdbc属性文件 方法二需要context约束 -->
<context:property-placeholder location="classpath:jdbc.properties"/>
<!-- ==================== 普通bean的注册 ==========================================-->
<!-- 注册DAO -->
<bean id="accountDao" class="com.hk.springdao.daoimpl.AccountDaoImpl">
<property name="dataSource" ref="dataSource"></property>
</bean>
<bean id="stockDao" class="com.hk.springdao.daoimpl.StockDaoImpl">
<property name="dataSource" ref="dataSource"></property>
</bean>
<!-- 注册Service -->
<bean id="buyStockService" class="com.hk.springdao.serviceimpl.BuyStockServiceImpl">
<property name="accountDao" ref="accountDao"></property>
<property name="stockDao" ref="stockDao"></property>
</bean>
<!-- ==================== 事务 ==========================================-->
<!-- 注册事务管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>
<!-- 注册事务注解驱动-->
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>

项目源码

项目源码：http://pan.baidu.com/s/1gfFsPEj