Spring中具有多个数据源的事务答案

【问题标题】：Transactions with multiple datasources in SpringSpring中具有多个数据源的事务
【发布时间】：2018-11-25 20:13:16
【问题描述】：

我有 2 个类用于使用 JDBC 和 Sqlite。这些类使用抽象类来扩展：

package atm.implementations;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;

import javax.sql.DataSource;

public abstract class AbstractDAO {

    NamedParameterJdbcTemplate jdbcTemplate;

    @Autowired
    public void setDataSource(DataSource dataSource) {
        this.jdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
    }
}

头等舱：

package atm.implementations;

import atm.dao.SQLiteDAO;
import atm.objects.Bank;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.sql.ResultSet;
import java.sql.SQLException;

@Component("bankDAO")
public class BankDAO extends AbstractDAO implements SQLiteDAO<Bank> {


@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.SERIALIZABLE)
    public void updateRecord(Bank object) {

        String sqlUpdate = "update bank set account_value = :value where id = :id";
        MapSqlParameterSource params = new MapSqlParameterSource();
        params.addValue("value", object.getAccountValue());
        params.addValue("id", object.getId());

        jdbcTemplate.update(sqlUpdate, params);
    }
}

第二个：

package atm.implementations;

import atm.dao.TranDAO;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Component("transDAO")
public class TranDAOImpl extends AbstractDAO implements TranDAO {

    @Transactional(propagation = Propagation.MANDATORY, isolation = Isolation.SERIALIZABLE)
    public void insert(String desc) {

        String sqlInsert = "insert into transactions_list (description) values (:descr)";
        MapSqlParameterSource params = new MapSqlParameterSource();
        params.addValue("descr", desc);

        jdbcTemplate.update(sqlInsert, params);
    }
}

这里是 context.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <context:component-scan base-package="atm.*"/>
    <aop:aspectj-autoproxy proxy-target-class="true"/>


    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="username" value=""/>
        <property name="password" value=""/>
        <property name="url" value="jdbc:sqlite:atm.db"/>
        <property name="driverClassName" value="org.sqlite.JDBC"/>
    </bean>

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

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


</beans>

我需要将这两个类中的方法设置为事务性的，但每个类实例中的数据源都不同。现在我有错误 - 没有找到标记为传播“强制”的交易的现有交易。

第一类使用新的帐户参数更新数据库，第二类只是在单独的表中插入有关此交易的文本。如果事务失败，第二类不应插入任何信息。

我真的不想将所有代码加入一个类，我想将它分开。

是否有任何方法可以为所有类使用一个单一的数据源？？

【问题讨论】：

标签： java spring jdbc transactions

【解决方案1】：

TranDAOImpl#insert 标有 MANDATORY-Transaction-Propagation。意思是，调用者必须有一个活动的事务。我怀疑你在调用这个方法时遇到了异常？

所以调用者本身应该用“REQUIRED”或“REQUIRES_NEW”注解。我不认为您的问题与使用不同的数据源有关。如果您的 Spring 接线正确完成，事务管理器应该以安全的方式处理它。

【讨论】：