outbox.jdbc.JdbcTransactionManager

public final class JdbcTransactionManager extends Object

Lightweight transaction manager for manual JDBC usage. Obtains a connection, disables auto-commit, and binds it to a ThreadLocalTxContext.

Use via try-with-resources on the returned JdbcTransactionManager.Transaction:


 try (var tx = txManager.begin()) {
     writer.write(event);
     tx.commit();
 }

See Also:

Constructor Details
- JdbcTransactionManager
  
  public JdbcTransactionManager(ConnectionProvider connectionProvider, ThreadLocalTxContext txContext)
Method Details
- begin
  
  public JdbcTransactionManager.Transaction begin() throws SQLException
  
  Begins a new transaction by obtaining a connection and binding it to the thread context.
  
  Returns:
  
  a new JdbcTransactionManager.Transaction handle (use with try-with-resources)
  
  Throws:
  
  SQLException - if a connection cannot be obtained

Class JdbcTransactionManager

Nested Class Summary