休眠事务开始并在正确的点提交

Question

我有一个 dao 包，其中我的所有 DaoClasses 都实现了以下方法：

public class XDaoImpl implements XDao {

    private SessionFactory sessionFactory;

    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    public SessionFactory getSessionFactory() {
        return sessionFactory;
    }

    @Override
    public void saveOrUpdate(MyObject o) {
            //Transaction trans = getSessionFactory().getCurrentSession().beginTransaction();
            getSessionFactory().getCurrentSession().saveOrUpdate(o); 
            //trans.commit();
        }
}

如果我运行我的应用程序，则需要很长时间才能将我的对象存储到数据库中。我相信它会发生，因为我为每个对象创建了一个新的事务。所以我尝试使用 Spring Framework 的基于 xml 的声明式事务实现。但直到现在它对我不起作用：

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:tx="http://www.springframework.org/schema/tx"
     xmlns:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
                           http://www.springframework.org/schema/tx
                           http://www.springframework.org/schema/tx/spring-tx.xsd
                           http://www.springframework.org/schema/aop
                           http://www.springframework.org/schema/aop/spring-aop.xsd">

    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location">
            <value>/resources/spring/config/database.properties</value>
        </property>
    </bean>


    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="${jdbc.driverClassName}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
    </bean>


    <bean id="hibernate3SessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">

        <property name="dataSource" ref="dataSource" />

        <property name="mappingResources">
            <list>
                <value>/resources/spring/config/A.hbm.xml</value>
                <value>/resources/spring/config/B.hbm.xml</value>
                <value>/resources/spring/config/C.hbm.xml</value>
                <value>/resources/spring/config/D.hbm.xml</value>
            </list>
        </property>

        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.PostgreSQLDialect</prop>
                <prop key="hibernate.current_session_context_class">thread</prop>
                <prop key="hibernate.hbm2ddl.auto">create</prop>
                <prop key="hibernate.show_sql">true</prop>
            </props>
        </property>

    </bean>

    <bean id="dBo" class="com.model.bo.DBoImpl">
        <property name="dDao" ref="dDao" />
        <property name="bDao" ref="bDao" />
    </bean>

    <bean id="dDao" class="com.model.dao.dDaoImpl">
        <property name="sessionFactory" ref="hibernate3SessionFactory" />
    </bean>

    <bean id="aBo" class="com.model.bo.aBoImpl">
        <property name="aDao" ref="aDao" />
        <property name="bDao" ref="bDao" />
        <property name="cDao" ref="cDao" />
    </bean>

    <bean id="bDao" class="com.model.dao.bDaoImpl">
        <property name="sessionFactory" ref="hibernate3SessionFactory" />
    </bean>

    <bean id="cDao" class="com.model.dao.cDaoImpl">
        <property name="sessionFactory" ref="hibernate3SessionFactory" />
    </bean>
    <bean id="aDao" class="com.model.dao.aDaoImpl">
        <property name="sessionFactory" ref="hibernate3SessionFactory" />
    </bean>

     <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
        <property name="sessionFactory" ref="hibernate3SessionFactory" />
    </bean>
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="get*" read-only="true" />
            <tx:method name="*" propagation="REQUIRED" />
        </tx:attributes>
    </tx:advice>
    <aop:config>
        <aop:pointcut id="boMethods" expression="execution(* com.model.bo.*.*(..))" />

        <aop:advisor advice-ref="txAdvice" pointcut-ref="boMethods" />
    </aop:config> 
    </beans>

抛出的错误：

类 org.springframework.beans.factory.BeanCreationException 错误 创建在类路径资源中定义的名称为“dataSource”的bean [resources/spring/config/BeanLocations.xml]: BeanPostProcessor 之前 bean 的实例化失败；嵌套异常是 org.springframework.beans.factory.BeanCreationException：错误 用名字创建bean 'org.springframework.aop.support.DefaultBeanFactoryPointcutAdvisor#0'： 设置 bean 时无法解析对 bean 'boMethods' 的引用 属性“切入点”；嵌套异常是 org.springframework.beans.factory.BeanCreationException：错误 创建名为“boMethods”的 bean：bean 实例化失败； 嵌套异常是 java.lang.NoClassDefFoundError： org/aspectj/weaver/BCException

public class DBoImpl implements DBo {

    private DDao dDao;
    private BDao bDao;


    public DDao getDDao() {
        return dDao;
    }

    public void setDDao(DDao dDao) {
        this.dDao = dDao;
    }

    public BDao getbDao() {
        return bDao;
    }

    public void setbDao(BDao bDao) {
        this.bDao = bDao;
    }

public D add(D r) {
        dDao.saveOrUpdate(r);
        return r;
    }

}

Answer 1

您的类路径中似乎没有 AOP jar 文件。

见： http://docs.spring.io/spring/docs/current/spring-framework-reference/html/aop.html

查找“10.2.1 启用@AspectJ 支持”部分

Answer 2

将 AOP 用于事务行为很好。我建议看看annotation based configuration（注意<tx:annotation-driven transaction-manager="transactionManager" />），这可能更简单一些。

此外，我会小心使用此配置。事务旨在封装一个原子工作单元。拥有像saveOrUpdate(EntityType entity) 这样的方法我认为您的原子工作单元正在保存一个实体，而不是保存n 个实体。事务运行的时间越长，发生死锁的可能性就越大。

我建议创建一个像 public void saveOrUpdateInBatch(MyObject... objects) 这样的方法。顾名思义，您正在处理一个处理许多元素的原子操作。此外，您可能希望针对批量插入优化此方法。