深入解析Java的Spring框架中的混合事务与bean的区分

     protected void doBegin(Object transaction,TransactionDefinition definition) {          DataSourceTransactionObjecttxObject = (DataSourceTransactionObject) transaction;          Connection con = null;           try {              if(txObject.getConnectionHolder() == null ||                        txObject.getConnectionHolder().isSynchronizedWithTransaction()){                   ConnectionnewCon = this.dataSource.getConnection();                   if(logger.isDebugEnabled()) {                        logger.debug("AcquiredConnection [" + newCon + "] for JDBC transaction");                   }                   txObject.setConnectionHolder(newConnectionHolder(newCon), true);              }               txObject.getConnectionHolder().setSynchronizedWithTransaction(true);              con =txObject.getConnectionHolder().getConnection();               IntegerpreviousIsolationLevel = DataSourceUtils.prepareConnectionForTransaction(con,definition);              txObject.setPreviousIsolationLevel(previousIsolationLevel);               // Switch to manualcommit if necessary. This is very expensive in some JDBC drivers,              // so we don't wantto do it unnecessarily (for example if we've explicitly              // configured theconnection pool to set it already).              if(con.getAutoCommit()) {                   txObject.setMustRestoreAutoCommit(true);                   if(logger.isDebugEnabled()) {                        logger.debug("SwitchingJDBC Connection [" + con + "] to manual commit");                   }                   con.setAutoCommit(false);              }              txObject.getConnectionHolder().setTransactionActive(true);               int timeout =determineTimeout(definition);              if (timeout !=TransactionDefinition.TIMEOUT_DEFAULT) {                   txObject.getConnectionHolder().setTimeoutInSeconds(timeout);              }               // Bind the sessionholder to the thread.              if(txObject.isNewConnectionHolder()) {                   TransactionSynchronizationManager.bindResource(getDataSource(),txObject.getConnectionHolder());              }          }           catch (Exception ex) {              DataSourceUtils.releaseConnection(con,this.dataSource);              throw newCannotCreateTransactionException("Could not open JDBC Connection fortransaction", ex);          }     }

     public static void bindResource(Objectkey, Object value) throws IllegalStateException {          Object actualKey =TransactionSynchronizationUtils.unwrapResourceIfNecessary(key);          Assert.notNull(value,"Value must not be null");          Map<Object, Object> map = resources.get();          // set ThreadLocal Map ifnone found          if (map == null) {              map = newHashMap<Object, Object>();              resources.set(map);          }          Object oldValue = map.put(actualKey, value);          // Transparently suppress aResourceHolder that was marked as void...          if (oldValue instanceofResourceHolder && ((ResourceHolder) oldValue).isVoid()) {              oldValue = null;          }          if (oldValue != null) {              throw newIllegalStateException("Already value [" + oldValue + "] for key[" +                        actualKey+ "] bound to thread [" + Thread.currentThread().getName() +"]");          }          if (logger.isTraceEnabled()){              logger.trace("Boundvalue [" + value + "] for key [" + actualKey + "] to thread[" +                        Thread.currentThread().getName()+ "]");          }     }

     public Objectexecute(PreparedStatementCreator psc, PreparedStatementCallback action)              throwsDataAccessException {           Assert.notNull(psc,"PreparedStatementCreator must not be null");          Assert.notNull(action,"Callback object must not be null");          if (logger.isDebugEnabled()){              String sql =getSql(psc);              logger.debug("Executingprepared SQL statement" + (sql != null ? " [" + sql +"]" : ""));          }           Connection con = DataSourceUtils.getConnection(getDataSource());          PreparedStatement ps = null;          try {              Connection conToUse= con;              if(this.nativeJdbcExtractor != null &&                        this.nativeJdbcExtractor.isNativeConnectionNecessaryForNativePreparedStatements()){                   conToUse =this.nativeJdbcExtractor.getNativeConnection(con);              }              ps =psc.createPreparedStatement(conToUse);              applyStatementSettings(ps);              PreparedStatementpsToUse = ps;              if(this.nativeJdbcExtractor != null) {                   psToUse =this.nativeJdbcExtractor.getNativePreparedStatement(ps);              }              Object result =action.doInPreparedStatement(psToUse);              handleWarnings(ps);              return result;          }          catch (SQLException ex) {              // ReleaseConnection early, to avoid potential connection pool deadlock              // in the case whenthe exception translator hasn't been initialized yet.              if (psc instanceofParameterDisposer) {                   ((ParameterDisposer)psc).cleanupParameters();              }              String sql =getSql(psc);              psc = null;              JdbcUtils.closeStatement(ps);              ps = null;              DataSourceUtils.releaseConnection(con,getDataSource());              con = null;              throwgetExceptionTranslator().translate("PreparedStatementCallback", sql,ex);          }          finally {              if (psc instanceofParameterDisposer) {                   ((ParameterDisposer)psc).cleanupParameters();              }              JdbcUtils.closeStatement(ps);              DataSourceUtils.releaseConnection(con,getDataSource());          }     }

    public static Connection doGetConnection(DataSourcedataSource) throws SQLException {          Assert.notNull(dataSource,"No DataSource specified");           ConnectionHolder conHolder = (ConnectionHolder)TransactionSynchronizationManager.getResource(dataSource);          if (conHolder != null&& (conHolder.hasConnection() ||conHolder.isSynchronizedWithTransaction())) {              conHolder.requested();              if(!conHolder.hasConnection()) {                   logger.debug("Fetchingresumed JDBC Connection from DataSource");                   conHolder.setConnection(dataSource.getConnection());              }              returnconHolder.getConnection();          }          // Else we either got noholder or an empty thread-bound holder here.           logger.debug("FetchingJDBC Connection from DataSource");          Connection con =dataSource.getConnection();           if (TransactionSynchronizationManager.isSynchronizationActive()){              logger.debug("Registeringtransaction synchronization for JDBC Connection");              // Use sameConnection for further JDBC actions within the transaction.              // Thread-boundobject will get removed by synchronization at transaction completion.              ConnectionHolderholderToUse = conHolder;              if (holderToUse ==null) {                   holderToUse= new ConnectionHolder(con);              }              else {                   holderToUse.setConnection(con);              }              holderToUse.requested();              TransactionSynchronizationManager.registerSynchronization(                        newConnectionSynchronization(holderToUse, dataSource));              holderToUse.setSynchronizedWithTransaction(true);              if (holderToUse !=conHolder) {                   TransactionSynchronizationManager.bindResource(dataSource,holderToUse);              }          }           return con;     }

if(txObject.isNewSessionHolder()) {      TransactionSynchronizationManager.bindResource(getSessionFactory(),txObject.getSessionHolder()); } 

 <bean name="xmlPageManager"class="org.apache.jetspeed.page.psml.CastorXmlPageManager"init-method="init" destroy-method="destroy">  <meta key="j2:cat" value="xmlPageManager orpageSerializer" />  <constructor-arg index="0">   <ref bean="IdGenerator"/>  </constructor-arg>  <constructor-arg index="1">   <refbean="xmlDocumentHandlerFactory" />  </constructor-arg>  …… </bean>  <bean id="dbPageManager"class="org.apache.jetspeed.page.impl.DatabasePageManager"init-method="init" destroy-method="destroy">  <meta key="j2:cat" value="dbPageManager orpageSerializer" />  <!-- OJB configuration file resourcepath -->  <constructor-arg index="0">   <value>JETSPEED-INF/ojb/page-manager-repository.xml</value>  </constructor-arg>  <!-- fragment id generator -->  <constructor-arg index="1">   <ref bean="IdGenerator"/>  </constructor-arg>  …… </bean>

  public boolean match(BeanDefinition bd)  {    String beanCategoriesExpression = (String)bd.getAttribute(CATEGORY_META_KEY);    boolean matched = true;    if (beanCategoriesExpression != null)    {      matched = ((matcher != null)&& matcher.match(beanCategoriesExpression));    }    return matched;}   public void registerDynamicAlias(BeanDefinitionRegistry registry, String beanName,BeanDefinition bd)  {    String aliases =(String)bd.getAttribute(ALIAS_META_KEY);    if (aliases != null)    {      StringTokenizer st = newStringTokenizer(aliases, " ,");      while (st.hasMoreTokens())      {        String alias = st.nextToken();        if (!alias.equals(beanName))        {          registry.registerAlias(beanName, alias);        }      }    }  }

public class FilteringXmlWebApplicationContextextends XmlWebApplicationContext{  private JetspeedBeanDefinitionFilterfilter;    publicFilteringXmlWebApplicationContext(JetspeedBeanDefinitionFilter filter, String[]configLocations, Properties initProperties, ServletContext servletContext)  {    this(filter, configLocations,initProperties, servletContext, null);  }    publicFilteringXmlWebApplicationContext(JetspeedBeanDefinitionFilter filter, String[]configLocations, Properties initProperties, ServletContext servletContext,ApplicationContext parent)  {    super();    if (parent != null)    {      this.setParent(parent);    }    if (initProperties != null)    {      PropertyPlaceholderConfigurer ppc =new PropertyPlaceholderConfigurer();      ppc.setIgnoreUnresolvablePlaceholders(true);      ppc.setSystemPropertiesMode(PropertyPlaceholderConfigurer.SYSTEM_PROPERTIES_MODE_FALLBACK);      ppc.setProperties(initProperties);      addBeanFactoryPostProcessor(ppc);    }    setConfigLocations(configLocations);    setServletContext(servletContext);    this.filter = filter;  }    protected DefaultListableBeanFactorycreateBeanFactory()  {    return new FilteringListableBeanFactory(filter,getInternalParentBeanFactory());  }} public classFilteringListableBeanFactory extends DefaultListableBeanFactory{  private JetspeedBeanDefinitionFilterfilter;    public FilteringListableBeanFactory(JetspeedBeanDefinitionFilterfilter, BeanFactory parentBeanFactory)  {    super(parentBeanFactory);    this.filter = filter;    if (this.filter == null)    {      this.filter = newJetspeedBeanDefinitionFilter();    }    this.filter.init();  }   /**   * Override of the registerBeanDefinitionmethod to optionally filter out a BeanDefinition and   * if requested dynamically register anbean alias   */  public void registerBeanDefinition(StringbeanName, BeanDefinition bd)      throws BeanDefinitionStoreException  {    if (filter.match(bd))    {      super.registerBeanDefinition(beanName, bd);      if (filter != null)      {        filter.registerDynamicAlias(this, beanName, bd);      }    }  }}

<bean class="org.springframework.beans.factory.config.BeanReferenceFactoryBean">  <meta key="j2:cat"value="xmlPageManager" />  <meta key="j2:alias"value="org.apache.jetspeed.page.PageManager" />  <propertyname="targetBeanName" value="xmlPageManager" /> </bean>  <bean class="org.springframework.beans.factory.config.BeanReferenceFactoryBean">  <meta key="j2:cat"value="dbPageManager" />  <meta key="j2:alias"value="org.apache.jetspeed.page.PageManager" />  <propertyname="targetBeanName" value="dbPageManager" /> </bean>  <bean id="org.apache.jetspeed.layout.PageLayoutComponent"  class="org.apache.jetspeed.layout.impl.PageLayoutComponentImpl">  <meta key="j2:cat"value="default" />  <constructor-arg index="0">   <refbean="org.apache.jetspeed.page.PageManager" />  </constructor-arg>  <constructor-arg index="1">   <value>jetspeed-layouts::VelocityOneColumn</value>  </constructor-arg> </bean>