[原理][来源解析]spring于@Transactional,Propagation.SUPPORTS,以及 Hibernate Session,以及jdbc Connection关联

一.

1. Spring 怎样处理propagation=Propagation.SUPPORTS?

2. Spring 何时生成HibernateSession ?

3. propagation=Propagation.SUPPORTS 和propagation=Propagation.require对生成Session有何影响 ?

共同点:都会进入aspect切面处理, 试图新建Session,开启Transaction ,都能获得.TransactionStatus

差别: 前者成功开启事务,后者未开启,但会设置一个同意懒惰载入Session的配置.详情见以下代码.

3.1. 未配置@Transaction 和 配置@Transaction(propagation=Propagation.SUPPORTS)的差别?

共同点: 都没有起事务.

不同点: 前者不会进入aspect切面处理, 后者进入试图新建Session,开启事务但未成功,会设置一个同意懒惰载入Session的配置. 详情见以下代码

4. Spring 何时从线程池中获取到 jdbcconnection 设置 setAutoCommit(false)?

spring是在TransactionAspectSupport(切面编程)的createTransactionIfNecessary方法中完毕对@Transactional注解的处理. 然后托付给PlatformTransactionManager实现类的getTransaction()方法( 实现

类是HibernateTransactionManager被我们配置在application.xml中)对propagation=Propagation.SUPPORTS的处理也是在这种方法内实现,详细是其父类AbstractPlatformTransactionManager.getTransaction()中.

代码片段例如以下:

AbstractPlatformTransactionManager.getTransaction(TransactionDefinitiondefinition){

Object transaction = doGetTransaction(); //注1: springframework的HibernateTransactionObject 实例,内部持有的是 HibernateSession ,一開始是Null;

. . otherCode . .

// No existing transaction found -> check propagationbehavior to find out how to proceed.

if (definition.getPropagationBehavior()== TransactionDefinition.PROPAGATION_MANDATORY) {

throw new IllegalTransactionStateException(

"No existing transaction found for transactionmarked 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 withname [" + definition.getName() + "]:" + definition);

}

try {

boolean newSynchronization =(getTransactionSynchronization() != SYNCHRONIZATION_NEVER);

DefaultTransactionStatus status = newTransactionStatus(

definition, transaction, true,newSynchronization, debugEnabled, suspendedResources);

doBegin(transaction, definition); // 注2: 生成 HibernateSession ,然后获取jdbcconnection , 而且Connection,setAutoCommit(false),开启我们理解上的sql事务.详细是调用Session持有的HibernateJDBCTransaction中的.begin()方法中,

prepareSynchronization(status,definition);  //设置SpringTransactionSynchronizationManager.initSynchronization().

return status;

}

catch (RuntimeException ex) {

resume(null, suspendedResources);

throw ex;

}

catch (Error err) {

resume(null, suspendedResources);

throw err;

}

}

else {

// 注3  这个流程就是当”线程中无事务,且配置是propagation= Propagation.SUPPORTS”时运行的路径.这一步未生成Hibernate Session, jdbc Connection.但 prepareTransactionStatus()中做了一步操作,设置SpringTransactionSynchronizationManager.initSynchronization().正是这个操作在之后,我们 才干在后来Hibernate
save or update时,同意Hibernate 回调初始化时注冊的 Spring SpringSessionContext 生成 HibernateSession ,进一步从连接池获取 jdbcConnection

// Create "empty" transaction: no actualtransaction, but potentially synchronization.

boolean newSynchronization = (getTransactionSynchronization()== SYNCHRONIZATION_ALWAYS);

return prepareTransactionStatus(definition, null, true,newSynchronization, debugEnabled, null);

}

. . .

}

   注2和注3解答了2,3问题.

对以上代码中命名的一点看法:

l       getTransaction返回TransactioStaus, 感觉用 getTransactioStaus比 spring眼下的命名getTransaction更合适 或者取名 getTransactionIfNecessary比較好的,依据注3可知,此分支并没有真正的开启数据库事务.更没有获取jdbc Connection.和不论什么生成 Hibernate Session.

