Spring3配置声明式事务

c#小王子 2022-04-02 615 Java

1. 配置 Spring3 声明式事务

在 Spring3 中配置声明式事务比早期版本显得更加简便。只需要几行配置文件+注解就可

以实现面向切面的 AOP 事务

2. 配置文件

在 Spring 的配置如下

<?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:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/bean
s
http://www.springframework.org/schema/beans/spring-beans-3.0.x
sd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3
.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd"
default-autowire="byName">
<!-- 配置Spring上下文的注解 -->
<context:annotation-config />
<!-- 配置DAO类 -->
<bean id="persondao" class="impl.PersonDAOImpl"> 
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<!-- 事务管理配置 -->
<!-- 配置事务管理开始 -->
<bean id="txManager"
class="org.springframework.orm.hibernate3.HibernateTransaction
Manager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<tx:annotation-driven transaction-manager="txManager" />

在配置文件中并没有出现像以前版本的事务传播和隔离级别，也就是类似如下配置

<!‐‐ 配置事务的传播特性 ‐‐>
<tx:advice id="txAdvice" transaction‐manager="transactionManager">
<tx:attributes>
<tx:method name="add*" propagation="REQUIRED"/>
<tx:method name="del*" propagation="REQUIRED"/>
<tx:method name="modify*" propagation="REQUIRED"/>
<tx:method name="*" read‐only="true"/>
</tx:attributes>
</tx:advice>
因为可以通过注解@Transactional 完成事务传播、事务隔离的功能。
3. DAO 代码
DAO 实现类代码如下
package impl;
import
org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import org.springframework.transaction.annotation.Transactional;
import pojo.Test;
@Transactional
public class PersonDAOImpl extends HibernateDaoSupport implements
PersonDAO {
public void save(Test test) {
this.getHibernateTemplate().saveOrUpdate(test);
Test test2 = new Test();
test2.setId(3);
test2.setName("3");
this.getHibernateTemplate().saveOrUpdate(test2);
throw new RuntimeException("主键重复");
} 
}

使用注解将此 DAO 实现类的所有方法进行了事务拦截，当遇到运行是异常时，事务回滚。

不提交到数据库。

当然可以指定单一原子方法进行隔离，方法可以指定

@Transactional(propagation=Propagation.NOT_SUPPORTED)
@Transactional(propagation=Propagation.MANDATORY)
@Transactional(propagation=Propagation.NESTED)
@Transactional(propagation=Propagation.REQUIRED)
@Transactional(propagation=Propagation.REQUIRES_NEW)
@Transactional(propagation=Propagation.SUPPORTS)

同 JTA 标准的事务隔离传播一样，具体参考

http://suhuanzheng7784877.iteye.com/blog/908382

之后在 Service 层可以进行原子操作的业务整合。

以前是如何在 Spring 中配置事务的

正好也总结一下原来的 AOP 事务

在 Spring2.X 中，仅仅使用 Hibernate 作为持久层方案的配置如下

<?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:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring‐beans‐2.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring‐aop‐2.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring‐tx‐2.0.xsd"
default‐autowire="byName">
<!‐‐连接池‐‐>
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy‐method="close">
<property name="driverClass" value="org.gjt.mm.mysql.Driver">
</property>
<property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/ssh">
</property>
<property name="user" value="root">
</property>
<property name="password" value="">
</property>
<property name="maxPoolSize" value="20">
</property>
<property name="minPoolSize" value="1">
</property>
<property name="initialPoolSize" value="1">
</property>
<property name="maxIdleTime" value="20">
</property>
</bean>
<!‐‐Hibernate 的 sessionFactory‐‐>
<bean id="sessionFactory"class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource"
ref="dataSource">
</property>
<property name="configLocation"
value="classpath:hibernate.cfg.xml">
</property>
</bean>
<!‐‐事务处理‐‐>
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<tx:advice id="txAdvice" transaction‐manager="transactionManager">
<tx:attributes>
<tx:method name="addBbs" rollback‐for="Exception"
read‐only="false" />
<tx:method name="addUser" rollback‐for="Exception"
read‐only="false" />
<tx:method name="addBbsType" rollback‐for="Exception"
read‐only="false" />
<tx:method name="*"/>
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut id="leeService"
expression="execution(* dao.*.*(..))"/>
<aop:advisor advice‐ref="txAdvice"
pointcut‐ref="leeService"/>
</aop:config>
</beans>
在 DAO 实现类中依然使用 Spring 提供的 HibernateDaoSupport .getHibernateTemplate()作
为操作的模板。例如
package dao;
import java.io.Serializable;
import java.math.BigInteger;
import java.util.List;
import java.util.Set;
import org.hibernate.Query;
4 / 6import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
import pojo.Bbs;
import pojo.Rebbs;
public class BbsDaoImpl extends HibernateDaoSupport implements BbsDao {
public String addBbs(Bbs bbs) {
Serializable id = this.getHibernateTemplate().save(bbs);
String idStr = id.toString();
return idStr;
}
public void deleteBbsById(String bbsId) {
Bbs bbs = this.loadBbsByBbsId(bbsId);
this.getHibernateTemplate().delete(bbs);
}
@SuppressWarnings("unchecked")
public List<Bbs> getAllBbs() {
String hql = "FROM Bbs";
List<Bbs> list = null;
//Query query =
this.getHibernateTemplate().getSessionFactory().openSession().createQuery(hql);
list = super.getSession().createQuery(hql).list();
return list;
}
@SuppressWarnings("unchecked")
public int getNumReBbsByBbs() {
String sql = "select count(id) from bbs";
Query query =
this.getHibernateTemplate().getSessionFactory().openSession().createSQLQuery(sql);
List<Object> list = query.list();
Object o = list.get(0);
BigInteger numObject = (BigInteger)o;
int num = numObject.intValue();
return num;
}
public Set<Rebbs> getReBbsByBbsId(String bbsId) {
return this.loadBbsByBbsId(bbsId).getReBbs();
}
public Bbs loadBbsByBbsId(String BbsId) {
Bbs bbs = null;
bbs = (Bbs)this.getHibernateTemplate().get(Bbs.class, BbsId);
//bbs = (Bbs)this.getHibernateTemplate().load(Bbs.class, BbsId);
return bbs;
}
public void updateBbsById(Bbs bbs) {
this.getHibernateTemplate().update(bbs);
} 
}

【下载地址】

百度网盘链接：https://pan.baidu.com/s/1VibeXgnp9VsmB7xq2H-WiQ

提取码：4h8y