1

我正在尝试实现以下内容:我需要在同一个事务中将两个不同的实体添加到数据库中。每个实体都有不同的 DAO 类和服务类。

public class InvoicesDAO  {
    @Autowired
    protected SessionFactory sessionFactory;

    public void save(Invoice object) {
        Session session = SessionFactoryUtils.getSession(sessionFactory, false);

        session.persist(object);
    }
}

public class RequestsDAO {
    @Autowired
    protected SessionFactory sessionFactory;

    public void save(Request object) {
        Session session = SessionFactoryUtils.getSession(sessionFactory, false);

        session.persist(object);
    }
}

public class InvoicesService {
    @Autowired
    private InvoicesDAO invoicesDAO;

    @Autowired
    private RequestsDAO requestsDAO;

    @Transactional
    public void add(Invoice object) throws HibernateException {
        invoicesDAO.save(object);
    }

    @Transactional
    public void updateAndGenerate(Invoice object1, Request object2) throws HibernateException {
        invoicesDAO.save(object1);
        requestsDAO.save(object2);
    }
}

配置:

<tx:annotation-driven transaction-manager="transactionManager" />
    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:/hibernate.properties" />
    </bean>
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="${hibernate.connection.driver_class}" />
        <property name="url" value="${hibernate.connection.url}" />
        <property name="username" value="${hibernate.connection.username}" />
        <property name="password" value="${hibernate.connection.password}" />
    </bean>      
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="packagesToScan" value="com.ejl.butler.object.data" />
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">${hibernate.dialect}</prop>
                <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
                <prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
                <prop key="hibernate.cache.use_query_cache">${hibernate.cache.use_query_cache}</prop>
                <prop key="hibernate.cache.region.factory_class">${hibernate.cache.region.factory_class}</prop>
           </props>
        </property>
    </bean>
    <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <property name="sessionFactory" ref="sessionFactory" />
    </bean>

<context:annotation-config />
    <context:component-scan base-package="com.service" />
    <bean id="invoicesDao" class="com.dao.InvoicesDAO" />
<bean id="requestsDao" class="com.dao.RequestsDAO" />

控制器:

//***
/**
     * Invoices access service
     */
    @Autowired
    private InvoicesService invoicesService;

        // objects creation
        invoicesService.updateAndGenerate(invoice, request);
//***

因此,当我尝试调用 updateAndGenerate 方法并在那里传递 object2 的无效值时 - 它会在不回滚 object1 的情况下失败。我该如何解决?谢谢

4

2 回答 2

0

我认为这与代理无关。您在这里不需要代理对象。通常,对于登录服务等实例,您需要一个代理对象,而单例 bean 定义需要一个代理对象。但是,它不能回滚的唯一方法是如果您对事务的传播级别不正确。

如果你使用 Trasaction.REQUIRES_NEW 那么 dao.save 不会回滚,它不会绑定到外部事务,因此不会回滚。

于 2013-12-30T09:50:35.193 回答
-1

最后我弄清楚问题出在哪里,所以我会回答我自己的问题......

根据声明式事务 (@Transactional) 不适用于 Spring 中的 @Repositoryhttps://stackoverflow.com/a/3250959/705869,指令中的base-package项目顺序context:component-scan非常重要。此外,您应该只放置真正必要的包。

我在该指令中有一些重复项,因此应用程序上下文在数据库上下文之前初始化。这就是为什么事务在服务内部被禁用的原因!

所以检查两次base-package里面的包裹context:component-scan并移除不必要的包裹。

于 2014-01-08T12:28:57.160 回答