l   比較重要的几个类Springframework的HibernateTransactionObject,Hibernate的Session,Hibernate的JDBCTransaction,jdbc的Connection. Springframework HibernateTransactionObject持有一个 Hibernate Session, Hibernate Session持有一个Hibernate JDBCTransaction , 终于持有 jdbc Connection.

由于 数据库事务Connection.setAutoCommit(false).事务开启是附属于Connection. Connection应该是先于事务开启. 所以感觉用Springframework HibernateTransactionObject 和Hibernate JDBCTransaction 持有 jdbc Connection不同合理.

取名为 Springframework  HibernateTransactionStatusObject ,  Hibernate  JDBCTransactionStaus更合理.

对于第4个问题.

对于@Transaction(propagation=Propagation.REQUIRE)时
Session新建和Session获取都是在AbstractPlatformTransactionManager.getTransaction方法中完毕的

对于@Transaction(propagation=Propagation.SUPPORTS) , 当懒惰获取完Session后,当且仅当真正尝试数据库操作时才会懒惰获取Connection.

获取Connection的简单堆栈例如以下.

ConnectionManager.openConnection()line: 446   //注:发现没有连接,从线程池获取一个连接

ConnectionManager.getConnection()line: 167

BatchingBatcher(AbstractBatcher).prepareQueryStatement(String,boolean, ScrollMode) line: 161

EntityLoader(Loader).prepareQueryStatement(QueryParameters,boolean, SessionImplementor) line: 1700

二. 对于上面第3个小问题的延伸,注3表明此处并没有生成Session. 然后get or save 正常不报错. 我们定义为A情况.

    A.当处于propagation=Propagation.SUPPORTS时,未生成Session和获取到jdbc Connection.当我们 save or get 时候正常不报错.

以下看下无Session情况下获取Session的第二种情况:

    B.我们可能遇到过这种错误:No Hibernate Session bound to thread,and configuration does not allow creationof non-transactional one here.错误原因是我们save
or get的时候获取不到Session,不正常抛错

     A和B都是在无Session情况下获取Session, 为什么一个正常,一个不正常?

详细代码片段例如以下:

        SpringSessionFactoryUtils.doGetSession(SessionFactory sessionFactory,InterceptorentityInterceptor,SQLExceptionTranslator jdbcExceptionTranslator,booleanallowCreate){

                    if (TransactionSynchronizationManager.isSynchronizationActive()){  // 注4:A情况下返回是true,原因见注3,B情况下返回是false.

// 注: 此部分代码实现了”假设眼下没有Session那么就生成Session”的逻辑

}

                   if ((!(allowCreate)) && (!(isSessionTransactional(session,sessionFactory)))) { // 注5: 两个开关推断. allowCreate 对于HibernateManager是强制设置为false(关闭)的,后者正是前面HibernateManager处理@Transaction时开启(返回true).
 有一个同意就正常运行返回了Session. 两个有一个开启(ture)就不抛错,正常运行返回Session.

何时allowCreate是ture?

见以下 三. 那么何时能够获取非事务类型的Session? .

closeSession(session);

throw new IllegalStateException("No Hibernate Session bound to thread, andconfiguration
does not allow creation of non-transactional one here");

}

return session;     //注6, 假设没有被注5禁止,那么就返回生成的Session

}

注4,注5解答了上述问题.

所以出现B问题, 检查下自己的代码,是否处于事务环境中. 因为getTransaction()会把Session绑定到ThreadLocal中,假设新建了独立线程, 注意内部调用的代码是否加上@Transaction,不然该线程中是无法获取到Threadlocal的Session变量.

对于这个Exception.后半部分”configuration does notallow creation of non-transactional one here”的详细语义.是指”configuration不同意生成一个非事务类型的Session”.

2.       还有就是Spring 提供的HibernateTemplate 模板工具类中也是allow=true,方便我们运行Hibernate方法.

其它如propagation= Propagation.require_new也是在上述的代码中,进行原connection挂起和恢复的操作.详细详见代码.