01: package com.completex.objective.components.persistency.core.impl;
02:
03: import com.completex.objective.components.log.Log;
04: import com.completex.objective.components.persistency.core.DatabasePolicy;
05: import com.completex.objective.components.persistency.transact.Transaction;
06:
07: import javax.transaction.UserTransaction;
08: import java.sql.SQLException;
09:
10: /**
11: * @author Gennady Krizhevsky
12: */
13: public class JtaDatabaseTransactionImpl extends DatabaseTransactionImpl {
14:
15: private UserTransaction userTransaction;
16:
17: public JtaDatabaseTransactionImpl(UserTransaction userTransaction,
18: Transaction transaction, DatabasePolicy databasePolicy,
19: boolean useBatchModify, Log logger) {
20: super (transaction, databasePolicy, useBatchModify, logger);
21: this .userTransaction = userTransaction;
22: }
23:
24: public JtaDatabaseTransactionImpl(UserTransaction userTransaction,
25: Transaction transaction, DatabasePolicy databasePolicy,
26: boolean useBatchModify) {
27: super (transaction, databasePolicy, useBatchModify);
28: this .userTransaction = userTransaction;
29: }
30:
31: public void commit() throws SQLException {
32: flush();
33: }
34:
35: public void rollback() throws SQLException {
36: flush();
37: }
38:
39: public UserTransaction getUserTransaction() {
40: return userTransaction;
41: }
42:
43: }
|