JPA事务总结 jpa事务配置

原文摘自:JPA数据库持久层开发实践

作者:冯曼菲

事务管理是JPA中另一项重要的内容,了解了JPA中的事务管理,能够进一步掌握JPA的使用。事务管理是对一系列操作的管理,它最终只有两个结果,要么成功,要么失败。一旦失败,所有的操作将回滚到初始状态。一旦成功,才最终提交,最终持久化。事务管理对银行系统最为典型。例如一个人去银行取款,他取款的钱此时大于银行账户中的钱,此时交易失败,所以取款不成功,事务回滚到操作前的状态。

在JPA中,对于实体的“CRUD”基本操作,其中涉及事务的是“C”、“U”和“D”,即“新建”、“更新”和“删除”,因为这些操作都会影响数据库中的数据变化,所以必须使用事务保证其一致性;对于“R”查询,只是查询数据,没有对数据产生变化,所以并不需要控制事务。

所以,一说到事务,读者首先应确定所使用的操作是否需要关联事务,先要界定事务所有效使用的范围。

11.4.1 事务与EntityManager

EntityManager对象的事务管理方式有两种,分别为JTA和RESOURCE_LOCAL,即Java Transaction API方法和本地的事务管理。

JPA中的事务类型通过persistence.xml文件中的“transaction-type”元素配置。例如,配置事务为JTA方式的代码如下所示。

<persistence>

<persistence-unit name="demo"transaction-type="JTA">

//其他配置省略

</persistence-unit>

</persistence>

如果使用RESOURCE_LOCAL管理事务,则配置代码如下所示。

<persistence>

<persistence-unit name="demo"transaction-type="RESOURCE_LOCAL">

//其他配置省略

</persistence-unit>

</persistence>

除了在配置文件时指明了事务的类型,不同的事务类型,不同类型的EntityManager对象,在代码中控制事务也是不同的。表11-2为不同的运行环境、不同的EntityManager对象所支持的事务类型。

表11-2 事务类型与EntityManager

运行环境

类型

J2EE环 境

J2SE环 境

EJB容 器

Web容 器

应用托管的EntityManager

JTA,RESOURCE_LOCAL

JTA,RESOURCE_LOCAL

RESOURCE_LOCAL

容器托管的EntityManager

JTA

不支持

不支持

从表11-2中可以看出,对于不同的EntityManager类型与所运行的环境,所支持的事务类型是不一样的。

其中两种情况下最为简单,一种是容器托管的EntityManager只能运行在EJB容器中,只能采用JTA的方式管理事务;另一种是J2SE环境下,只能使用应用托管的EntityManager并且只能采用RESOURCE_LOCAL的方式管理事务。本节的事务只针对这两种情况讲述,而对于应用托管的EntityManager在EJB容器和Web容器中由于都可以选择不同的事务管理方式,情况比较复杂,所以将在第11.5节中详细讲述。

11.4.2 JTA管理事务

JTA事务(Java TransactionAPI)是J2EE规范中有关事务的标准。它是容器级别的事务,只能运行在J2EE服务器中。它的最大优势是可以支持分布式的事务,如果系统采用的是分布式的数据库,那么只能选择JTA管理EntityManager事务。

使用JTA管理EntityManager事务时,需要注意以下几个问题。

—JTA事务只能运行在J2EE的环境中,即EJB容器中和Web容器中;而在J2SE环境中只能使用RESOURCE_LOCAL管理事务。

—容器托管的EntityManager对象只能采用JTA的事务,而不能采用RESOURCE_LOCAL事务。

在第11.3节中,已经简单了解了一些JTA事务与EntityManager之间的关系,但当Bean的方法中又调用了另一个Bean的方法时,那么此时事务传播(Propagation)是如何进行的?下面就深入了解事务的传播与持久化上下文的关系。

有这样一个记录日志的会话Bean,它负责记录相关的日志信息等,它有一个记录日志的方法recordLog,代码如下所示。

@Stateless

public class LogService implements ILogService {

@PersistenceContext(unitName = "jpaUnit")

private EntityManager entityManager;

/**记录日志*/

public void recordLog(Integer id, String reason) {

LogEO log = new LogEO();

log.setId(id);

log.setReason(reason);

entityManager.persist(log);

}

}

