Package app.ductape.sdk.graph.transactions

Class GraphTransactionManager

java.lang.Object

app.ductape.sdk.graph.transactions.GraphTransactionManager

public class GraphTransactionManager
extends Object

TS parity for transactions/transaction-manager.ts: lifecycle owner for a single graph adapter's transactions.

Transaction status nuances (TS-aligned):

• Active transactions are tracked by id. beginTransaction(Map) returns a copy with status="active".
• commitTransaction(Map) and rollbackTransaction(Map) are idempotent no-ops once the transaction is no longer active (TS catches and swallows second-rollback errors, Java does the same).
• If commit throws after the adapter has already started writing, we still try to roll back the underlying database tx (TS try { commit } catch { rollback; throw }).
• executeTransaction(Function, Map) mirrors TS session.executeWrite(callback): errors thrown inside the callback trigger rollback and re-throw as a GraphError.transactionError(java.lang.String, java.lang.Throwable), with the original cause preserved.

Constructor Summary

Constructors

Constructor	Description
GraphTransactionManager(BaseGraphAdapter adapter)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	beginTransaction(Map<String,Object> options)
void	commitTransaction(Map<String,Object> transaction)
<T> T	executeTransaction(Function<Map<String,Object>,T> callback, Map<String,Object> options)
List<Map<String,Object>>	getActiveTransactions()
String	getTransactionStatus(String transactionId)	TS getTransactionStatus(tx): returns "active" when the manager owns the tx, otherwise null.
boolean	isTransactionActive(String transactionId)
boolean	ownsTransaction(String transactionId)
void	rollbackAll()
void	rollbackTransaction(Map<String,Object> transaction)
void	setAdapter(BaseGraphAdapter adapter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GraphTransactionManager

public GraphTransactionManager(BaseGraphAdapter adapter)

Method Details

setAdapter

public void setAdapter(BaseGraphAdapter adapter)

executeTransaction

public <T> T executeTransaction(Function<Map<String,Object>,T> callback,
 Map<String,Object> options)

beginTransaction

public Map<String,Object> beginTransaction(Map<String,Object> options)

commitTransaction

public void commitTransaction(Map<String,Object> transaction)

rollbackTransaction

public void rollbackTransaction(Map<String,Object> transaction)

getActiveTransactions

public List<Map<String,Object>> getActiveTransactions()

getTransactionStatus

public String getTransactionStatus(String transactionId)

TS getTransactionStatus(tx): returns "active" when the manager owns the tx, otherwise null. The status key on the returned tx map after commit/rollback is set in-place to "committed", "rolled_back", or "failed".

isTransactionActive

public boolean isTransactionActive(String transactionId)

ownsTransaction

public boolean ownsTransaction(String transactionId)

rollbackAll

public void rollbackAll()