弹簧传播requires_new不起作用



我有以下场景,其中我有 2 个服务层负责将数据插入到 emp table 和 dept 表中。

我已经编写了查询以在 dept 表上插入失败,即 deptno 无法接受长度为> 2 的 deptno,因此由于违反数据完整性,它不会插入到 db 中。我不希望我以前的交易依赖于此交易。所以使用了REQUIRES_NEW传播级别。

这是我的代码。

@Component
public class EmployeeServiceImpl implements EmployeeService {
    @Autowired
    private EmployeeDao employeeDao;
    @Autowired
    private DeptService deptService;
    @Transactional(propagation = Propagation.REQUIRED)
    public boolean createEmployee() {
        employeeDao.insertEmployee();
        deptService.createDept();
        return false;
    }
}
@Component
public class DeptServiceImpl implements DeptService {
    @Autowired
    private DeptDao deptDao;
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public boolean createDept() {
        deptDao.insertDepartment();
        return false;
    }
}

下面是道层

@Component
public class EmployeeDaoImpl implements EmployeeDao {
    private String empInsert = "INSERT INTO emp VALUES ('1000','Ravi','CLERK','7782','1990-01-01','1235.00',NULL,'50');";
    @Autowired
    private JdbcTemplate jdbcTemplate;
    public boolean insertEmployee() {
        int n = jdbcTemplate.update(empInsert);
        return true;
    }
}
@Component
public class DeptDaoImpl implements DeptDao {
    private String deptInsert = "INSERT INTO dept VALUES ('500','MATERIAL','ALASKA');";
    @Autowired
    private JdbcTemplate jdbcTemplate;
    public boolean insertDepartment(){
        jdbcTemplate.update(deptInsert);
        return true;
    }
}

以下代码从主类调用

public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("txrequirednew.xml");
        EmployeeService es = (EmployeeService) context.getBean("employeeServiceImpl");
        es.createEmployee();
    }

以下是我的应用程序上下文:

   <beans>
     <context:annotation-config/>
        <context:component-scan base-package="txrequirednew">
    </context:component-scan>
        <bean id="dataSource" class="org.springframework.jdbc.datasource.SingleConnectionDataSource">
            <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
            <property name="url" value="jdbc:mysql://localhost:3306/tejadb"></property>
            <property name="username" value="root"/>
            <property name="password" value="sai"/>
        </bean>
        <!-- Dao Configurations-->
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"/>
        </bean>
        <tx:annotation-driven transaction-manager="transactionManager" />
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource" />
        </bean>
    </beans>

当我尝试执行时,两个事务都被回滚。但我不希望我的第一个事务被回滚。

我在这里缺少什么,导致两个事务都回滚?我该如何解决这个问题。

如果通过requires_new传播进行内部转换回滚,则事务范围是正确的,它不应该影响外部转换,因为

PROPAGATION_REQUIRES_NEW为给定范围启动一个新的、独立的"内部"事务。此事务将完全独立于外部事务提交或回滚,具有自己的隔离作用域、自己的锁集等。外部事务将在内部事务开始时暂停,并在内部事务完成后恢复。...

但是你应该处理内部方法抛出的异常,如果你没有处理它们,它将回滚外部事务。Spring 框架事务将仅回滚 RunTimeException,而不是其他已检查的例外,如 SqlException。

最新更新