此时在CustomerService的会话Bean中,addCustomer方法中需要新建客户后,再调用日志组件来记录日志信息,代码如下所示。

@Stateless

public class CustomerService implements ICustomerService {

@PersistenceContext(unitName = "jpaUnit")

private EntityManager entityManager;

@EJB

private ILogService logService ;

public CustomerEO addCustomer(CustomerEO customer) {

entityManager.persist(customer);

logService.recordLog(customer.getId(),"新建Customer");

return customer;

}

}

此时EntityManager对象是容器托管的,并且设置的事务类型为JPA。下面仔细分析一下,当在一个EJB组件中调用另外一个EJB组件时,事务的传播与持久化上下文环境的关系。

—当客户端调用addCustomer方法时,此时容器自动关联一个JTA的事务,一个事务开始,这里将该事务记为事务A。

—当调用persist方法持久化客户时,EntityManager对象发现当前有一个JTA的事务A,则此时将EntityManager对象的事务附加到JTA的事务A中,并且创建了一个新的持久化上下文。

—调用日志组件的recordLog方法,容器发现调用了另外一个EJB的方法,所以首先检查当前是否存在事务,由于当前状态下存在事务A,所以将recordLog方法的事务附加到事务A中(由于默认情况下,CustomerService的事务类型是REQUIRED)。

—当进入recordLog方法时,再次调用persist方法持久化日志时,由于此时EntityManager对象的事务是附加到JTA事务A中的,所以仍与之前调用的persist方法时所在的持久化上下文相同,所以,可以直接调用持久化客户后的customer.getId(),来获得持久化客户的Id值。虽然在一个EJB组件中调用了另外一个EJB组件的方法,但两次调用的persist方法所在的持久化上下文是相同的。

—recordLog方法结束,又回到addCustomer方法中,此时事务A提交,一个持久化上下文也就随之结束了。

11.4.3 RESOURCE_LOCAL管理事务

RESOURCE_LOCAL事务数据库本地的事务。它是数据库级别的事务,只能针对一种数据库,不支持分布式的事务。对于中小型的应用,可以采用RESOURCE_LOCAL管理EntityManager事务。

使用RESOURCE_LOCAL管理EntityManager事务时需要注意以下几个问题。

—在J2SE环境中,只能使用RESOURCE_LOCAL管理EntityManager事务,并且EntityManager对象是以应用托管方式获得的。

—代码中使用RESOURCE_LOCAL管理事务时,要通过调用EntityManager的getTransac-tion()方法获得本地事务对象。

例如,在J2SE环境中,使用RESOURCE_LOCAL管理EntityManager事务的代码如下所示。

public class CustomerClient {

public static void main(String[] args) {

EntityManagerFactory emf = Persistence

.createEntityManagerFactory("jpaUnit");

EntityManager entityManager =emf.createEntityManager();

try {

/** 事务开始 */

entityManager.getTransaction().begin();

CustomerEO customer = new CustomerEO();

customer.setName("Janet");

customer.setEmail("janetvsfei@yahoo.com.cn");

customer.setAsset(100000.00);

/** 事务提交 */

entityManager.getTransaction().commit();

} finally {

entityManager.close();

emf.close();

}

}

}

★ 提示 ★

采用RESOURCE_LOCAL管理事务时,要保证数据库支持事务。例如使用MySQL时,需要设置数据库的引擎类型为“InnoDB”,而“MyISAM”类型是不支持事务的。

—在代码中,entityManager.getTransaction()方法获得本地事务EntityTransaction对象,然后通过该对象提供的方法来控制本地的事务。有关EntityTransaction的API将在下一节讲述。

—控制本地事务时,开始一个新事务,使用begin()方法;事务完成后,使用commit()方法提交。控制事务时,并没有调用rollback()方法回滚,这是因为在事务开始后,一旦有异常抛出,EntityTransaction对象将自动回滚,所以并不需要显式地调用rollback()方法回滚。

11.4.4 EntityTransactionAPI

下面来看本地事务EntityTransaction中所定义的方法EntityTransaction API,以及它们的作用,如下所示。

