Spring声明式事务管理
声明式事务管理 收藏
我们一下说的都是spring 整合hibernate的事物配置。
Spring2.0及以后的版本中声明式事务有两种风格的配置：使用基于XML文件和基于注解式的声明式事务配置方法。具体参见
Spring2.0及以后的版本中声明式事务的配置与之前的版本有相当大的不同。主要差异在于不再需要配置TransactionProxyFactoryBean了。
Spring2.0之前的旧版本风格的配置仍然是有效的；你可以简单地认为新的
Spring2.0之前的旧版本风格的配置示例如下：
//applicationContext.xml
rop>
an>
对于特定的方法或方法命名模式，代理的具体事务行为由事务属性驱动，如下面的例子所示：
ROPAGATION_REQUIRED, ISOLATION_READ_COMMITTED
key属性确定代理应该给哪个方法增加事务行为。这样的属性最重要的部份是传播行为。有以下选项可供使用：
PROPAGATION_REQUIRED--支持当前事务，如果当前没有事务，就新建一个事务。这是最常见的选择。
PROPAGATION_SUPPORTS--支持当前事务，如果当前没有事务，就以非事务方式执行。
PROPAGATION_MANDATORY--支持当前事务，如果当前没有事务，就抛出异常。
PROPAGATION_REQUIRES_NEW--新建事务，如果当前存在事务，把当前事务挂起。
PROPAGATION_NOT_SUPPORTED--以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。
PROPAGATION_NEVER--以非事务方式执行，如果当前存在事务，则抛出异常。
PROPAGATION_NESTED--如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则进行与PROPAGATION_REQUIRED类似的操作。
前六个策略类似于EJB CMT，第七个（PROPAGATION_NESTED）是Spring所提供的一个特殊变量。
它要求事务管理器或者使用JDBC 3.0 Savepoint API提供嵌套事务行为（如Spring的DataSourceTransactionManager）。
事务属性中的readOnly标志表示对应的事务应该被最优化为只读事务。这是一个最优化提示。在一些情况下，一些事务策略能够起到显著的最优化效果，
例如在使用Object/Relational映射工具（如：Hibernate或TopLink）时避免dirty checking（试图“刷新”）。
在事务属性中还有定义“timeout”值的选项，指定事务超时为几秒。在JTA中，这将被简单地传递到J2EE服务器的事务协调程序，并据此得到相应的解释。
------------------------------------------------------------------
Spring的事务管理是通过AOP代理实现的。其中的事务通知由元数据（目前基于XML或注解）驱动。代理对象与事务元数据结合产生了一个AOP代理，
它使用一个PlatformTransactionManager的实现配合TransactionInterceptor，在方法调用前后实施事务。spring使用aop机制管理jdbc的连接和事务。
它使用TransactionInterceptor类，Spring事务支持中的核心接口是org.springframework.transaction.PlatformTransactionManager。
为了实际执行事务，Spring所有的事务划分功能都通过传递适当的TransactionDefinition实例，委托给 PlatformTransactionManager。
尽管PlatformTransactionManager接口可以直接使用，应用程序通常配置具体的事务管理器并使用声明性事务来划分事务。Spring具有多种
PlatformTransactionManager实现，它们分为两类：
局部事务策略即针对单个资源执行事务（主要是针对单个的数据库）。实现有 org.springframework.jdbc.datasource.DataSourc
eTransactionManager。
它用于jdbc数据源的配置，调用TransactionInterceptor开启一个事务,从DataSource得到一个connection并确保auto-commit设为false。
他用JdbcTemplate在一个线程内绑定一个JDBC connection，TransactionInterceptor负责提交事务，DataSourceTransactionManager
调用https://www.wendangku.net/doc/112183612.html,mit()关闭connection,并解除绑定（potentially allowing for one thread connection per data source）。
例如:
transactionAttributesSource 属性指定每个方法的transaction attribute，PROPAGATION_REQUIRED说明在一个事务内这个方法被执行。
和EJB一样，默认的情况下，spring只有当unchecked exception被抛出时，才rollback事务，也可以自己加入checked exception。
tatanTransactionScripts被TransactionInterceptor封装，在一个事物内执行类的每一个方法。
全局事务管理即执行有可能跨越多个资源的全局事务。主要对应的Spring类是org.springframework.transaction.jta.JtaTransactionManager，它委托给遵循JTA规范的J2EE服务器，也有例外。
spring支持JTA，只需要一个标准的JtaTransactionManager定义，数据库必须支持XA protocol，或者J2EE服务器提供支持XA规范的DataSource。
默认的Spring JtaTransactionManager设置将从标准的JNDI位置获取JTA的 https://www.wendangku.net/doc/112183612.html,erTransaction对象，该JNDI位置由J2EE指定：java: comp/UserTransaction。对于大多数标准J2EE环境下的用例来说，它工作良好。
但是，默认的 JtaTransactionManager不能执行事务挂起操作(即它不支持PROPAGATION_REQUIRES_NEW和 PROPAGATION_NOT_S
UPPORTED)。原因是标准的JTA UserTransaction接口不支持挂起或恢复事务的操作；它只支持开始和完成新事务的操作。
为执行事务挂起操作，还需要提供javax.transaction.TransactionManager实例，按照JTA的规定，它提供标准的挂起和恢复方法。遗憾的是，J2EE没有为JTA TransactionManager定义标准的JNDI位置！
因此，必须使用特定于供应商的(vendor-specific)查寻机制。J2EE没有考虑把JTA TransactionManager接口作为它的公开API的一部分。JTA规范规定的TransactionManager接口原本是打算用于容器集成的。
但是为JTA TransactionManager定义标准的JNDI位置还是有重大意义的，尤其是对于轻量级容器（如Spring）；然后，便可以以同样的方式来定位任意的J2EE服务器的JTA TransactionManager。
结合jboss JTA的Spring事务划分
oracle-ds.xml
name="jboss.jca:service=OracleXAExceptionFormatter">
jboss:service=TransactionManager
spring配置
Spring有效地将DAO实现从实际的运行时环境中分离出来，允许在J2EE容器之外轻松地测试或重用用。
Spring提供了多种事务策略，比如JtaTransactionManager和JDBC DataSourceTransactionManager，
前者委托给J2EE服务器的事务协调程序，后者则针对单个JDBC DataSource（即单个的目标数据库）执行事务。
通过对后端配置进行简单的更改，就能够轻松地调整事务策略适应另一个环境。
--------------------------------------------------------------
Spring事务抽象的关键是事务策略的概念。这个概念由org.springframework.transaction.PlatformTransactionManager接口定义如下：
public interface PlatformTransactionManager {
TransactionStatus getTransaction(TransactionDefinition definition)
throws TransactionException;
void commit(TransactionStatus status) throws TransactionException;
void rollback(TransactionStatus status) throws TransactionException;
}
这首先是一个SPI接口，虽然它也可以在 编程 中使用。注意按照Spring框架的哲学，PlatformTransactionManager 是一个 接口。
因而如果需要它可以很容易地被模拟和桩化。它也没有和一个查找策略如JNDI捆绑在一起：PlatformTransactionManager 的实现定义
和其他Spring IoC容器中的对象一样。这个好处使得即使使用JTA，也是一个很有价值的抽象：事务代码可以比直接使用JTA更加容易测试。
继续Spring哲学，可由任何 PlatformTransactionManager 的接口方法抛出的 TransactionException 是unchecked exception
（继承自https://www.wendangku.net/doc/112183612.html,ng.RuntimeException）的。底层的事务失败几乎总是致命的。很少情况下应用程序代码可以从它们中恢复，不过应用开发
者依然可以捕获并处理TransactionException，他们可以自由决定怎么干。getTransaction(..)方法根据一个类型为 TransactionDefinition
的参数返回一个 TransactionStatus 对象。返回的 TransactionStatus 对象可能代表一个新的或已经存在的事务（如果在当前调用堆栈有一个
符合条件的事务。如同J2EE事务环境，一个 TransactionStatus 也是和执行 线程 绑定的）。
TransactionDefinition接口指定：
事务隔离：当前事务和其它事务的隔离的程度。例如，这个事务能否看到其他事务未提交的写数据？
事务传播：通常在一个事务中执行的所有代码都会在这个事务中运行。但是，如果一个事务上下文已经存在，有几个选项可以指定一个事务性方法的执行行为：
例如，简单地在现有的事务中继续运行（大多数情况）；或者挂起现有事务，创建一个新的事务。Spring提供EJB CMT中常见的事务传播选项。
事务超时: 事务在超时前能运行多久（自动被底层的事务基础设施回滚）。
只读状态: 只读事务不修改任何数据。只读事务在某些情况下（例如当使用Hibernate时），是一种非常有用的优化。
这些设置反映了标准概念。如果需要，请查阅讨论事务隔离层次和其他核心事务概念的资源：理解这些概念在使用Spring框架和其他事务管理解决方案时是非常关键的。
TransactionStatus 接口为处理事务的代码提供一个简单的控制事务执行和查询事务状态的方法。这个概念应该是熟悉的，因为它们在所有的事务API中是相同的:
public interface TransactionStatus {
boolean isNewTransaction();
void setRollbackOnly();
boolean isRollbackOnly();
}
使用Spring时，无论你选择编程式还是声明式的事务管理，定义一个正确的 PlatformTransactionManager 实现都是至关重要的。按照Spring的良好风格，
这种重要定义都是通过IoC实现的。一般来说，选择PlatformTransactionManager实现时需要知道当前的工作环境，如(1)JDBC、(2)JTA、(3)Hibernate等。
(1)下面的例子来自Spring示例应用——jPetStore——中的dataAccessContext-local.xml文件，其中展示了一个局部PlatformTransactionManager实现
是怎么定义的（仅限于纯粹JDBC环境）我们必须先定义一个JDBC DataSource，然后使用Spring的DataSourceTransactionManager，并传入指向DataSource的引用。
PlatformTransactionManager bean的定义如下：
在dao中如下示例：
public class BigAmountRuleHibernateDAO extends BaseDaoHibernate implements BigAmountRuleDAO{
private JdbcTemplate jdbcTemplate;
/**
* jdbcTemplate根查询列表数据
*/
public List findListByJdbcTemplate(String sql,String[] args){
List list = null;
if(args != null)
list=jdbcTemplate.queryForList(sql, args);
else
list=jdbcTemplate.queryForList(sql);
return list;
}
public JdbcTemplate getJdbcTemplate() {
return jdbcTemplate;
}
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
}
(2)如果我们在J2EE容器里使用JTA，就像示例中 'dataAccessContext-jta.xml' 文件所示，我们将通过JNDI和Spring的 JtaTransactionManager 来获取一个容
器管理的 DataSource。JtaTransactionManager 不需要知道 DataSource 和其他特定的资源，因为它将使用容器提供的全局事务管理。
xmlns:jee="https://www.wendangku.net/doc/112183612.html,/schema/jee"
xsi:schemaLocation="
https://www.wendangku.net/doc/112183612.html,/schema/beans https://www.wendangku.net/doc/112183612.html,/schema/beans/spring-beans-2.0.xsd
https://www.wendangku.net/doc/112183612.html,/schema/jee https://www.wendangku.net/doc/112183612.html,/schema/jee/spring-jee-2.0.xsd">
注意
上面 'dataSource' 的bean定义使用了 'jee' 名称空间下的
关于
(3)我们也可以很容易地使用Hibernate局部事务，就像下面的Spring框架的 PetClinic 示例应用中的例子一样）。这种情况下，我们需要定义一个Hibernate的
LocalSessionFactoryBean，应用程序从中获取到Hibernate Session 实例。DataSource 的bean定义同上例类似（这里不再展示）。不过，
如果是一个JEE容器提供的 DataSource，它将由JEE容器自身，而不是Spring框架来管理事务。这种情况中'txManager' bean的类型为 HibernateTransactionManager。
同样地，DataSourceTransactionManager 需要一个指向 DataSource 的引用，而 HibernateTransactionManager 需要一个指向 SessionFactory 的引用。
hibernate.dialect=${hibernate.dialect}
使用getHibernateTemplate()示例：
public class BigAmountRuleHibernate extends BaseDaoHibernate implements BigAmountRuleDAO{
public void saveOrUpdateEntity(Object obj){
this.getHibernateTemplate().save(obj);
}
}
我们可以简单地使用 JtaTransactionManager 来处理Hibernate事务和JTA事务，就像我们处理JDBC，或者任何其它的资源策略一样。
注意任何资源的JTA配置都是这样的，因为它们都是全局事务，可以支持任何事务性资源。
在所有这些情况下，应用程序代码根本不需要做任何改动。我们仅仅通过改变配置就可以改变事务管理方式，即使这些更改是在局部事务和全局事务间切换。
--------------------------------------------------------------
先提出一个问题：spring是否能mixed JDBC和ORM
下面以具体示例来说明事物执行的来龙去脉。
配置：jdk6.o + spring2.5.6 + hibernate2
先看一段代码：
Connection conn = Conn.getConnection();
conn.setAutoCommit(false);
……..
……...
conn.rollback();
https://www.wendangku.net/doc/112183612.html,mit();
因此我们要明确一个事实：数据库的事务是针对 Connection 的。
接下来是具体的配置。
// applicationContext.xml
xmlns:aop="https://www.wendangku.net/doc/112183612.html,/schema/aop"
xmlns:jee="https://www.wendangku.net/doc/112183612.html,/schema/jee"
xmlns:tx="https://www.wendangku.net/doc/112183612.html,/schema/tx"
xsi:sch
emaLocation="https://www.wendangku.net/doc/112183612.html,/schema/beans https://www.wendangku.net/doc/112183612.html,/schema/beans/spring-beans-2.0.xsd
https://www.wendangku.net/doc/112183612.html,/schema/aop https://www.wendangku.net/doc/112183612.html,/schema/aop/spring-aop-2.0.xsd
https://www.wendangku.net/doc/112183612.html,/schema/tx https://www.wendangku.net/doc/112183612.html,/schema/tx/spring-tx-2.0.xsd
https://www.wendangku.net/doc/112183612.html,/schema/jee https://www.wendangku.net/doc/112183612.html,/schema/jee/spring-jee-2.0.xsd">
org.hibernate.dialect.DB2Dialect
true
org.hibernate.cache.EhCacheProvider
classpath:/com/hiaward/xbankmibs/cpc/dao/model
classpath:/com/hiaward/xbankmibs/dao/journal/model
classpath:/com/hiaward/xbankmibs/dao/taskmanager/model
classpath:/com/hiaward/xbankmibs/dao/service/model
classpath:/com/hiaward/xbankmibs/dao/security/model
classpath:/com/hiaward/xbankmibs/message/model
classpath:/com/hiaward/xbankmibs/dao/daily/model
classpath:/com/hiaward/xbankmibs/dao/accountIgt/model
classpath:/com/hiaward/xbankmibs/dao/cardmade/model
classpath:/com/hiaward/xbankmibs/dao/scenarioservice/model
classpath:/com/hiaward/xbankmibs/dao/pay/model
org.hibernate.dialect.DB2Dialect
true
org.hibernate.cache.EhCacheProvider
classpath:/com/hiaward/xbankmibs/dao/journal/model
org.hibernate.dialect.DB2Dialect
org.hibernate.cache.EhCacheProvider
false
org.hibernate.cache.EhCacheProvider
// Service:BigAmountRuleServiceImpl.java
@SuppressWarnings("unchecked")
@Transactional
public class BigAmountRuleServiceImpl implements BigAmountRuleService{
protected final Log log = LogFactory.getLog(getClass());
private BigAmountRuleDAO bigAmountRuleDAO;
/**
* 查询条数
* @param scenarioCode
* @param orgCode
* @param accountType
* @param currencyCode
* @return
*/
@Transactional (readOnly=false, isolation = Isolation.READ_COMMITTED)
public int getTransRegisterCount(String scenarioCode,String orgCode,String accountType,String currencyCode){
List
if(scenarioCode != null || orgCode != null || accountType != null || currencyCode != null){
String[] scenarioCodeArr = scenarioCode != null?scenarioCode.split(","):null;
String[] orgCodeArr = orgCode != null?orgCode.split(","):null;
String[] accountArr = accountType!=null?accountType.split(","):null;
String[] currencyArr = currencyCode!=null?currencyCode.spl
it(","):null;
objTempList = new ArrayList
objTempList.add(0,scenarioCodeArr);
objTempList.add(1,orgCodeArr);
objTempList.add(2,accountArr);
objTempList.add(3,currencyArr);
}
int iCount = bigAmountRuleDAO.getTotalCount(objTempList); // 使用了jdbcTemplate
return iCount;
}
/**
*
* @param scenarioCode
* @param orgCode
* @param accountType
* @param currencyCode
* @return
*/
@Transactional (readOnly=false, isolation = Isolation.READ_COMMITTED)
public Map
List
if(scenarioCode != null || orgCode != null || accountType != null || currencyCode != null){
String[] scenarioCodeArr = scenarioCode != null?scenarioCode.split(","):null;
String[] orgCodeArr = orgCode != null?orgCode.split(","):null;
String[] accountArr = accountType!=null?accountType.split(","):null;
String[] currencyArr = currencyCode!=null?currencyCode.split(","):null;
objTempList = new ArrayList
objTempList.add(0,scenarioCodeArr);
objTempList.add(1,orgCodeArr);
objTempList.add(2,accountArr);
objTempList.add(3,currencyArr);
}
Map
return this.getHibernateTemplate().executeFind(new HibernateCallback() {
public Object doInHibernate(Session session) throws SQLException,
HibernateException {
List vehicleList = null;
Query q = session.createQuery(sql);
q.setFirstResult(currentPage);
q.setMaxResults(pageSize);
vehicleList = q.list();
return vehicleList;
}
});
*/
return map;
}
@Transactional (readOnly=false, isolation = Isolation.READ_COMMITTED)
public int getRecordCountBySql(String sql){
return bigAmountRuleDAO.getListCount(sql);
}
public BigAmountRuleDAO getBigAmountRuleDAO() {
return bigAmountRuleDAO;
}
public void setBigAmountRuleDAO(BigAmountRuleDAO bigAmountRuleDAO) {
this.bigAmountRuleDAO = bigAmountRuleDAO;
}
}
//DAO:BigAmountRuleHibernate.java
@SuppressWarnings("unchecked")
public class BigAmountRuleHibernate extends BaseDaoHibernate implements BigAmountRuleDAO{
private JdbcTemplate jdbcTemplate;
public JdbcTemplate getJdbcTemplate() {
return jdbcTemplate;
}
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public void saveOrUpdateEntity(Object obj){
this.getHibernateTemplate().save(obj);
}
public void deleteEntity(
Object obj){
this.getHibernateTemplate().delete(obj);
}
/**
* jdbcTemplate根查询列表数据
*/
public List findListByJdbcTemplate(String sql,String[] args){
List list = null;
if(args != null)
list=jdbcTemplate.queryForList(sql, args);
else
list=jdbcTemplate.queryForList(sql);
return list;
}
public List findList(String sql,String[] args){
return jdbcTemplate.queryForList(sql, args);
}
public Object getEntityByCondition(){
return null;
}
/**
* 新增和修改映射和大额核实规则信息
*/
public String saveByList(List
int iRef = 0;
int iAchk = 0;
Session session = this.getHibernateTemplate().getSessionFactory().openSession();
try{
Transaction tx = session.beginTransaction();
for(int i=0;i
String[] arr = strArr.split(",");
//新增前查看当前币种的规则是否已经存在
String blnExistRuleSql = "select ref.rscerefcode from Rsceref ref,Amountcheck chk where ref.ruletype='11' and ref.rulecode = chk.bmcrcode and chk.monetarycategory=? and ref.scenariocode=? and https://www.wendangku.net/doc/112183612.html,code=?";
List
//新增到规则
Amountcheck chkObj = new Amountcheck();
chkObj.setAccountcategory(arr[2]);
chkObj.setMonetarycategory(arr[3]);
chkObj.setMonetary(Double.valueOf(arr[4]));
chkObj.setOperator(arr[5]);
chkObj.setUpdatedatetime(new Date());
this.getHibernateTemplate().save(chkObj);
iAchk++;
//新增映射
if(listExistRuleSql != null && listExistRuleSql.size() > 0){//更新映射引用的规则ID
String updateSql = "update Rsceref ref set ref.rulecode = ? where ref.rscerefcode = ?";
getHibernateTemplate().bulkUpdate(updateSql, new Object[]{chkObj.getBmcrcode(),listExistRuleSql.get(0)});
}
else{//当前币种对应的规则映射表中没有 直接新增
Rsceref refObj = new Rsceref();
refObj.setScenariocode(arr[0]);
refObj.setOrgcode(arr[1]);
refObj.setRulecode(chkObj.getBmcrcode());
refObj.setRuletype("11");
this.getHibernateTemplate().save(refObj);
iRef++;
}
}
https://www.wendangku.net/doc/112183612.html,mit();
}catch(Exception e){
throw new Exception(e);
}finally{
if(session != null)
session.close();
}
return iRef+","+iAchk;
}
/**
* 批量删除
*/
public int deleteByList(List
StringBuffer sql = new StringBuffer();
sql.append("from Rsceref ref where");
sql.append(" ruletype = '11' and (");
for(int i=0;i
String[] arr = strArr.split(",");
//删除映射表
sql.append("(ref.scenariocode='").append(arr[0]);
sql.append("' and https://www.wendangku.net/doc/112183612.html,code='").append(arr[1]).append("' and ref.rulecode in");
sql.append("(select chk.bmcrcode from Amountcheck chk wh
ere chk.accountcategory='").append(arr[2]);
sql.append("' and chk.monetarycategory='").append(arr[3]).append("')) or");
}
String str = sql.substring(0, sql.length()-2);
str = str+")";
int iCount = Integer.parseInt(this.getHibernateTemplate().find("select count(*) "+str).get(0).toString());
this.getHibernateTemplate().bulkUpdate("delete "+str);
return iCount;
}
/**
* 根据多选删除
* @param args
*/
public void deleteBySelect(String[] args){
StringBuffer strId = new StringBuffer();
strId.append("delete from Rsceref where ruletype = '11' and rscerefcode in");
for(int i=0;i
strId.append("(");
strId.append(args[i]);
}
else{
strId.append(",");
strId.append(args[i]);
}
}
strId.append(")");
jdbcTemplate.execute(strId.toString());
}
/**
* 查询记录
*/
public Map
Map
List listR = new ArrayList();
StringBuffer sql=new StringBuffer();
sql.append("from Rsceref ref,Amountcheck chk where ref.rulecode = chk.bmcrcode and ref.ruletype='11'");
if(list != null && list.size()>0){
String[] scenarioCodeArr = list.get(0);
String[] orgCodeArr = list.get(1);
String[] accountArr = list.get(2);
String[] currencyArr = list.get(3);
if(scenarioCodeArr!=null && orgCodeArr != null && accountArr != null && currencyArr != null){
sql.append(" and (");
for(int i=0;i
sql.append(scenarioCodeArr[i]);
sql.append("'");
sql.append(" and https://www.wendangku.net/doc/112183612.html,code='");
sql.append(orgCodeArr[j]);
sql.append("'");
sql.append(" and chk.accountcategory='");
sql.append(accountArr[k]);
sql.append("'");
sql.append(" and chk.monetarycategory='");
sql.append(currencyArr[m]);
sql.append("') or ");
}
}
}
}
sql = new StringBuffer(sql.substring(0, https://www.wendangku.net/doc/112183612.html,stIndexOf("or")));
sql.append(")");
}
else if(scenarioCodeArr!=null && orgCodeArr != null && accountArr != null){
sql.append(" and (");
for(int i=0;i
sql.append(scenarioCodeArr[i]);
sql.append("'");
sql.append(" and https://www.wendangku.net/doc/112183612.html,code='");
sql.append(orgCodeArr[j]);
sql.append("'");
sql.append(" and chk.accountcategory='");
sql.append(accountArr[k]);
sql.append("') or ");
}
}
}
sql = new StringBuffe
r(sql.substring(0, https://www.wendangku.net/doc/112183612.html,stIndexOf("or")));
sql.append(")");
}
}
sql.append(" order by ref.scenariocode,https://www.wendangku.net/doc/112183612.html,code,chk.accountcategory,chk.monetarycategory");
listR = findPage(sql.toString(),pStart,size);
List
Map
List listName = this.getHibernateTemplate().find("select strscenarionum,strscenarioname from Scenario");
for(int i=0;i
mapName.put(obj[0].toString(), obj[1].toString());
}
for(int i=0;i
Rsceref refObj = (Rsceref)obj[0];
Amountcheck chk = (Amountcheck)obj[1];
chk.setRscerefcode(refObj.getRscerefcode());
System.out.println(refObj.getScenariocode());
chk.setScenarioName(mapName.get(refObj.getScenariocode()));
chk.setScenarioCode(refObj.getScenariocode());
chk.setOrgCode(refObj.getOrgcode());
chk.setStrMonetary(NumberUtil.getNormalStyle(chk.getMonetary(), 2));
listEntity.add(chk);
}
map.put("listEntity", listEntity);
map.put("bigAmounChecktSql", sql.toString());
return map;
}
/**
* 分页方法
*/
public List findPage(final String sql, final int currentPage,final int pageSize) {
return this.getHibernateTemplate().executeFind(new HibernateCallback() {
public Object doInHibernate(Session session) throws SQLException,
HibernateException {
List vehicleList = null;
Query q = session.createQuery(sql);
q.setFirstResult(currentPage);
q.setMaxResults(pageSize);
vehicleList = q.list();
return vehicleList;
}
});
}
}
以action -> service -> dao 这种调用路径执行时，因为通过@Transactional我们把连接点（joinpoint）加入到service层，所以
在调用service的方法如getTransRegisterCount()还未进入时，就会调用TransactionInterceptor开启一个事务，进入
Cglib2AopProxy$CglibMethodInvocation(ReflectiveMethodInvocation).proceed(),如下
代码1.
public Object proceed() throws Throwable {
// We start with an index of -1 and increment early.
//interceptorsAndDynamicMethodMatchers中包含[org.springframework.transaction.interceptor.TransactionInterceptor@1b53927]
if (this.currentInterceptorIndex == this.interceptorsAndDynamicMethodMatchers.size() - 1) {
return invokeJoinpoint();
}
Object interceptorOrInterceptionAdvice =
this.interceptorsAndDynamicMethodMatchers.get(++this.currentInterceptorIndex);
if (interceptorOrInterceptionAdvice instanceof InterceptorAndDynamicMethodMatcher) {
// Evaluate dynamic method matcher here: static part will already have
// been evaluated and found to match.
InterceptorAndDynamicMethodMatcher dm =
(InterceptorAndDynamicMethodMatcher) interceptorOrInterceptionAdvice;
if (dm.methodMatcher.matches(this.method, this.targetClass, this.a
rguments)) {
return dm.interceptor.invoke(this);
}
else {
// Dynamic matching failed.
// Skip this interceptor and invoke the next in the chain.
return proceed();
}
}//与切入点匹配，调用匹配成功的方法，因为我们是对所有service的public方法开启事物，以这里为例就是
else {
// It's an interceptor, so we just invoke it: The pointcut will have
// been evaluated statically before this object was constructed.
// 调用interceptor:TransactionInterceptor.java 的invoke() ，见代码2.
return ((MethodInterceptor) interceptorOrInterceptionAdvice).invoke(this);
}
}
代码2.
// TransactionTnterceptor.java
public Object invoke(final MethodInvocation invocation) throws Throwable {
// Work out the target class: may be null.
// The TransactionAttributeSource should be passed the target class
// as well as the method, which may be from an interface.
// 这里对应的是你的service：BigAmountRuleServiceImpl
Class targetClass = (invocation.getThis() != null ? invocation.getThis().getClass() : null);
// If the transaction attribute is null, the method is non-transactional.
final TransactionAttribute txAttr =
getTransactionAttributeSource().getTransactionAttribute(invocation.getMethod(), targetClass);
final String joinpointIdentification = methodIdentification(invocation.getMethod());
if (txAttr == null || !(getTransactionManager() instanceof CallbackPreferringPlatformTransactionManager)) {
// Standard transaction demarcation with getTransaction and commit/rollback calls.
// TransactionInfo 中拥有TransactionAttribute，TransactionStatus引用，TransactionStatus（DefaultTransactionStatus）中拥有Object transaction。
// 创建事物，txAttr包含隔离级别、传播行为、是否只读。joinpointIdentification = com.hiaward.xbankmibs.cpc.service.impl.BigAmountRuleServiceImpl.getRecordCountBySql
// 见代码3.
TransactionInfo txInfo = createTransactionIfNecessary(txAttr, joinpointIdentification);
Object retVal = null;
try {
// This is an around advice: Invoke the next interceptor in the chain.
// This will normally result in a target object being invoked.
/*
* 执行代码1.的
*
* if (this.currentInterceptorIndex == this.interceptorsAndDynamicMethodMatchers.size() - 1) {
* return invokeJoinpoint();
* }
* 执行代码代码15.
*
* 之后调用service的方法,这里是getRecordCountBySql(String sql)，在执行DAO的方法。
* public int getListCount(String sql){
*
* return this.getHibernateTemplate().find(sql).size();
*
* }
* 见代码10.
*/
retVal = invocation.proceed();
}
catch (Throwable ex) {
// target invocation exception
completeTransactionAfterThrowing(txInfo, ex);
throw ex;
}
finally {
cleanupTransactionInfo(txInfo); // Reset the
TransactionInfo ThreadLocal.
}
// 刷新、提交、关闭connection。见代码16. 这样整个流程跑完了。
commitTransactionAfterReturning(txInfo);
return retVal;
}
else {
// It's a CallbackPreferringPlatformTransactionManager: pass a TransactionCallback in.
try {
Object result = ((CallbackPreferringPlatformTransactionManager) getTransactionManager()).execute(txAttr,
new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
TransactionInfo txInfo = prepareTransactionInfo(txAttr, joinpointIdentification, status);
try {
return invocation.proceed();
}
catch (Throwable ex) {
if (txAttr.rollbackOn(ex)) {
// A RuntimeException: will lead to a rollback.
if (ex instanceof RuntimeException) {
throw (RuntimeException) ex;
}
else {
throw new ThrowableHolderException(ex);
}
}
else {
// A normal return value: will lead to a commit.
return new ThrowableHolder(ex);
}
}
finally {
cleanupTransactionInfo(txInfo);
}
}
});
// Check result: It might indicate a Throwable to rethrow.
if (result instanceof ThrowableHolder) {
throw ((ThrowableHolder) result).getThrowable();
}
else {
return result;
}
}
catch (ThrowableHolderException ex) {
throw ex.getCause();
}
}
}
代码3. TransactionAspectSupport.java
/**
* Create a transaction if necessary based on the given TransactionAttribute.
*
Allows callers to perform custom TransactionAttribute lookups through
* the TransactionAttributeSource.
* @param txAttr the TransactionAttribute (may be null)
* @param joinpointIdentification the fully qualified method name
* (used for monitoring and logging purposes)
* @return a TransactionInfo object, whether or not a transaction was created.
* The hasTransaction() method on TransactionInfo can be used to
* tell if there was a transaction created.
* @see #getTransactionAttributeSource()
*/
protected TransactionInfo createTransactionIfNecessary(TransactionAttribute txAttr, final String joinpointIdentification) {
// If no name specified, apply method identification as transaction name.
// 如果事物没有指定名字，则把方法标识作为事物名。
if (txAttr != null && txAttr.getName() == null) {
txAttr = new DelegatingTransactionAttribute(txAttr) {
public String getName() {
return joinpointIdentification;
}
};
}
TransactionStatus status = null;
if (txAttr != null) {
// Return the transaction manager.这里是org.springframework.orm.hibernate3.HibernateTransactionManager
PlatformTransactionManager tm = getTransactionManager();
if (tm != null) {
// 得到事物状态对
象（newTransactionStatus(definition, null, true, newSynchronization, debugEnabled, null);））
// 见代码4.
status = tm.getTransaction(txAttr);
}
else {
if (logger.isDebugEnabled()) {
logger.debug("Skipping transactional joinpoint [" + joinpointIdentification +
"] because no transaction manager has been configured");
}
}
}
return prepareTransactionInfo(txAttr, joinpointIdentification, status);
}
代码4.
/**
* This implementation handles propagation behavior. Delegates to
* doGetTransaction, isExistingTransaction
* and doBegin.
* @see #doGetTransaction
* @see #isExistingTransaction
* @see #doBegin
*/
public final TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException {
// 返回DataSourceTransactionObject 对象txObject，并txObject.setConnectionHolder(conHolder, false)，
// conHolder可能是null（如果TransactionSynchronizationManager的ThreadLocal resources 中不存在这个ConnectionHolder）。
// 见代码5.
Object transaction = doGetTransaction();
// Cache debug flag to avoid repeated checks.
boolean debugEnabled = logger.isDebugEnabled();
//interface TransactionAttribute extends TransactionDefinition
if (definition == null) {
// Use defaults if no transaction definition given.
definition = new DefaultTransactionDefinition();
}
//transaction.getConnectionHolder() != null && transaction.getConnectionHolder().isTransactionActive()
if (isExistingTransaction(transaction)) {
// Existing transaction found -> check propagation behavior to find out how to behave.
return handleExistingTransaction(definition, transaction, debugEnabled);
}
// Check definition settings for new transaction.
if (definition.getTimeout() < TransactionDefinition.TIMEOUT_DEFAULT) {
throw new InvalidTimeoutException("Invalid transaction timeout", definition.getTimeout());
}
// No existing transaction found -> check propagation behavior to find out how to proceed.
if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_MANDATORY) {
throw new IllegalTransactionStateException(
"No existing transaction found for transaction marked with propagation 'mandatory'");
}
else if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRED ||
definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRES_NEW ||
definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_NESTED) {
SuspendedResourcesHolder suspendedResources = suspend(null);
if (debugEnabled) {
logger.debug("Creating new transaction with name [" + definition.getName() + "]: " + definition);
}
try {
// 设置事物（DataSourceTransactionObject）对象txObject的属性，如isolation level（隔离级别），
// 绑定Conn
ectionHolder和SessionHolder到TransactionSynchronizationManager的ThreadLocal resources 中。
// 见代码6.事物开启。
doBegin(transaction, definition);
}
catch (RuntimeException ex) {
resume(null, suspendedResources);
throw ex;
}
catch (Error err) {
resume(null, suspendedResources);
throw err;
}
boolean newSynchronization = (getTransactionSynchronization() != SYNCHRONIZATION_NEVER);
// Create a new TransactionStatus（DefaultTransactionStatus ，其中包含transaction属性） for the given arguments ，
// initializing transaction synchronization as appropriate(TransactionSynchronizationManager的ThreadLocal 变量).
return newTransactionStatus(definition, transaction, true, newSynchronization, debugEnabled, suspendedResources);
}
else {
// Create "empty" transaction: no actual transaction, but potentially synchronization.
boolean newSynchronization = (getTransactionSynchronization() == SYNCHRONIZATION_ALWAYS);
return newTransactionStatus(definition, null, true, newSynchronization, debugEnabled, null);
}
}
代码5.
/**
* 返回一个事物对象HibernateTransactionObject，并对其sessionHolder、connectionHolder属性赋值。
*
*/
protected Object doGetTransaction() {
HibernateTransactionObject txObject = new HibernateTransactionObject();
txObject.setSavepointAllowed(isNestedTransactionAllowed());
// 从（当前线程绑定的）变量resource中查找是否存在(用来装载Session的)SessionHolder，
// 这个变量resource由TransactionSynchronizationManager来维护。如果存在则放到线程对象txObject中。
SessionHolder sessionHolder = (SessionHolder) TransactionSynchronizationManager.getResource(getSessionFactory());
if (sessionHolder != null) {
if (logger.isDebugEnabled()) {
logger.debug("Found thread-bound Session [" + SessionFactoryUtils.toString(sessionHolder.getSession()) + "] for Hibernate transaction");
}
txObject.setSessionHolder(sessionHolder);
}
else if (this.hibernateManagedSession) {
try {
Session session = getSessionFactory().getCurrentSession();
if (logger.isDebugEnabled()) {
logger.debug("Found Hibernate-managed Session [" + SessionFactoryUtils.toString(session) + "] for Spring-managed transaction");
}
txObject.setExistingSession(session);
}
catch (HibernateException ex) {
throw new DataAccessResourceFailureException( "Could not obtain Hibernate-managed Session for Spring-managed transaction", ex);
}
}
if (getDataSource() != null) {
// 从（当前线程绑定的）变量resource中查找是否存在(用来装载Connection的)ConnectionHolder，
// 这个变量resource由TransactionSynchronizationManager来维护。如果存在则放到线程对象txObject中。
ConnectionHolder conHolder = (ConnectionHolder)TransactionSynchronizationManager.getResource(getDataSource());
txObject.setConnectionHolder(conHolder);
}
return txObject;
}
代码6.
protected void doBegin(Object transaction, TransactionDefinition definition) {
HibernateTransactionObject txObject = (HibernateTransactionObject) transaction;
if (txObject.hasConnectionHolder() && !txObject.getConnectionHolder().isSynchronizedWithTransaction()) {
throw new IllegalTransactionStateException(
"Pre-bound JDBC Connection found! HibernateTransactionManager does not support " +
"running within DataSourceTransactionManager if told to manage the DataSource itself. " +
"It is recommended to use a single HibernateTransactionManager for all transactions " +
"on a single DataSource, no matter whether Hibernate or JDBC access.");
}
Session session = null;
try {
if (txObject.getSessionHolder() == null || txObject.getSessionHolder().isSynchronizedWithTransaction()) {
Interceptor entityInterceptor = getEntityInterceptor();
// getSessionFactory().openSession() 见代码7.
Session newSession = (entityInterceptor != null ?
getSessionFactory().openSession(entityInterceptor) : getSessionFactory().openSession());
if (logger.isDebugEnabled()) {
logger.debug("Opened new Session [" + SessionFactoryUtils.toString(newSession) +
"] for Hibernate transaction");
}
// 把事物对象session属性赋值。这里Session对象的connection = null
txObject.setSession(newSession);
}
session = txObject.getSessionHolder().getSession();
if (this.prepareConnection && isSameConnectionForEntireSession(session)) {
// We're allowed to change the transaction settings of the JDBC Connection.
if (logger.isDebugEnabled()) {
logger.debug(
"Preparing JDBC Connection of Hibernate Session [" + SessionFactoryUtils.toString(session) + "]");
}
// 从Session中建立连接，见代码8.
Connection con = session.connection();
// 根据条件是否执行con.setReadOnly(true),con.setTransactionIsolation(definition.getIsolationLevel())。然后返回previousIsolationLevel。
Integer previousIsolationLevel = DataSourceUtils.prepareConnectionForTransaction(con, definition);
txObject.setPreviousIsolationLevel(previousIsolationLevel);
}
else {
// Not allowed to change the transaction settings of the JDBC Connection.
if (definition.getIsolationLevel() != TransactionDefinition.ISOLATION_DEFAULT) {
// We should set a specific isolation level but are not allowed to...
throw new InvalidIsolationLevelException(
"HibernateTransactionManager is not allowed to support custom isolation levels: " +
"make sure that its 'prepareConnection' flag is on (the default) and that the " +
"Hibernate connection release mode is set to 'on_close' (SpringTransactionFactory's default). " +
"Make sure that your LocalSessionFactoryBean actually uses SpringTransactionFactory: Your " +
- Spring事务配置的五种方式
- spring事务
- Spring事务管理注解开发
- Spring的声明式事务示例 2
- spring使用基于注解的AOP事务管理
- Spring事务管理及与mybatis整合的事务管理
- spring,mybatis事务管理配置与@Transactional注解使用[转]
- spring事务配置详解
- Spring事务管理
- Spring的声明式事务
- spring的@Transactional注解详细用法
- DataSourceTransactionManager编程式事务管理
- MyBatis-Spring-TransactionManager事务管理
- Spring事务管理抽象
- spring事务管理
- spring编程式事务与声明式事务详解
- 在spring中如何配代码的事务管理
- 第5章 Spring的事务管理
- spring事务锁
- spring 如何管理事务的