Spring框架学习[Spring具体事务处理器的实现] - JAVA

(), resourcesHolder.getConnectionHolder()); } } //准备提交 protected void prepareForCommit(DefaultTransactionStatus status) { //如果事务配置为FlushBeforeCommit，并且是新事务 if (this.earlyFlushBeforeCommit && status.isNewTransaction()) { //获取事务对象 HibernateTransactionObject txObject = (HibernateTransactionObject) status.getTransaction(); //回去事务对象中的Session Session session = txObject.getSessionHolder().getSession(); //如果Session的刷新模式不低于COMMIT if (!session.getFlushMode().lessThan(FlushMode.COMMIT)) { logger.debug("Performing an early flush for Hibernate transaction"); try { //刷新Session session.flush(); } catch (HibernateException ex) { throw convertHibernateAccessException(ex); } finally { //把Session的刷新模式设置为MANUAL session.setFlushMode(FlushMode.MANUAL); } } } } //提交处理 protected void doCommit(DefaultTransactionStatus status) { //获取当前的Hibernate事务对象 HibernateTransactionObject txObject = (HibernateTransactionObject) status.getTransaction(); if (status.isDebug()) { logger.debug("Committing Hibernate transaction on Session [" +SessionFactoryUtils.toString(txObject.getSessionHolder().getSession()) + "]"); } try { //通过Hibernate事务完成提交 txObject.getSessionHolder().getTransaction().commit(); } catch (org.hibernate.TransactionException ex) { throw new TransactionSystemException("Could not commit Hibernate transaction", ex); } catch (HibernateException ex) { throw convertHibernateAccessException(ex); } } //回滚处理 protected void doRollback(DefaultTransactionStatus status) { //获取Hibernate事务对象 HibernateTransactionObject txObject = (HibernateTransactionObject) status.getTransaction(); if (status.isDebug()) { logger.debug("Rolling back Hibernate transaction on Session ["+SessionFactoryUtils.toString(txObject.getSessionHolder().getSession()) + "]"); } try { //通过Hibernate事务执行回滚操作 txObject.getSessionHolder().getTransaction().rollback(); } catch (org.hibernate.TransactionException ex) { throw new TransactionSystemException("Could not roll back Hibernate transaction", ex); } catch (HibernateException ex) { throw convertHibernateAccessException(ex); } finally { if (!txObject.isNewSession() && !this.hibernateManagedSession) { //清除事务对象中的Hibernate Session txObject.getSessionHolder().getSession().clear(); } } } …… }

<div class="article-middle-ad" style="margin: 30px 0; padding: 20px 0; text-align: center; clear: both;">
<script async src="https://pagead2.googlesyndication.com/pagead/js/adsbygoogle.js?client=ca-pub-3873923678443673" crossorigin="anonymous"></script>

<ins class="adsbygoogle"
     style="display:block"
     data-ad-client="ca-pub-3873923678443673"
     data-ad-slot="5723320063"
     data-ad-format="auto"
     data-full-width-responsive="true"></ins>
<script>
     (adsbygoogle = window.adsbygoogle || []).push({});
</script>
</div>public class HibernateTransactionManager extends AbstractPlatformTransactionManager		implements ResourceTransactionManager, BeanFactoryAware, InitializingBean {	……	//获取Hibernate事务	protected Object doGetTransaction() {		//创建Hibernate事务对象		HibernateTransactionObject txObject = new HibernateTransactionObject();		//根据是否允许嵌套事务设置事务对象是否允许保存点		txObject.setSavepointAllowed(isNestedTransactionAllowed());		//从线程中获取SessionHolder,SessionHolder是在事务开始时与线程绑定的。		SessionHolder sessionHolder =				(SessionHolder) TransactionSynchronizationManager.getResource(getSessionFactory());		//如果获取到的SessionHolder不为null		if (sessionHolder != null) {			if (logger.isDebugEnabled()) {				logger.debug("Found thread-bound Session [" +				SessionFactoryUtils.toString(sessionHolder.getSession()) + "] for Hibernate transaction");			}			//把获取到的SessionHolder设置到Hibernate事务对象中			txObject.setSessionHolder(sessionHolder);		}		//如果当前Hibernate事务处理器有被管理的Hibernate Session		else if (this.hibernateManagedSession) {			try {				//获取当前的Hibernate Sess</span>
            </div>

<div class="article-footer mt-60 pt-40">
                
                <div class="share-box">
                    
                        <div class="bdsharebuttonbox"><a href="#" class="bds_more" data-cmd="more"></a><a href="#" class="bds_qzone" data-cmd="qzone" title="分享到QQ空间"></a><a href="#" class="bds_tsina" data-cmd="tsina" title="分享到新浪微博"></a><a href="#" class="bds_tqq" data-cmd="tqq" title="分享到腾讯微博"></a><a href="#" class="bds_renren" data-cmd="renren" title="分享到人人网"></a><a href="#" class="bds_weixin" data-cmd="weixin" title="分享到微信"></a></div>
                    <script>window._bd_share_config={"common":{"bdSnsKey":{},"bdText":"","bdMini":"2","bdMiniList":false,"bdPic":"","bdStyle":"0","bdSize":"24"},"share":{}};with(document)0[(getElementsByTagName('head')[0]||body).appendChild(createElement('script')).src='http://bdimg.share.baidu.com/static/api/js/share.js?v=89860593.js?cdnversion='+~(-new Date()/36e5)];</script>
                </div>

<div class="prev-next mt-20">
                    <div class="prev">
                        <span class="label">上一篇</span>
                        <a href="bencandy.php?fid=76&id=39440" onclick="" class="link">微信打飞机--Java版</a>
                    </div>
                    <div class="next">
                        <span class="label">下一篇</span>
                        <a href="bencandy.php?fid=76&id=39438" onclick="" class="link">hdu1039 java正则表达式解法</a>
                    </div>
                </div>
            </div>
        </div>

</div>
</div>
</div>

<footer class="container mt-20 site-footer">
    <div id="copyright">
        Copyright © https://www.cppentry.com all rights reserved 
        <a href="http://www.miibeian.gov.cn" target="_blank">粤ICP备13067022号-3</a><br>
            </div>
</footer>

Spring框架学习[Spring具体事务处理器的实现](十)