hibernate spring 加载多个TransactionManager

Question

我在用多个TransactionManager尝试不同数据库之间的切换，但是总是默认的第一个。
以下是我的XML配置

    <bean id="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
        <property name="sessionFactory" ref="sessionFactory" />
    </bean>
    
    <bean id="transactionManagerSS" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
        <property name="sessionFactory" ref="sessionFactorySS" />
    </bean>

    <bean id="routingTransactionManager" class="com.ivo.util.RoutingTransactionManager">
        <property name="targetTransactionManagers">
          <map value-type="org.springframework.transaction.PlatformTransactionManager">
            <entry key="transactionManager" value-ref="transactionManager" />
            <entry key="transactionManagerSS" value-ref="transactionManagerSS" />
          </map>
        </property>
      </bean>

这是我指定TransactionManager的类

import org.apache.commons.lang.Validate;
@SuppressWarnings("unchecked")
public class RoutingContextHolder<T> {
     
    @SuppressWarnings("rawtypes")
    private static final ThreadLocal contextHolder = new ThreadLocal();

      public static <T> void setContext(T context) {
        Validate.notNull(context, "必须指定路由的context");
        contextHolder.set(context);
      }

      public static <T> T getContext() {
        return (T) contextHolder.get();
      }
    }

这个类实现了PlatformTransactionManager

import java.util.HashMap;
import java.util.Map;

import org.apache.commons.lang.Validate;
import org.hibernate.TransactionException;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;

public class RoutingTransactionManager implements PlatformTransactionManager{

    private Map<Object, PlatformTransactionManager> targetTransactionManagers = new HashMap<Object, PlatformTransactionManager>();

          /**
           * 根据给定的规则获取指定的tx
           * 
           * @return
           */
          protected PlatformTransactionManager getTargetTransactionManager() {
            Object context = RoutingContextHolder.getContext();
            Validate.notNull(context, "必须指定路由的context");
            return targetTransactionManagers.get(context);
          }

          public void setTargetTransactionManagers(Map<Object, PlatformTransactionManager> targetTransactionManagers) {
            this.targetTransactionManagers = targetTransactionManagers;
          }

          public void commit(TransactionStatus status) throws TransactionException {
            getTargetTransactionManager().commit(status);
          }

          public TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException {
            return getTargetTransactionManager().getTransaction(definition);
          }

          public void rollback(TransactionStatus status) throws TransactionException {
            getTargetTransactionManager().rollback(status);
          }
}

我的调用是这样的：

RoutingContextHolder.setContext("transactionManagerSS");

报错是这样的

com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'eimdb.rma_o_customer' doesn't exist
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
    at com.mysql.jdbc.Util.handleNewInstance(Util.java:411)

搞了很久没看懂 希望大家能帮帮我~ Thanks in advance!
(这只是部分代码，如果需要详细的，请@我)

以下是两个Sessionfactory的配置

    <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
        <property name="dataSource" ref="dataSourceMS" />
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">
                    org.hibernate.dialect.MySQLDialect
                </prop>
                <prop key="hibernate.show_sql">false</prop>
                <prop key="hibernate.cache.region.factory_class">
                    org.hibernate.cache.ehcache.EhCacheRegionFactory
                </prop>
                <prop key="hibernate.format_sql">false</prop>
                <prop key="hibernate.use_sql_comments">false</prop>
                <prop key="hibernate.jdbc.fetch_size">80</prop>
                <prop key="hibernate.jdbc.batch_size">80</prop>
                <prop key="hibernate.jdbc.use_streams_for_binary">
                    true
                </prop>
                <prop key="hibernate.current_session_context_class">
                    org.springframework.orm.hibernate4.SpringSessionContext
                </prop>
                <prop key="hibernate.cache.use_second_level_cache">
                    true
                </prop>
                <prop key="hibernate.cache.use_query_cache">true</prop>
                <prop key="hibernate.max_fetch_depth">3</prop>
                <prop key="hibernate.hbm2ddl.auto">none</prop>
            </props>
        </property>
        <property name="packagesToScan" value="com.ivo.*" />
    </bean>

    <bean id="sessionFactorySS" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
        <property name="dataSource" ref="dataSourceSS" />
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">
                    org.hibernate.dialect.SQLServerDialect
                </prop>
                <prop key="hibernate.show_sql">false</prop>
                <prop key="hibernate.cache.region.factory_class">
                    org.hibernate.cache.ehcache.EhCacheRegionFactory
                </prop>
                <prop key="hibernate.format_sql">false</prop>
                <prop key="hibernate.use_sql_comments">false</prop>
                <prop key="hibernate.jdbc.fetch_size">80</prop>
                <prop key="hibernate.jdbc.batch_size">80</prop>
                <prop key="hibernate.jdbc.use_streams_for_binary">
                    true
                </prop>
                <prop key="hibernate.current_session_context_class">
                    org.springframework.orm.hibernate4.SpringSessionContext
                </prop>
                <prop key="hibernate.cache.use_second_level_cache">
                    true
                </prop>
                <prop key="hibernate.cache.use_query_cache">true</prop>
                <prop key="hibernate.max_fetch_depth">3</prop>
                <prop key="hibernate.hbm2ddl.auto">none</prop>
            </props>
        </property>
        <property name="packagesToScan" value="com.ivo.*" />
    </bean>

