Spring：Propagation.REQUIRED not working

Question

我在几张表中插入记录，即Dept和Emp。如果Dept表成功创建，那么只需要在Emp表中插入记录。另外，如果Emp中的任何插入失败，那么我想要回滚所有包含从Emp以及Dept表中回滚的事务。

这个我试过用Propagation.REQUIRED如下图所示：

Java文件

public void saveEmployee(Employee empl){ 
    try { 
     jdbcTemplate.update("INSERT INTO EMP VALUES(?,?,?,?,?)",empl.getEmpId(),empl.getEmpName(), 
       empl.getDeptId(),empl.getAge(),empl.getSex()); 
    } catch (DataAccessException e) { 
     e.printStackTrace(); 
    } 

} 

@Transactional(propagation=Propagation.REQUIRED) 
public void saveRecords(){ 
    saveDepartment(dept); 
    saveEmployee(empl);  
} 

的context.xml

<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/> 

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

问题：

即使插入Emp表失败，Dept插入正在持续，我不想。我想回滚一切。

请建议。

Answer 1

问题是你的catch块。由于异常被捕获，tx不会回滚。

必须抛出异常：

public void saveEmployee(Employee empl){ 
    try { 
     jdbcTemplate.update("INSERT INTO EMP VALUES(?,?,?,?,?)",empl.getEmpId(),empl.getEmpName(), 
       empl.getDeptId(),empl.getAge(),empl.getSex()); 
    } catch (DataAccessException e) { 
     e.printStackTrace(); 
     throw e; 
    } 

} 

顺便说一下，语义的Progation.Required只是意味着：创建一个新的TX，如果它不存在，或使用现有的，如果有tx正在运行。

---

按照您的评论这里是一个建议，看看新的TX的效果：

@Transactional(propagation=Propagation.REQUIRES_NEW) 
public void saveEmployee(Employee empl){ 
    try { 
     jdbcTemplate.update("INSERT INTO EMP VALUES(?,?,?,?,?)",empl.getEmpId(),empl.getEmpName(), 
       empl.getDeptId(),empl.getAge(),empl.getSex()); 
    } catch (DataAccessException e) { 
     e.printStackTrace(); 
     throw e; 
    } 

} 

@Transactional(propagation=Propagation.REQUIRED) 
public void saveRecords(){ 
    saveDepartment(dept); 
    try{ 
     saveEmployee(empl); 
    }catch(Exception e){Logger.log("Fail to save emp !");}  
} 

的关键点上可看到REQUIRES_NEW的效果是捕捉周围saveEmployee例外。如果你没有捕获它：异常将在另一个tx中传播（在进入saveRecords（）时启动的异常），它也会回滚。