如何修复Spring批处理中没有事务正在进行

Question

当我尝试使用spring batch中的作业处理器将从csv文件恢复的一些数据持久化到我的数据库中时，控制台中会出现这个错误，对于我的dao来说，我使用的是hibernate

我已经尝试了2种方法，但同样的问题！

    Session session = factory.getCurrentSession();
    session.saveOrUpdate(p);

    Session session = factory.openSession();
    session.beginTransaction();
    session.save(p);
    session.getTransaction().commit();
    session.close();

<bean name="dataSource"
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/yassir" />
        <property name="username" value="root" />
        <property name="password" value="" />
    </bean>


    <bean id="sessionFactory"
        class="org.springframework.orm.hibernate5.LocalSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="annotatedClasses">
            <list>
                <value>tp.entities.Personne</value>
            </list>
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</prop>
                <prop key="hibernate.show_sql">true</prop>
                <prop key="hibernate.hbm2ddl.auto">update</prop>
            </props>
        </property>
    </bean>


    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <tx:annotation-driven />

错误：javax.persistence.transactionRequiredException：在org.hibernate.internal.sessionimpl.checktransactionNeed(sessionimpl.java:3450)在org.hibernate.internal.sessionimpl.doFlush（sessionimpl.java:1418)在org.hibernate.internal.sessionimpl.flush（sessionimpl.java:1414).

Answer 1

您将Spring Batch配置为使用DataSourceTransActionManager来驱动事务。该事务管理器对您的Hibernate上下文一无所知。您需要使用HibernateTransactionManager使编写器中的Hibernate会话参与Spring批处理托管事务。

我还建议使用HibernateItemWriter，而不是创建自定义writer(PersonneWriter)手动创建会话和管理事务。

在这里可以找到类似的问题/答案：Spring Batch JpaItemWriter vs HibernateItemWriter以及为什么在使用HibernateItemWriter时需要HibernateTransactionManager

希望这能有所帮助。