Блог

Я вставляю записи в пару таблиц, а именно 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 вставка сохраняется, чего я не хочу. Я хочу откатить все.

Пожалуйста, предложите.

Проблема в вашем блоке 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;
    }

}
  

И, кстати, семантика продвижения.Требуется просто означает: создайте новый 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 !");}     
}
  

Ключевым моментом, позволяющим увидеть эффект REQUIRE_NEW, является перехват исключения вокруг saveEmployee . Если вы его не поймаете: исключение будет распространяться в другом tx (тот, который начался при вводе saveRecords() ), и он тоже будет откатываться.