Ако използвате обикновен JDBC, това, което бихте могли да направите, е да споделите същия екземпляр на Connection
в двата екземпляра на класовете DAO.
public class EmployeeDAO {
private Connection conn;
public void setConnection(Connection conn) {
this.conn = conn;
}
...
}
public class BankDAO {
private Connection conn;
public void setConnection(Connection conn) {
this.conn = conn;
}
...
}
В клиентския код първо трябва да създадете Connection
екземпляр на обекта. След това трябва да стартирате транзакцията с conn.setAutoCommit(false);
. Предайте Connection
екземпляр на обект към двата класа DAO. Ако не възникнат грешки при която и да е операция, conn.commit();
, в противен случай conn.rollback();
напр.:
Connection conn = null;
try {
// getConnection from pool
conn.setAutoCommit(false);
EmployeeDAO employeeDAO = new EmployeeDAO();
employeeDAO.setConnection(conn);
BankDAO bankDAO = new BankDAO();
bankDAO.setConnection(conn);
// save employee
// save bank details
conn.commit();
catch(Exception e) {
if (conn != null) {
conn.rollback();
}
} finally {
if (conn != null) {
conn.close();
}
}