Spring + Hibernate: вместе с транзакционными и не транзакционными источниками данных

Question

В моей Spring 2.5.6 + Hibernate app Мне нужно читать/записывать данные в/из нескольких баз данных с разными схемами. Приложение находится на Tomcat, поэтому я бы предпочел не использовать JTA, так что мне не нужно переходить на полномасштабный сервер приложений.

Итак, я решил иметь только один транзакционный источник данных. Я могу жить с другими, не являющимися транзакционными.

Но почему-то я не могу заставить его работать. Не могли бы вы дать мне понять, что я могу делать неправильно?

Это мой applicationContext.xml:

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"> 
    <property name="dataSource" ref="dataSource"/> 
    <!-- ..configuration.. --> 
</bean> 

<bean id="nonTransactionalSessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean"> 
    <property name="dataSource" ref="nonTransactionalDataSource" /> 
    <!-- ..configuration.. --> 
</bean> 

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> 
    <!-- ..configuration.. --> 
</bean> 

<bean id="nonTransactionalDataSource" class="org.apache.commons.dbcp.BasicDataSource"> 
    <!-- ..configuration.. --> 
</bean> 

<bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"> 
    <property name="sessionFactory" ref="sessionFactory"/> 
</bean> 

<bean id="daoHolder" class="com.app.services.TransactionTest$DaoHolder"/> 

<tx:annotation-driven transaction-manager="txManager"/> 

<bean id="transactionalDao" class="com.app.services.TransactionalDaoImpl"> 
    <property name="sessionFactory" ref="sessionFactory" /> 
</bean> 

<bean id="nonTransactionalDao" class="com.app.services.NonTransactionalDaoImpl"> 
     <property name="sessionFactory" ref="nonTransactionalSessionFactory" /> 
</bean> 

Как вы можете видеть выше, является лишь определение двух сессионных заводов, каждый из которых использует свой собственный источник данных. Менеджер транзакций использует только одну из этих сессионных фабрик и настраивается управление tx, основанное на аннотациях.

Вот мой блок тест, в котором я пытаюсь проверить поведение транзакционной:

@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration(locations = {"/applicationContext.xml"}) 
public class TransactionTest { 

@Autowired 
private DaoHolder daoHolder; 

@Test 
public void testTransactions() throws Exception { 

    try { 
     daoHolder.runTransactionalMethod(); 
    } catch (Exception exception) { 
     System.out.println("Exception caught"); 
    } 
} 

---

public static class DaoHolder { 

    @Autowired 
    private TransactionalDao transactionalDao; 
    @Autowired 
    private NonTransactionalDao nonTransactionalDao; 

    @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW, rollbackFor={Exception.class}) 
    private void runTransactionalMethod() throws Exception { 
     transactionalDao.insertRow(); 
     nonTransactionalDao.insertRow(); 
     throw new Exception(); 
    } 

} 

В результате проведенной проверки, я ожидал, что новая строка вставляется в не транзакционный источник данных, потому что изменения на транзакционном источнике данных должны быть отброшены, потому что есть исключение. Однако после прохождения этого теста я вижу строки, вставленные в оба источника данных.

EDIT: Я переехал немного дальше. Я превратил DaoHolder в интерфейс, переместил вышеуказанную логику в класс, реализующий интерфейс (DaoHolderImpl), и пометил также класс (а не только метод) с помощью @Transactional. Я также добавил этот класс как Spring Bean. Итак, теперь Spring обрабатывает мои транзакции. Но на этот раз, бросая Exception, новая строка откатывается из обоих источников данных, а не только транзакционной. Это все еще не то, что я ожидал:/

Кто-нибудь видит, что я делаю неправильно? Спасибо заранее,

Питер

Answer 1

насчет сдачи контрольных точек на линии «бросить исключение», так что вы можете увидеть, если один или оба баз данных имеют эту линию?

Он не исправляет вашу странную проблему отката, а не говорит о том, работает ли ваш источник данных без транзакций.

Вы бы скорее включить рессора/спящий режим протоколирования, чтобы посмотреть, что происходит о сделках ...