arangodb#80 allow commit/rollback if not started yet

Author: aburmeis

src/main/java/com/arangodb/springframework/transaction/ArangoTransaction.java

@@ -16,7 +16,6 @@
 class ArangoTransaction implements SmartTransactionObject {
 
     private final ArangoDatabase database;
-
     private final Set<String> writeCollections = new HashSet<>();
     private TransactionDefinition definition;
     private StreamTransactionEntity transaction;
@@ -53,11 +52,15 @@ String getOrBegin(Collection<String> collections) {
     }
 
     void commit() {
-        database.commitStreamTransaction(transaction.getId());
+        if (transaction != null && transaction.getStatus() == StreamTransactionStatus.running) {
+            database.commitStreamTransaction(transaction.getId());
+        }
     }
 
     void rollback() {
-        database.abortStreamTransaction(transaction.getId());
+        if (transaction != null && transaction.getStatus() == StreamTransactionStatus.running) {
+            database.abortStreamTransaction(transaction.getId());
+        }
     }
 
     @Override

src/main/java/com/arangodb/springframework/transaction/ArangoTransactionManager.java

@@ -1,6 +1,7 @@
 package com.arangodb.springframework.transaction;
 
 import com.arangodb.ArangoDatabase;
+import com.arangodb.DbName;
 import com.arangodb.model.StreamTransactionOptions;
 import com.arangodb.springframework.core.ArangoOperations;
 import com.arangodb.springframework.repository.query.QueryTransactionBridge;
@@ -32,7 +33,11 @@ public ArangoTransactionManager(ArangoOperations operations, QueryTransactionBri
 
     @Override
     protected Object doGetTransaction() throws TransactionException {
-        return new ArangoTransaction(operations.driver().db(operations.getDatabaseName()));
+        DbName database = operations.getDatabaseName();
+        if (logger.isDebugEnabled()) {
+            logger.debug("Create new transaction for database " + database);
+        }
+        return new ArangoTransaction(operations.driver().db(database));
     }
 
     @Override