我已经搜索了这个问题,有相当多的他们在这里的StackOverflow和谷歌,但我似乎不能得到任何为我工作。
下面是我的代码Spring配置:(我不使用任何切入点-我想我不需要?)
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
...
</bean>
<bean id="hibernateSessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
...
</bean>
<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="hibernateSessionFactory"/>
</bean>
<tx:annotation-driven transaction-manager="transactionManager"/>
我有一个服务类:
@Service
public class ServiceImpl implements ServiceInterface
{
/**
* Injected session factory
*/
@Autowired(required=true)
private SessionFactory sessionFactory;
@Autowired(required=true)
private Dao myDao;
/**
* {@inheritDoc}
*/
@Transactional(rollbackFor=Exception.class, propagation=Propagation.REQUIRED)
public void scheduleBlast(BlastParameters blastParameters) throws ServiceException
{
... do bunch of stuff ..
myDao.persist(entity)
if(true)
throw new ServiceException("random error")
}
.. setter methods and other stuff ..
}
和一个刀类:
public class DaoImpl implements DaoInterface
{
@Autowired(required=true)
private SessionFactory sessionFactory
/**
* {@inheritDoc}
*/
@Transactional(propagation=Propagation.MANDATORY)
public void persist(Entity e) throws DaoException
{
try
{
sessionFactory.getCurrentSession().persist(e);
}
catch(Exception ex)
{
throw new DaoException(ex);
}
}
.. setter methods and other stuff ..
}
一些不必要的细节被删除(例如,丢失setter等),假设代码工作完美。
我对上面的问题是,当我添加throw random异常行时,它不会回滚,通过DAO持久化的对象仍保留在数据库中。
我使用的是Spring 3.1和Hibernate 3.6(因为Spring 3.1上的Hibernate 4.0有一个bug)
有什么想法?
谢谢
5条答案
按热度按时间mnemlml81#
我找到了问题的原因,以及为什么事务(看起来)没有得到正确管理。
在我的代码里
它说“--这里有一些逻辑--"的部分,有一些使用原始SQL并调用execute update的逻辑:
因为它没有使用Hibernate查询,而是使用原始SQL执行,所以它导致了一个刷新被调用,因此在调用之前所做的任何工作都将与它沿着提交。
我重新设计了逻辑流来解释这个逻辑,以确保事务得到正确的管理。虽然使用原始SQL可能表明存在问题-但由于服务试图完成的事情以及提高服务性能,这是必须要做的事情。
vsikbqxv2#
这是事务管理的预期行为。@Transactional的默认行为是仅对运行时异常进行回滚。如果您希望在抛出DaoException后回滚,请将其添加到回滚异常列表中。不要忘记还包括RuntimeException。在Dao类@Transactional上尝试以下操作(propagation=Propagation.Mandatory,rollbackFor={RuntimeException.class,DaoException.class})
tsm1rwdh3#
尝试从DaoImpl类中删除@Transactional注解。我怀疑可能发生的情况是,当事务跨越事务边界(DaoImpl)时,事务正在被提交。我在此设置中获得了好坏参半的成功。您可以尝试一些不同的事务方法来处理“内部”事务。
你可以做的另一件事是打开spring事务日志。它认为它的类别是org.springframework.transaction或其他什么。这样你就会看到它在做什么w.r.t来回滚和提交事务...
bvjxkvbb4#
您没有缺省情况下处于AUTOCOMMIT模式的JDBC驱动程序,是吗?
t3irkdon5#
我在Spring仓库中手动打开连接时遇到了同样的问题。开始使用JdbcTemplate后,错误消失了
我以前
在我的存储库中
然后是
jdbc.query(sql, new RowMapper());
或jdbc.update(sql);
或jdbc.queryForObject(sql, new RowMapper());
,具体取决于查询返回的对象数量。我还定义了RowMapper():