Вы должны вызывать DatabaseContextHolder.setDatabaseType (DatabaseType.MAIN) перед вызовом метода. Hibernate ищет соединение после запуска транзакции. В вашем случае транзакция запускается до выполнения DatabaseContextHolder.setDatabaseType (DatabaseType.MAIN). И после запуска транзакции схема не может быть изменена. Ваша реализация верна, попробуйте установить DatabaseType перед вызовом метода, т.е. перед запуском транзакции.
ите за мой плохой английский. Я написал реализацию для AbstractRoutingDataSource:
public class DatabaseRoutingDataSource extends AbstractRoutingDataSource{
@Override
protected Object determineCurrentLookupKey() {
return DatabaseContextHolder.getDatabaseType();
}
}
И я создал новый класс для переключения между базами данных:
public class DatabaseContextHolder {
private static final ThreadLocal<DatabaseType> contextHolder = new ThreadLocal<DatabaseType>();
public static void setDatabaseType(DatabaseType databaseType) {
contextHolder.set(databaseType);
}
public static DatabaseType getDatabaseType() {
return (DatabaseType) contextHolder.get();
}
public static void clearDatabaseType() {
contextHolder.remove();
}
}
где DatabaseType:
public enum DatabaseType {
MAIN,
BACKUP
}
в моем файле beans.xml:
<bean id="mainDataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:/jdbc/DBMIDS"/>
</bean>
<bean id="backupDataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName" value="java:/jdbc/DBMIDS2"/>
</bean>
<bean id="dataSource" class="DatabaseRoutingDataSource">
<property name="targetDataSources">
<map key-type="DatabaseType">
<entry key="MAIN" value-ref="mainDataSource"/>
<entry key="BACKUP" value-ref="backupDataSource"/>
</map>
</property>
<property name="defaultTargetDataSource" ref="mainDataSource"/>
</bean>
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<bean id="databaseTarget" class="DatabaseBean">
<property name="dataSource" ref="dataSource"/>
</bean>
<bean id="database" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="transactionManager" ref="transactionManager"/>
<property name="target" ref="databaseTarget"/>
<property name="proxyInterfaces">
<value>Database</value>
</property>
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED,-MyException</prop>
</props>
</property>
</bean>
Теперь, когда я пытаюсь изменить источник данных в моем DAO:
public class DatabaseBean extends JdbcDaoSupport implements Database
public void myMethod() {
DatabaseContextHolder.setDatabaseType(DatabaseType.MAIN);
getJdbcTemplate().execute("INSERT INTO test(test) VALUES('test')");
DatabaseContextHolder.setDatabaseType(DatabaseType.BACKUP);
getJdbcTemplate().execute("INSERT INTO test(test) VALUES('test')");
}
defineCurrentLookupKey () вызывается один раз, когда впервые выполняется getJdbcTemplate (), а источник данных не переключается.