Во-первых, я не могу использовать декларативный подход @Transactional, так как приложение имеет несколько источников данных JDBC, я не хочу утомлять деталями, но достаточно сказать, что методу DAO передается правильный источник данных для выполнения логика. Все источники данных JDBC имеют одинаковую схему, они разделены, так как я предоставляю остальные службы для системы ERP.
Из-за этой устаревшей системы существует много долгоживущих заблокированных записей, которые я не могу контролировать, поэтому я хочу грязное чтение.
Используя JDBC, я бы выполнил следующее:
private Customer getCustomer(DataSource ds, String id) {
Customer c = null;
PreparedStatement stmt = null;
Connection con = null;
try {
con = ds.getConnection();
con.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
stmt = con.prepareStatement(SELECT_CUSTOMER);
stmt.setString(1, id);
ResultSet res = stmt.executeQuery();
c = buildCustomer(res);
} catch (SQLException ex) {
// log errors
} finally {
// Close resources
}
return c;
}
Ладно, много шаблонного, я знаю. Итак, я попробовал JdbcTemplate, так как использую Spring.
Использовать шаблон Jdbc
private Customer getCustomer(JdbcTemplate t, String id) {
return t.queryForObject(SELECT_CUSTOMER, new CustomerRowMapper(), id);
}
Гораздо лучше, но по-прежнему используется изоляция транзакций по умолчанию. Мне нужно как-то это изменить. Поэтому я подумал об использовании TransactionTemplate.
private Customer getCustomer(final TransactionTemplate tt,
final JdbcTemplate t,
final String id) {
return tt.execute(new TransactionCallback<Customer>() {
@Override
public Customer doInTransaction(TransactionStatus ts) {
return t.queryForObject(SELECT_CUSTOMER, new CustomerRowMapper(), id);
}
});
}
Но как здесь установить изоляцию транзакций? Я не могу найти его ни в обратном вызове, ни в TransactionTemplate, чтобы сделать это.
Я читаю Spring в действии, третье издание, в котором объясняется, насколько я это сделал, хотя в главе о транзакциях продолжается использование декларативных транзакций с аннотациями, но, как уже упоминалось, я не могу использовать это, поскольку мой DAO должен определить в runtime, какой источник данных использовать на основе предоставленных аргументов, в моем случае код страны.
Любая помощь будет принята с благодарностью.
