[原理][源代码解析]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”.

   

三. 那么什么时候能够获取非事务类型的Session?

1.       查看源代码能够发现OpenSessionInViewFilter中能够 (配置在 web.xml中),正是这个allow=true ,才使其在无事务环境下先生成一个Session,并延迟关闭.保证了view层可以获取到懒惰加载的实体. 2.       还有就是Spring 提供的HibernateTemplate 模板工具类中也是allow=true,方便咱们执行Hibernate方法.   其余如propagation= Propagation.require_new也是在上述的代码中,进行原connection挂起和恢复的操做.具体详见代码.

 

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

 

原文地址：http://blog.csdn.net/fei33423/article/details/32346821