EntityTransaction API

package javax.persistence;

public interface EntityTransaction {

public void begin();

public void commit();

JPA事务总结 jpa事务配置
public void rollback();

public void setRollbackOnly();

public boolean getRollbackOnly();

public boolean isActive();

}

下面具体来看各个方法所表示的意义,每个方法都从作用、方法参数、异常信息,以及返回值这几个方面来讲述。

— public void begin()

作用:声明事务开始。

方法参数:无。

异常信息:如果此时事务处于激活状态,即isActive()为true,将抛出IllegalStateException异常。

返回值:无返回值。

— public void commit()

作用:提交事务,事务所涉及的数据的更新将全部同步到数据库中。

方法参数:无。

异常信息:如果此时事务处于未激活状态,即isActive()为false,将抛出IllegalState Exception异常;如果此时提交不成功,则抛出RollbackException异常。

返回值:无返回值。

— public void rollback()

作用:事务回滚。

方法参数:无。

异常信息:如果此时事务处于未激活状态,即isActive()为false,将抛出IllegalState Exception异常;如果此时回滚失败,则抛出PersistenceException异常。

返回值:无返回值。

— public void setRollbackOnly()

作用:设置当前的事务只能是回滚状态。

方法参数:无。

异常信息:如果此时事务处于未激活状态,即isActive()为false,将抛出IllegalState Exception异常。

返回值:无返回值。

— public boolean getRollbackOnly()

作用:获得当前事务的回滚状态。

方法参数:无。

异常信息:如果此时事务处于未激活状态,即isActive()为false,将抛出IllegalState Exception异常。

返回值:true表示只能回滚状态。

— public boolean isActive ()

作用:判断当前事务是否处于激活状态。

方法参数:无。

异常信息:如果发生了未知的异常,将抛出PersistenceException异常。

返回值:true表示当前事务处于激活状态,false表示当前事务未处于激活状态。

11.5应用托管的EntityManager的持久化上下文

通过表11-2所总结的各种情况,应用托管EntityManager对象在EJB容器中和Web容器中,可选择的事务类型比较复杂,既可以支持JTA,又可以支持RESOURCE_LOCAL。下面讲述在这两种情况下,如何控制事务。

11.5.1无状态的会话Bean与JTA事务(事务范围)

在会话Bean里以注入的方式获得EntityManagerFactory对象,不需要负责它的关闭,所以此时,只需要控制EntityManager的打开和关闭。当客户端每次调用Bean中的方法时,都首先创建EntityManager对象,然后在方法结束前关闭EntityManager对象。EntityManager对象的事务使用的是容器自动管理的事务JTA。

代码如下所示。

@Stateless

public class CustomerService implements ICustomerService {

@PersistenceUnit(unitName="jpaUnit")

private EntityManagerFactory emf;

public CustomerEO findCustomerById(Integer customerId){

EntityManager em = emf.createEntityManager();

CustomerEO customer = em.find(CustomerEO.class,customerId);

em.close();

return customer;

}

public void placeOrder(Integer customerId, OrderEOorder) {

EntityManager em = emf.createEntityManager();

CustomerEO customer = em.find(CustomerEO.class,customerId);

customer.getOrders().add(order);

em.merge(customer);

em.close();

}

}

11.5.2无状态的会话Bean与JTA事务(扩展范围)

与上个会话Bean中的管理方式不同,此时EntityManager对象为Bean的属性,当Bean初始化后,也就是标注@PostConstruct方法后,创建EntityManager对象;当Bean销毁前,也就是标注@PreDestroy方法后,关闭EntityManager对象,所以EntityManager对象是整个的Bean的声明周期中。当客户端调用需要关联事务的方法时,需要使用joinTransaction()方法合并到上一次的事务中。

代码如下所示。

@Stateless