这是datasource

    <bean id="dataSourceMS" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
        <property name="url" value="**" />
        <property name="username" value="root"/>
        <property name="password" value="root"/>
         
        <!-- 配置初始化大小、最小、最大 -->
        <property name="initialSize" value="1" />
        <property name="minIdle" value="1"/>
        <property name="maxActive" value="8" />
        <!-- 配置获取连接等待超时的时间 -->
        <property name="maxWait" value="3000"/>
        <!-- 配置间隔多久才进行一次检测（启动destroy线程），检测需要关闭的空闲连接，单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000" />
        <!-- 配置一个连接在池中最小生存的时间，单位是毫秒；即最多允许一个连接空闲多长时间，超出此时间的连接，会被destroy线程关闭 -->
        <property name="minEvictableIdleTimeMillis" value="300000" />
        <!-- 对空闲接连再被使用时，如果空闲时间超过timeBetweenEvictionRunsMillis，会发出验证sql进行有效检测 -->
        <property name="validationQuery" value="SELECT 'x'" />
        <property name="testWhileIdle" value="true" />
        <property name="testOnBorrow" value="false" />
        <property name="testOnReturn" value="false" />
        <!-- 移除执行超时的sql，单位是毫秒 -->
        <property name="removeAbandoned" value="true"/>
        <property name="removeAbandonedTimeout" value="60"/>
        <property name="logAbandoned" value="true" />
        
        <!-- 配置监控统计拦截的filters -->
        <property name="proxyFilters">
            <list>
                <ref bean="stat-filter" />
                <ref bean="wall-filter" />
                <ref bean="log-filter" />
            </list>
        </property>
    </bean>
    
    <bean id="dataSourceSS" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
        <property name="url" value="**" />
        <property name="username" value="test"/>
        <property name="password" value="***"/>
         
        <!-- 配置初始化大小、最小、最大 -->
        <property name="initialSize" value="1" />
        <property name="minIdle" value="1"/>
        <property name="maxActive" value="8" />
        <!-- 配置获取连接等待超时的时间 -->
        <property name="maxWait" value="3000"/>
        <!-- 配置间隔多久才进行一次检测（启动destroy线程），检测需要关闭的空闲连接，单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000" />
        <!-- 配置一个连接在池中最小生存的时间，单位是毫秒；即最多允许一个连接空闲多长时间，超出此时间的连接，会被destroy线程关闭 -->
        <property name="minEvictableIdleTimeMillis" value="300000" />
        <!-- 对空闲接连再被使用时，如果空闲时间超过timeBetweenEvictionRunsMillis，会发出验证sql进行有效检测 -->
        <property name="validationQuery" value="SELECT 'x'" />
        <property name="testWhileIdle" value="true" />
        <property name="testOnBorrow" value="false" />
        <property name="testOnReturn" value="false" />
        <!-- 移除执行超时的sql，单位是毫秒 -->
        <property name="removeAbandoned" value="true"/>
        <property name="removeAbandonedTimeout" value="60"/>
        <property name="logAbandoned" value="true" />
        
        <!-- 配置监控统计拦截的filters -->
        <property name="proxyFilters">
            <list>
                <ref bean="stat-filter" />
                <ref bean="wall-filter" />
                <ref bean="log-filter" />
            </list>
        </property>
    </bean>

Answer 1

com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'eimdb.rma_o_customer' doesn't exist

不是很明显的错吗？你的数据库中有rma_o_customer这张表吗? eimdb是数据库schema？还是catalog？