У меня есть 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>
Мне нужно создать методы в двух этих классах Transactional, но Datasource отличается в каждом экземпляре классов.Теперь у меня ошибка - не найдена существующая транзакция для транзакции, помеченной с распространением «обязательный».
Первый класс обновляет базу данных новыми параметрами учетной записи, а второй класс просто вставляет текст в отдельной таблице об этой транзакции.Если транзакция не удалась, второй класс не должен вставлять какую-либо информацию.
Я действительно не хочу объединять весь код в одном классе, я хотел бы сохранить его разделенным.
Есть ли какой-либо метод для использования ОДНОГО ЕДИНОГО источника данных для всех классов ??