2

我有这个 Web 服务，它基本上查询数据库并返回所有持久化的实体。出于测试目的，我创建了一个 TestDataManager，它在加载 Spring 上下文后保留 2 个示例实体（顺便说一句，我使用的是 JAX-WS、Spring、Hibernate 和 HSQLDB）。

我的 TestDataManager 看起来像这样：

@Component
public class TestDataManager {

@Resource
private SessionFactory sf;

@PostConstruct
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
public void insertTestData(){
    sf.openSession();
    sf.openSession().beginTransaction();
    sf.openSession().persist(new Site("site one"));
    sf.openSession().persist(new Site("site two"));
    sf.openSession().flush();
}
}

我的 JAX-WS 端点如下所示：

@WebService
public class SmartBrickEndpoint {

@Resource
private WebServiceContext context;

public Set<Site> getSitesForUser(String user){
    return getSiteService().findByUser(new User(user));
}

private ISiteService getSiteService(){
    ServletContext servletContext = (ServletContext) context.getMessageContext().get("javax.xml.ws.servlet.context");
    return (ISiteService) BeanRetriever.getBean(servletContext, ISiteService.class);
}
}

这是我的服务类：

@Component
@Transactional(readOnly = true)
public class SiteService implements ISiteService {

@Resource
private ISiteDao siteDao;

@Override
public Set<Site> findByUser(User user) {
    return siteDao.findByUser(user);
}
}

这是我的 DAO：

@Component
@Transactional(readOnly = true)
public class SiteDao implements ISiteDao {

@Resource
private SessionFactory sessionFactory;

@Override
public Set<Site> findByUser(User user) {
    Set<Site> sites = new LinkedHashSet<Site>(sessionFactory.getCurrentSession().createCriteria(Site.class).list());

    return sites;
}
}

这是我的 applicationContext.xml：

<context:annotation-config />
<context:component-scan base-package="br.unirio.wsimxp.dao"/>
<context:component-scan base-package="br.unirio.wsimxp.service"/>
<context:component-scan base-package="br.unirio.wsimxp.spring"/>

<bean id="applicationDS" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
    <property name="url" value="jdbc:hsqldb:file:sites"/>
</bean>

<bean id="sessionFactory"
      class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
    <property name="dataSource" ref="applicationDS" />

    <property name="configLocation">
        <value>classpath:hibernate.cfg.xml</value>
    </property>

    <property name="hibernateProperties">
        <props>
            <prop key="hibernate.dialect">org.hibernate.dialect.HSQLDialect</prop>
            <prop key="hibernate.show_sql">true</prop>
            <prop key="hibernate.format_sql">true</prop>
            <prop key="hibernate.connection.release_mode">on_close</prop>
            <!--<prop key="hibernate.current_session_context_class">thread</prop>-->
            <prop key="hibernate.query.factory_class">org.hibernate.hql.classic.ClassicQueryTranslatorFactory</prop>
            <prop key="hibernate.hbm2ddl.auto">create-drop</prop>
        </props>
    </property>
</bean>

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

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

这就是现在发生的事情：

  1. 部署应用程序时，TestDataManager#insertTestData 启动（由于@PostConstruct）并且持久化不会引发任何异常。我现在应该在数据库中有 2 个实体。
  2. 之后，我通过 SOAP 客户端调用端点，请求一直到达 DAO。Hibernate 调用不会引发任何异常，但返回的列表是空的。

奇怪的是，在 TestDataManager 中，如果我从 切换sf.openSession()到sf.getCurrentSession()，我会收到一条错误消息：“没有 Hibernate Session 绑定到线程，并且配置不允许在此处创建非事务性会话”。

我在这里做错了什么？为什么查询“没有看到”持久化实体？为什么我需要sf.openSession()在 TestDataManager 上调用，尽管它带有注释@Transactional？

我hibernate.current_session_context_class=thread在 application.xml 中做了一些测试，但是我只是在每个类中切换问题。我不想手动调用sf.openSession()并将其留给 Hibernate 来处理。

非常感谢您的帮助！

4

3 回答 3

1

（我在 jpa 模式下使用休眠）

我认为您的事务注释没有被正确拦截。您是否指定了 HibernateVendorAdapter？在 jpa+hibernate 中，没有它，集成就没有完全设置好！您很可能缺少此声明。

在您应该能够直接自动装配会话而不是工厂之后。

作为旁注。如果您在代码中使用 opensession 至少只调用一次并将会话保存在变量中。否则你总是在每次通话时打开一个新的，我相信。

于 2013-06-30T12:25:16.377 回答
1 
@PostConstruct
public void insertTestData(){
  Obejct o = new TransactionTemplate(transactionManager).execute(new TransactionCallback() {
    public Object doInTransaction(TransactionStatus status) {
      //Your code here
    }
  });
}

来源： http: //forum.springsource.org/showthread.php?58337-No-transaction-in-transactional-service-called-from-PostConstruct &p=194863#post194863

于 2013-07-02T15:46:50.290 回答
1

我认为您需要在以下时间提交交易insertTestData：

@PostConstruct
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
public void insertTestData(){
    Session session = sf.openSession();

    session.persist(new Site("site one"));
    session.persist(new Site("site two"));
    session.flush();
    session.close();
}
于 2013-06-30T10:19:29.140 回答