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 <[email protected]>
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);