1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
Пользователь 1 | Пользователь 2
==========================================================================
1) Open ТРАНЗАКЦИЯ-1 | ----
ТРАНЗАКЦИЯ-1 – Query Data=X |
--------------------------------------------------------------------------------------
| Open ТРАНЗАКЦИЯ-2
2) ---- | ТРАНЗАКЦИЯ-2 – Query Data=X
--------------------------------------------------------------------------------------
3) ТРАНЗАКЦИЯ-1 – Update Data=X+1 |
And Commit | -----
Close ТРАНЗАКЦИЯ-1 |
--------------------------------------------------------------------------------------
4) ---- | ТРАНЗАКЦИЯ-2 – Update Data=X+1
| And Commit
| Close ТРАНЗАКЦИЯ-2
На 4) шаге должен выйти Exception, и ТРАНЗАКЦИЯ-2 должна откатиться так как ТРАНЗАКЦИЯ-1 уже поменяла значение X на X+1, тогда как ТРАНЗАКЦИЯ-2 уже работает с устаревшими данными.
Данная задача реализована ниже, с использованием Оптимистической блокировки и @Version (в Entity поле Integer mgr ), где транзакция контролируется BMT (bean-managed transaction) и ВСЯ транзакция ( Открывается Тр. –> Запрос –> Обновление данных -> Commit -> Закрывается Тр.) происходит в одном методе через javax.transaction.UserTransaction.
Вопросы :
1) Как Запрос данных, Обновление данных и Commit поместить в одну транзакцию, с использованием WEB, тогда как Запрос и обновление будут разделены в отдельных методах (или Bean-ах) ?
2) Может есть какое-то стандартное решение данной задачи ?
3) Какую технологию Web лучше использовать совместно с EJB, для более гибкого контроля транзакциями?
Листинг 1. EJB Session Bean
==============================================================================
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
@Stateless
@LocalBean
@TransactionManagement(TransactionManagementType.BEAN)
public class myBean implements myBeanLocal {
@PersistenceContext(unitName="ModelDDL")
private EntityManager emDDL;
@Resource
private UserTransaction ut;
public void incSal() throws NotSupportedException, SystemException, SQLException {
{
// -- Открывается Тр.
ut.begin();
try {
// -- Запрос данных
Emp emp1 = emDDL.find(Emp.class, new BigDecimal(7369));
// 5 sec timeout
.......
// -- Обновление данных
emp1.setSal(new Integer(emp1.getSal().intValue()+100));
// -- commit
ut.commit();
// Закрывается Тр.
} catch (OptimisticLockException e) {
......
}
}
catch (Exception e){
......
}
}
}
}
==============================================================================
Листинг 2. EJB Entity bean “Emp.java”
==============================================================================
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
@Entity
public class Emp implements Serializable {
@Id
@Column(nullable = false)
private BigDecimal empno;
..................
@Version
private Integer mgr;
private Integer sal;
..................
==============================================================================
