You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2019/11/21 16:54:06 UTC
[jena] branch master updated: Update Transactional usage template
This is an automated email from the ASF dual-hosted git repository.
andy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/jena.git
The following commit(s) were added to refs/heads/master by this push:
new c06fd2b Update Transactional usage template
c06fd2b is described below
commit c06fd2b2ddc488a92c499aa786312e5e50b8a452
Author: Andy Seaborne <an...@apache.org>
AuthorDate: Thu Nov 21 16:54:51 2019 +0000
Update Transactional usage template
---
.../apache/jena/sparql/core/TransactionalLock.java | 45 ++++++++++++----------
1 file changed, 24 insertions(+), 21 deletions(-)
diff --git a/jena-arq/src/main/java/org/apache/jena/sparql/core/TransactionalLock.java b/jena-arq/src/main/java/org/apache/jena/sparql/core/TransactionalLock.java
index 1c0ce6f..9dd499d 100644
--- a/jena-arq/src/main/java/org/apache/jena/sparql/core/TransactionalLock.java
+++ b/jena-arq/src/main/java/org/apache/jena/sparql/core/TransactionalLock.java
@@ -33,35 +33,38 @@ import org.apache.jena.sparql.JenaTransactionException ;
* To use with implementation inheritance, for when you don't inherit:
* <pre>
* private final Transactional txn = TransactionalLock.createMRSW() ;
- * {@literal @}Override public void begin(TxnType txnType) { txn.begin(txnType) ; }
- * {@literal @}Override public void begin() { txn.begin(); }
- * {@literal @}Override public void begin(TxnType txnType) { txn.begin(txnType); }
- * {@literal @}Override public void begin(ReadWrite mode) { txn.begin(mode); }
- * {@literal @}Override public boolean promote() { return txn.promote(); }
- * {@literal @}Override public void commit() { txn.commit(); }
- * {@literal @}Override public void abort() { txn.abort(); }
- * {@literal @}Override public boolean isInTransaction() { return txn.isInTransaction(); }
- * {@literal @}Override public void end() { txn.end(); }
- * {@literal @}Override public ReadWrite transactionMode() { return txn.transactionMode(); }
- * {@literal @}Override public TxnType transactionType() { return txn.transactionType(); }
+ * protected final Transactional txn() { return txn; }
+ * {@literal @}Override public void begin(TxnType txnType) { txn().begin(txnType) ; }
+ * {@literal @}Override public void begin() { txn().begin(); }
+ * {@literal @}Override public void begin(TxnType txnType) { txn().begin(txnType); }
+ * {@literal @}Override public void begin(ReadWrite mode) { txn().begin(mode); }
+ * {@literal @}Override public boolean promote() { return txn().promote(); }
+ * {@literal @}Override public void commit() { txn().commit(); }
+ * {@literal @}Override public void abort() { txn().abort(); }
+ * {@literal @}Override public boolean isInTransaction() { return txn().isInTransaction(); }
+ * {@literal @}Override public void end() { txn().end(); }
+ * {@literal @}Override public ReadWrite transactionMode() { return txn().transactionMode(); }
+ * {@literal @}Override public TxnType transactionType() { return txn().transactionType(); }
* {@literal @}Override public boolean supportsTransactions() { return true; }
- * {@literal @}Override public boolean supportsTransactionAbort() { return true; }
+ * {@literal @}Override public boolean supportsTransactionAbort() { return false; }
* </pre>
*/
public class TransactionalLock implements Transactional {
/*
private final Transactional txn = TransactionalLock.createMRSW() ;
- @Override public void begin() { txn.begin(); }
- @Override public void begin(TxnType txnType) { txn.begin(txnType); }
- @Override public void begin(ReadWrite mode) { txn.begin(mode); }
- @Override public void commit() { txn.commit(); }
- @Override public void abort() { txn.abort(); }
- @Override public boolean isInTransaction() { return txn.isInTransaction(); }
- @Override public void end() { txn.end(); }
- @Override public ReadWrite transactionMode() { return txn.transactionMode(); }
- @Override public TxnType transactionType() { return txn.transactionType(); }
+ protected final Transactional txn() { return txn; }
+ @Override public void begin() { txn().begin(); }
+ @Override public void begin(TxnType txnType) { txn().begin(txnType); }
+ @Override public void begin(ReadWrite mode) { txn().begin(mode); }
+ @Override public void commit() { txn().commit(); }
+ @Override public void abort() { txn().abort(); }
+ @Override public boolean isInTransaction() { return txn().isInTransaction(); }
+ @Override public void end() { txn().end(); }
+ @Override public ReadWrite transactionMode() { return txn().transactionMode(); }
+ @Override public TxnType transactionType() { return txn().transactionType(); }
@Override public boolean supportsTransactions() { return true; }
@Override public boolean supportsTransactionAbort() { return false; }
+
*/
private ThreadLocal<Boolean> inTransaction = ThreadLocal.withInitial(() -> Boolean.FALSE);