public class CustomerService implements ICustomerService {

@PersistenceUnit(unitName="jpaUnit")

private EntityManagerFactory emf;

private EntityManager em;

@PostConstruct

public void init (){

em = emf.createEntityManager();

}

public CustomerEO findCustomerById(Integer customerId){

/**查询不需要关联事务*/

CustomerEO customer = em.find(CustomerEO.class,customerId);

em.clear();

return customer;

}

public void placeOrder(Integer customerId, OrderEOorder) {

/**

*EntityManager 对象的作用范围是这个Bean的生命周期

*所以,每次使用时要合并到上一次的事务中

*/

em.joinTransaction();

CustomerEO customer = em.find(CustomerEO.class,customerId);

customer.getOrders().add(order);

em.merge(customer);

/**

* 手动脱离当前事务和持久化上下文

*/

em.flush();

em.clear();

}

@PreDestroy

public void destroy(){

em.close();

}

}

11.5.3 有状态的会话Bean与JTA事务

同样是EntityManager对象在整个的Bean的声明周期中,但由于会话Bean此时是有状态的Bean,所以当客户端调用任何方法时,都处在同一个持久化上下文中。所以每次并不需要调用clear()方法来手动地脱离当前的上下文,但每次客户端的调用仍需要使用joinTransaction()方法合并到上一次的事务中。

代码如下所示。

@Stateful

public class CustomerService implements ICustomerService {

@PersistenceUnit(unitName="jpaUnit")

private EntityManagerFactory emf;

private EntityManager em;

private CustomerEO customer ;

@PostConstruct

public void init (){

em = emf.createEntityManager();

}

public CustomerEO findCustomerById(Integer customerId){

customer = em.find(CustomerEO.class, customerId);

return customer;

}

public void placeOrder(Integer customerId, OrderEOorder) {

em.joinTransaction();

customer.getOrders().add(order);

}

@Remove

public void destroy(){

em.close();

}

}

11.5.4 RESOURCE_LOCAL事务

前面三节的例子讲述的是JTA事务,当在J2SE环境中,必须采用RESOURCE_LOCAL事务,而且需要手动创建和关闭EntityManagerFactory、EntityManager对象。关联事务时要使用EntityManager对象的getTransaction().begin()和getTransaction().commit()方法。

代码如下所示。

public class CustomerService {

private EntityManagerFactory emf;

private EntityManager em;

public CustomerService (){

emf =Persistence.createEntityManagerFactory("jpaUnit");

em = emf.createEntityManager();

}

private CustomerEO customer ;

public CustomerEO findCustomerById(Integer customerId){

customer = em.find(CustomerEO.class, customerId);

return customer;

}

public void placeOrder(Integer customerId, OrderEOorder) {

em.getTransaction().begin();

customer.getOrders().add(order);

em.getTransaction().commit();

}

public void destroy(){

em.close();

emf.close();

}

}

  

爱华网本文地址 » http://www.413yy.cn/a/25101011/54724.html

更多阅读

TransactionScope和分布式事务 transactionscope使用

分布式事务听起来很不错,其实不然。它只是尽可能的降低数据不一致的可能性,并不能完全避免。从我的应用中来看,总数约5千万的操作,错了十几个。当然,这个错误率完全可以忍受了。不能忍受的是当你的DB在cluster(集群)当中,msdtc也会被作为一

第三章常用事务类文书写作 纪检监察常用文书写作

第三章常用事务类文书写作第一节常用事务文书概述第二节 计划和总结第三节 调查报告第四节公示、启示、海报教学目的要求:了解调查报告、计划、总结及各类规章制度的涵义;理解调查报告的特点;掌握调查报告、计划、总结及各类规章

spring事务隔离级别 spring事务的传播属性

都是概念性的东西,最后spring事务传播级别几个参数讲解还有点用,就直接摘抄了。事务的四个属性:原子性(atomicity)、一致性(consistency)、隔离性(isolation)和持久性(durability)。1.原子性(Atomic)最重要的原则,也是最容易理解的原则。被事务

Spring+Hibernate+JPA常见小问题 spring mvc 常见问题

1、jpa包的冲突2、事务不正常执行3、Cannot proxy target class because CGLIB2 is not available1、jpa包的冲突运行 jpa 程序,却出现:Caused by: java.lang.NoSuchMethodError: javax.persistence.spi.PersistenceUnitInfo.getValid

声明:《JPA事务总结 jpa事务配置》为网友夏至春掩分享!如侵犯到您的合法权益请联系我们删除