Соединение JDBC внутри слоя DAO

Question

Добрый день,
Я пытаюсь создать слой DAO, следуя главным образом this guide.
Обратите внимание, что я не использую никаких фреймворков, просто JDBC.

Посмотрите на создание экземпляра соединения:
Внутри каждого метода CRUD мы получаем связь следующим образом:

Connection connection = daoFactory.getConnection(); 

Таким образом, мы получаем новое соединение каждый раз, когда мы вызываем метод.
Единственный вопрос, который у меня есть, - как реализовать транзакции здесь?
Я вижу два решения:

1. Вместо DaoFactory поле, я использую поле Connection, которое я разделяю среди методов. Чтобы иметь одно соединение на DAO. Но тогда, какой уровень должен отвечать за транзакцию? Должен ли я создать что-то между Сервисом - DAO?
2. Я создаю поля для других экземпляров DAO, необходимых для создания транзакции. Так, например, я бы имел TransactionDao для реализации banktransfer (возьмите деньги у одного пользователя и добавьте в другой), и у этого TransactionDao будет также UserDao, потому что я должен сделать одно создание и два действия обновления.

Я хочу знать правильное решение, возможно, это ни один из вышеперечисленных.
Скажите, пожалуйста, есть ли какие-либо проблемы с параллелизмом, о которых я должен беспокоиться?
Спасибо

Answer 1

Самое простое решение, чтобы всегда выполнять транзакции в рамках одного метода DAO, захватывая соединение в начале метода и передачи его остальным методам, которые работают SQL, который должен быть частью этого сделка. Я бы посоветовал вам откатить свою альтернативу этому упрощенному подходу. Весна позволит вам сделать это с помощью волшебства за кулисами, и я уверен, что есть другие рамки для этого, десятки из них, но если вы хотите сохранить его простым, держите его простым. Если некоторые из этих методов также автономный вид, я бы сделал что-то вроде этого:

public void incBalance(int accountId, int val) { 
    Connection conn = daoFactory.getConnection(); 
    incBalance(conn, accountId, val); 
} 

private void incBalance(Connection conn, int accountId, int val) { 
    con.update(...); 
} 

public void transfer(...) { 
    Connection conn = daoFactory.getConnection(); 
    conn.beginTransaction(); 
    ... 
    incBalance(conn, acc1, val); 
    incBalance(conn, acc2, -val); 
    ... 
    conn.commit(); 
}