Всем здравствуйте!
Подскажите пожалуйста, как заставить EntityManager откатывать изменения, т.е. делать rollback для транзакции?
Работает вот такой вот код:
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.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
eManager.getTransaction().begin();
// eManager.joinTransaction();
// eManager.getTransaction().setRollbackOnly();
// eManager.setFlushMode(FlushModeType.COMMIT);
try {
// eManager.persist(contract);
EntityUtils.saveEntity(eManager, contract, contract.getContractId());
if (contract.getContractStatus() == null && commonContract.getContractStatus() != null) {
contractStatus = new ContractStatus(commonContract.getContractStatus());
contract.setContractStatus(contractStatus);
contractStatus.setContractId(contract.getContractId());
} else {
contractStatus = contract.getContractStatus();
contractStatus.setContractStatusDate(new Date());
contractStatus.setContractStatusUser(AlfaPolicyApplication.getInstance()
.getCurrentShortUser().toUpperCase());
contractStatus.setContractStatusType(commonContract.getContractStatus());
}
contractStatus.setContracts(new ArrayList<Contract>());
contractStatus.addContracts(contract);
// eManager.flush();
contractConditionFactory = new ContractConditionFactory();
for (Iterator<ContractVariant> itrCV = contractConditionFactory.getContractVariant(contractId).iterator(); itrCV.hasNext();) {
contractVariant = itrCV.next();
contractVariant.setLiabilityBeginDate(contract.getActionBeginDate());
contractVariant.setLiabilityEndDate(contract.getActionEndDate());
// contractVariant.setContractId(contract.getContractId());
contractVariant.setContract(contract);
contract.addContractVariants(contractVariant);
// eManager.persist(contractVariant);
// eManager.flush();
contractConditionFactory.PrepareContractConditions(product, contract, contractVariant, premium, transport, eManager);
}
// eManager.flush();
eManager.getTransaction().commit();
// transaction.commit();
eManager.getTransaction().begin();
for (Iterator<ContractVariant> itrCV = contractConditionFactory
.getContractVariant(contract.getContractId()).iterator();
itrCV.hasNext();) {
contractVariant = itrCV.next();
contractConditionFactory.PreparePremiums(product, contract, contractVariant, premium, eManager);
EntityUtils.saveEntity(eManager, contractVariant, contractVariant.getContractVariantId());
}
eManager.getTransaction().commit();
AlfaPolicyApplication.getInstance().getMainWindow().showNotification("Завершили сохранение!!! Проверь в базе!");
eManager.refresh(contract);
} catch (Exception e) {
AlfaPolicyApplication.getInstance().getMainWindow()
.showNotification("Во время сохранения возникла ошибка! Обратитесь в SD.", Notification.TYPE_ERROR_MESSAGE);
if (eManager.getTransaction().isActive())
eManager.getTransaction().rollback();
else {
if (contractId == null) {
eManager.getTransaction().begin();
contract = eManager.find(Contract.class, contract.getContractId());
eManager.remove(contract);
eManager.getTransaction().commit();
}
}
e.printStackTrace();
}
eManager.close();
Создаю транзакцию вот таким вот способом -> eManager.getTransaction().begin();
Делаю EntityUtils.saveEntity(eManager, contract, contract.getContractId());, т.е. сохраняю сущность contract в базу.
Код процедуры:
1.
2.
3.
4.
5.
6.
public static void saveEntity(EntityManager manager, Object entity, Object Id) {
if (Id == null)
manager.persist(entity);
else
manager.merge(entity);
}
Затем говорю commit, вот таким вот образом -> eManager.getTransaction().commit();. По ошибке происходит падение, сущность на которой произошло падение она логичным образом не вставляется в базу... а вот другие, вставлены... и какEntityManager-у сказать сделай rollback, я не понимаю, т.к. на этапе eManager.getTransaction().commit();, JPA завершает транзакцию и на этапе eManager.getTransaction().rollback(); получаем ошибку о том, что транзакция уже не активна... Люди добрые, подскажите пожалуйста, что я делаю не так?
P.S. Сервак weblogic, тип транзакции JTA
1.
<persistence-unit name="oraPU" transaction-type="JTA">
Для тех, кто скажет, что нужно работать через eManager.joinTransaction();, пробовал, валится с ошибкой, не могу найти активную транзакцию...
Всем заранее спасибо за ответ...
