spring hibernate 集成:spring使用容器JTA事务管理器
说明:1.EJB的事务是方法级别的隔离,而spring的拦截事务是类级别的,所以spring管理的jta事务在同一个类的不同方法设置不同的事务传播策略是无效的。2.使用了spring的事务,就不能显示地使用hibernate的开启事务,提交事务等,spring通过拦截器自动实现这些操作。正文开始:spring hibernate 集成,hibernate操作多个数据库需要
说明:
1.EJB的事务是方法级别的隔离,而spring的拦截事务是类级别的,所以spring管理的jta事务在同一个类的不同方法设置不同的事务传播策略是无效的。
2.使用了spring的事务,就不能显示地使用hibernate的开启事务,提交事务等,spring通过拦截器自动实现这些操作。
正文开始:
spring hibernate 集成,hibernate操作多个数据库需要 jta 事务管理器,spring提供了对容器jta事务管理器的支持,同时hibernate也提供了对容器jta事务管理器的支持,注意两者不能同时使用,只能选择其一来管理事务,如果要使用spring则可以通过配置事务代理或者拦截器的方式实现,如果要使用hibernate则可以配置session工厂使用jta事务管理器同事编码过程中要显示开启事务/提交或回滚事务,显然使用spring管理事务更加优越:1.声明式事务管理,对代码无侵入;2.拦截器使用aop的方式,可以批量对多个业务服务bean植入事务支持,下面是一个完整的使用spring管理事务的例子:
项目的pom文件:
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<parent>
<artifactId>eden</artifactId>
<groupId>com.conquer.eden</groupId>
<version>1.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>springtx</artifactId>
<packaging>war</packaging>
<name>springtx</name>
<properties>
<springVersion>2.0.1</springVersion>
</properties>
<dependencies>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.transaction</groupId>
<artifactId>javax.transaction-api</artifactId>
<version>1.2</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
<version>2.0.1</version>
</dependency>
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate</artifactId>
<version>3.1.3</version>
<exclusions>
<exclusion>
<groupId>javax.transaction</groupId>
<artifactId>jta</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<build>
<finalName>springtx</finalName>
</build>
</project>
注意这里:由于web层没有使用spring管理,所以这里没有配置spring的请求转发器,所以需要手工使用spring的api来初始化spring容器,web.xml代码:
<!DOCTYPE web-app PUBLIC
"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
"http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
<servlet>
<servlet-name>test</servlet-name>
<servlet-class>com.test.TestServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>test</servlet-name>
<url-pattern>/test</url-pattern>
</servlet-mapping>
</web-app>
Servlet代码:
package com.test;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
public class TestServlet extends HttpServlet {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String data = req.getParameter("data");
if (data == null) data = "00000";
try {
SpringTest.testSpring(data);
PrintWriter writer = resp.getWriter();
writer.println("ok, check the console output ...");
writer.flush();
} catch (Exception e) {
throw new ServletException(e);
}
}
}
下面是spring事务测试的入口,由于没有使用spring管理web,故在这里进行spring容器的初始化:
package com.test;
import com.test.service.Service1;
import com.test.service.Service2;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class SpringTest {
private static Service1 service1;
private static Service2 service2;
static {
/**
* 测试使用:
* 保证实例是在spring的管理范围内,即在spring的IOC容器中,在spring mvc 的 web 架构中,我们不需要这样显示写出来,注入是自动的
* 这里因为我们的 测试 Servlet 没有被spring 管理,也就不能触发spring的注入机制,所以这里使用编程的方式测试。
*/
// 使用 代理bean方式 支持事务
// ApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"spring/*.xml", "spring/tx/tx_proxy.xml"});
// 使用 拦截bean方法方式(拦截器) 支持事务
ApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"spring/*.xml", "spring/tx/tx_interceptor.xml"});
//直接引用,会导致事务不起作用,必需使用spring的事务代理类,注意:使用拦截器时使用这个,不需要改变,拦截器的实现会自动改变内存里的实现
//拦截器是推荐使用的事务支持方式,好处:
// 一:不需要使用新的代理bean(不用担心引用错误造成事务无效)
// 二:可以批量配置bean的事务属性(避免事务bean的配置膨胀)
service1 = (Service1) context.getBean("service1");
service2 = (Service2) context.getBean("service2");
//使用spring的事务代理类,可使用事务支持
// service1 = (Service1) context.getBean("myTxProxy1");
// service2 = (Service2) context.getBean("myTxProxy2");
}
public static void testSpring(String data) {
service1.twoTX(data);
}
}
好了,现在看下spring需要的配置文件:
base.xml:引用容器提供的jndi资源,主要是数据源和JTA事务管理器
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!--通过JNDI查找的对象,最终会强制转为为需要的类型,如这个会强转为 TransactionManager-->
<bean id="twJtaTm" class="org.springframework.jndi.JndiObjectFactoryBean">
<!--tw6-->
<property name="jndiName" value="java:appserver/TransactionManager"/>
<!--twe5-->
<!--<property name="jndiName" value="java:internal/TransactionManager"/>-->
<!--jboss-->
<!--<property name="jndiName" value="java:/TransactionManager"/>-->
<!--weblogic-->
<!--<property name="jndiName" value="javax.transaction.TransactionManager"/>-->
<!--<property name="resourceRef" value="true" />TODO-->
</bean>
<!--通过JNDI查找的对象,最终会强制转为为需要的类型,如这个会强转为 DataSource-->
<bean id="myDataSource1" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="DataSource1"/>
<!--<property name="resourceRef" value="true" />TODO-->
</bean>
<!--通过JNDI查找的对象,最终会强制转为为需要的类型,如这个会强转为 DataSource-->
<bean id="myDataSource2" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="DataSource1"/>
<!--<property name="resourceRef" value="true" />TODO-->
</bean>
</beans>
business_beans.xml:业务bean的配置文件:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!-- 以下是具体业务相关 -->
<!--业务类,需要事务配置的类,特别注意,业务中不要直接使用此实例,而应该使用其事务代理:basicTxProxy -->
<!-- NOTE:非嵌入式的,命名的,此目标业务 bean 可被直接引用,直接引用将导致 无事务,所以应该使用代理事务bean的引用或使用事务拦截器来处理-->
<bean id="baseDAO" abstract="true">
<property name="sessionFactory1" ref="sessionFactory1"/>
<property name="sessionFactory2" ref="sessionFactory2"/>
</bean>
<!--如果使用代理,直接引用这里的bean会导致事务失效,应该引用其代理,而且事务应该加在 服务层(service)-->
<bean id="dao1" parent="baseDAO" class="com.test.dao.impl.DAOImpl1"/>
<bean id="dao2" parent="baseDAO" class="com.test.dao.impl.DAOImpl2"/>
<!--事务应该加在 服务层(service):如果使用代理,直接引用这里的bean会导致事务失效,应该引用其代理-->
<bean id="service1" class="com.test.service.impl.Service1Impl">
<property name="dao1" ref="dao1"/>
<property name="dao2" ref="dao2"/>
<!--如果使用代理,直接引用这里的bean会导致事务失效,应该引用其代理,但是,如果使用的事务拦截器,这里不需要变动,拦截器会自动改掉内存里的实现-->
<property name="service2" ref="service2"/>
<!--引用事务代理代理,不使用拦截器时使用这个-->
<!--<property name="service2" ref="myTxProxy2"/>-->
</bean>
<bean id="service2" class="com.test.service.impl.Service2Impl">
<property name="dao2" ref="dao2"/>
</bean>
</beans>
hibernate.xml:hibernate session工厂的配置
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!--spring 对 hibernate的支持,用于创建 hibernate的SessionFactory-->
<bean id="sessionFactory1" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="hibernateProperties">
<value>
<!--这里填写hibernate特定属性,注意不要在这里写 hibernate.transaction.factory_class 和 jta.UserTransaction,因为事务需要交给spring管理
这里写了,只会对代码调用 org.hibernate.Session#getTransaction()方法起效,对于spring配置的事务策略无效,使用spring的事务会忽略此设置
-->
hibernate.dialect=org.hibernate.dialect.OracleDialect
hibernate.show_sql=true
</value>
</property>
<!--配置hibernate的映射文件,这里配置的是整个 hbm 文件夹下的文件-->
<property name="mappingDirectoryLocations">
<list>
<value>
classpath*:/hbm/
</value>
</list>
</property>
<!--JNDI 查找到的 myDataSource1 是DataSource类型的,所以可以在这里注入-->
<property name="dataSource" ref="myDataSource1"/>
<!--JNDI 查找到的 twJtaTm 是TransactionManager类型的,所以可以在这里注入 TODO-->
<!--<property name="jtaTransactionManager" ref="twJtaTm"/>-->
</bean>
<!--spring 对 hibernate的支持,用于创建 hibernate的SessionFactory-->
<bean id="sessionFactory2" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="hibernateProperties">
<value>
<!--这里填写hibernate特定属性,注意不要在这里写 hibernate.transaction.factory_class 和 jta.UserTransaction,因为事务需要交给spring管理
这里写了,只会对代码调用 org.hibernate.Session#getTransaction()方法起效,对于spring配置的事务策略无效,使用spring的事务会忽略此设置
-->
hibernate.dialect=org.hibernate.dialect.OracleDialect
hibernate.show_sql=true
</value>
</property>
<!--配置hibernate的映射文件,这里配置的是指定的文件-->
<property name="mappingResources">
<list>
<value>hbm/Student.hbm.xml</value>
<value>hbm/Teacher.hbm.xml</value>
</list>
</property>
<!--JNDI 查找到的 myDataSource2 是DataSource类型的,所以可以在这里注入-->
<property name="dataSource" ref="myDataSource2"/>
<!--JNDI 查找到的 twJtaTm 是TransactionManager类型的,所以可以在这里注入 TODO-->
<!--<property name="jtaTransactionManager" ref="twJtaTm"/>-->
</bean>
</beans>
tx_common.xml:事务公共配置,注意是一些公共bean
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!--
要使用 JTA 事务管理,需要配置 JtaTransactionManager,他需要 TransactionManager 类型的实例,twJtaTm正好是一个
它本身是 PlatformTransactionManager 的实现,可以配合完成 spring 的多种事务配置
-->
<bean id="mySpringTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager" ref="twJtaTm"/>
</bean>
</beans>
下面就是重头戏了,spring有至少两种方式配置事务,代理bean和拦截器,下面是这两种的不同配置文件,实际使用其中一种即可:
tx_proxy.xml:使用代理bean支持事务
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!--设置为 abstract,这样可以通过继承的方式,简化子类的代码,如果没有子类就不初始化-->
<bean id="baseTxProxyBean" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"
abstract="true">
<!--需要的 transactionManager 是 PlatformTransactionManager 类型,所以不能直接注入 twJtaTm,需要使用 JtaTransactionManager 这个实现类,此实现类依赖 twJtaTm -->
<property name="transactionManager" ref="mySpringTransactionManager"/>
<property name="transactionAttributes">
<!--Spring中Propagation类的事务属性详解:
PROPAGATION_REQUIRED:支持当前事务,如果当前没有事务,就新建一个事务。这是最常见的选择。
PROPAGATION_SUPPORTS:支持当前事务,如果当前没有事务,就以非事务方式执行。
PROPAGATION_MANDATORY:支持当前事务,如果当前没有事务,就抛出异常。
PROPAGATION_REQUIRES_NEW:新建事务,如果当前存在事务,把当前事务挂起。
PROPAGATION_NOT_SUPPORTED:以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。
PROPAGATION_NEVER:以非事务方式执行,如果当前存在事务,则抛出异常。
PROPAGATION_NESTED:支持当前事务,如果当前事务存在,则执行一个嵌套事务,如果当前没有事务,就新建一个事务。
-->
<props>
<!--<prop key="*">PROPAGATION_REQUIRED</prop>-->
<prop key="*">PROPAGATION_REQUIRED</prop>
<!--<prop key="testTX">PROPAGATION_REQUIRED</prop>-->
<!--<prop key="insert*">PROPAGATION_REQUIRED</prop>-->
<!--<prop key="*">PROPAGATION_SUPPORTS,readOnly</prop>-->
</props>
</property>
<!--非嵌入式的,命名的,目标业务bean可被直接引用导致无事务-->
<!--<property name="target" ref="springTest"/>-->
<!--嵌入式的,匿名的,避免目标业务bean被直接引用-->
<!--<property name="target">-->
<!--<bean class="com.test.SpringTest"/>-->
<!--</property>-->
</bean>
<!-- 代理对象 -->
<bean id="myTxProxy1" parent="baseTxProxyBean">
<!--非嵌入式的,命名的,目标业务bean可被直接引用导致无事务,所以应该引用此:baseTxProxyBean-->
<property name="target" ref="service1"/>
</bean>
<!-- 代理对象 -->
<bean id="myTxProxy2" parent="baseTxProxyBean">
<property name="transactionAttributes">
<props>
<prop key="twoTX">PROPAGATION_REQUIRES_NEW</prop>
</props>
</property>
<!--非嵌入式的,命名的,目标业务bean可被直接引用导致无事务,所以应该引用此:baseTxProxyBean-->
<property name="target" ref="service2"/>
<!--嵌入式的,匿名的,避免目标业务bean被直接引用-->
<!--<property name="target">-->
<!--<bean parent="baseDAO" class="com.test.dao.impl.DAOServiceImpl"/>-->
<!--</property>-->
</bean>
<!--以上的代理事务,如果业务类较多会出现配置膨胀,即每个需要事务的业务bean都需要配置一次,虽然使用了 继承 ,减少了代码量,但配置膨胀问题还没有解决
从根本上解决就是用使用 拦截器的配置方式,看 tx_interceptor.xml 定义的的拦截器配置事务方式-->
</beans>
tx_interceptor.xml:使用拦截器支持事务:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
"http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<!--tx_proxy.xml中使用的代理事务,如果业务类较多会出现配置膨胀,即每个需要事务的业务bean都需要配置一次,虽然使用了 继承 ,减少了代码量,但配置膨胀问题还没有解决
从根本上解决就是用使用 拦截器的配置方式,看下面的拦截器配置事务方式:利用切面编程思想,自动添加事务支持-->
<!-- 定义事务 -->
<bean id="txInterceptor"
class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager" ref="mySpringTransactionManager" />
<!-- 配置事务属性 -->
<property name="transactionAttributes">
<!--Spring中Propagation类的事务属性详解:
PROPAGATION_REQUIRED:支持当前事务,如果当前没有事务,就新建一个事务。这是最常见的选择。
PROPAGATION_SUPPORTS:支持当前事务,如果当前没有事务,就以非事务方式执行。
PROPAGATION_MANDATORY:支持当前事务,如果当前没有事务,就抛出异常。
PROPAGATION_REQUIRES_NEW:新建事务,如果当前存在事务,把当前事务挂起。
PROPAGATION_NOT_SUPPORTED:以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。
PROPAGATION_NEVER:以非事务方式执行,如果当前存在事务,则抛出异常。
PROPAGATION_NESTED:支持当前事务,如果当前事务存在,则执行一个嵌套事务,如果当前没有事务,就新建一个事务。
-->
<props>
<prop key="*">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>
<bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
<property name="beanNames">
<list>
<!--matches service1 & service2 & service*-->
<value>service*</value>
</list>
</property>
<property name="interceptorNames">
<list>
<value>txInterceptor</value>
</list>
</property>
</bean>
</beans>
由于在上面使用了hibernate,所以需要提供下hibernate的映射文件,连个 hbm 文件:
Student.hbm.xml:
<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="com.test.model">
<class name="Student" table="STUDENT">
<id name="id">
<generator class="uuid"/>
</id>
<property name="name"/>
</class>
</hibernate-mapping>
Teacher.hbm.xml:
<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="com.test.model">
<class name="Teacher" table="TEACHER">
<id name="id">
<generator class="uuid"/>
</id>
<property name="name"/>
</class>
</hibernate-mapping>
注意:以上spring的配置文件都放到类路径的 spring 目录下,hibernate的两个hbm放到类路径的hbm目录下。
好了,到这里就可以看看具体的java代码了,值得说明的是:spring提供的切面编程支持事务的能力,对代码零侵入,使得我们在编码过程中根本不用关心事务功能,编写好的程序最后通过一个简单的AOP事务配置就支持事务,感慨一下spring的魅力,切面编程的魅力吧!!!
dao层代码:此层直接进行数据库操作,不关心业务,不关心事务,为service层提供支持
service层代码:此层用于完成具体的业务单元,一般一个业务单元需要同时进行多项数据库操作,所以往往事务也在这一次加入
controller层代码:此层用于控制业务逻辑的导向,并完成页面(视图层)交互,本示例没有涉及到此层
dao层代码:
package com.test.dao;
public interface DAO2 {
void tx1(String data);
void tx2(String data);
}
package com.test.dao;
public interface DAO1 {
void tx1(String data);
void tx2(String data);
}
package com.test.dao.impl;
import org.hibernate.SessionFactory;
public class BaseDAO {
protected SessionFactory sessionFactory1;
protected SessionFactory sessionFactory2;
public void setSessionFactory1(SessionFactory sessionFactory1) {
this.sessionFactory1 = sessionFactory1;
}
public void setSessionFactory2(SessionFactory sessionFactory2) {
this.sessionFactory2 = sessionFactory2;
}
}
package com.test.dao.impl;
import com.test.dao.DAO1;
import com.test.model.Student;
import com.test.model.Teacher;
import org.hibernate.Query;
import org.hibernate.Session;
import java.util.Date;
import java.util.List;
public class DAOImpl1 extends BaseDAO implements DAO1 {
public void tx1(String data) {
System.out.println("=========第 一 次写数据========");
Session studentSession = sessionFactory1.openSession();
insertStudent(studentSession);
List<Student> students = queryStudent(studentSession);
for (Student u : students) {
System.out.println(u);
}
if (data.equals("1")) throw new RuntimeException("111111111111");
}
public void tx2(String data) {
System.out.println("=========第 二 次写数据========");
Session teacherSession = sessionFactory2.openSession();
insertStudent(teacherSession);
List<Student> students2 = queryStudent(teacherSession);
for (Student u : students2) {
System.out.println(u);
}
if (data.equals("2")) throw new RuntimeException("222222222222");
}
public void insertStudent(Session session) {
Student s = new Student();
s.setName("SpringTest1:" + new Date().toString());
session.save(s);
}
public List<Student> queryStudent(Session session) {
Query query = session.createQuery("from Student");
return query.list();
}
public void insertTeacher(Session session) {
Teacher s = new Teacher();
s.setName(new Date().toString());
session.save(s);
}
public List<Student> queryTeacher(Session session) {
Query query = session.createQuery("from Teacher");
return query.list();
}
}
package com.test.dao.impl;
import com.test.dao.DAO2;
import com.test.model.Student;
import org.hibernate.Query;
import org.hibernate.Session;
import java.util.Date;
import java.util.List;
public class DAOImpl2 extends BaseDAO implements DAO2 {
public void tx1(String data) {
System.out.println("=========第 一 次写数据========");
Session studentSession = sessionFactory1.openSession();
insertStudent(studentSession);
List<Student> students = queryStudent(studentSession);
for (Student u : students) {
System.out.println(u);
}
if (data.equals("3")) throw new RuntimeException("111111111111");
}
public void tx2(String data) {
System.out.println("=========第 二 次写数据========");
Session teacherSession = sessionFactory2.openSession();
insertStudent(teacherSession);
List<Student> students2 = queryStudent(teacherSession);
for (Student u : students2) {
System.out.println(u);
}
if (data.equals("4")) throw new RuntimeException("222222222222");
}
private void insertStudent(Session session) {
Student s = new Student();
s.setName("SpringTest2:" + new Date().toString());
session.save(s);
}
private List<Student> queryStudent(Session session) {
Query query = session.createQuery("from Student");
return query.list();
}
}
service层代码:
package com.test.service;
public interface Service1 {
void twoTX(String data);
}
package com.test.service;
public interface Service2 {
void twoTX(String data);
}
package com.test.service.impl;
import com.test.dao.DAO1;
import com.test.dao.DAO2;
import com.test.service.Service1;
import com.test.service.Service2;
public class Service1Impl implements Service1 {
private DAO1 dao1;
private DAO2 dao2;
private Service2 service2;
public void setDao1(DAO1 dao1) {
this.dao1 = dao1;
}
public void setDao2(DAO2 dao2) {
this.dao2 = dao2;
}
public void setService2(Service2 service2) {
this.service2 = service2;
}
public void twoTX(String data) {
dao1.tx1(data);
dao1.tx2(data);
service2.twoTX(data);
}
}
package com.test.service.impl;
import com.test.dao.DAO1;
import com.test.dao.DAO2;
import com.test.service.Service2;
public class Service2Impl implements Service2 {
private DAO1 dao1;
private DAO2 dao2;
public void setDao1(DAO1 dao1) {
this.dao1 = dao1;
}
public void setDao2(DAO2 dao1) {
this.dao2 = dao1;
}
public void twoTX(String data) {
dao2.tx1(data);
dao2.tx2(data);
}
}
model类:
package com.test.model;
public class Student {
private String id;
private String name;
public String getName() {
return name;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "Student{" +
"id='" + id + '\'' +
", name='" + name + '\'' +
'}';
}
}
package com.test.model;
public class Teacher {
private String id;
private String name;
public String getName() {
return name;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "Teacher{" +
"id='" + id + '\'' +
", name='" + name + '\'' +
'}';
}
}
最后说明:
1.EJB的事务是方法级别的隔离,而spring的拦截事务是类级别的,所以spring管理的jta事务在同一个类的不同方法设置不同的事务传播策略是无效的。
2.使用了spring的事务,就不能显示地使用hibernate的开启事务,提交事务等,spring通过拦截器自动实现这些操作。
更多推荐
所有评论(0)