io.flamingock.internal.core.task.navigation.navigator.strategy

Class SharedTxChangeProcessStrategy

java.lang.Object

io.flamingock.internal.core.task.navigation.navigator.strategy.AbstractChangeProcessStrategy<TransactionalTargetSystemOps>

io.flamingock.internal.core.task.navigation.navigator.strategy.SharedTxChangeProcessStrategy

All Implemented Interfaces:

ChangeProcessStrategy

public class SharedTxChangeProcessStrategy
extends AbstractChangeProcessStrategy<TransactionalTargetSystemOps>

Change process strategy for transactional target systems with shared audit store.

This strategy is used when the target system and audit store share the same database and can participate in the same transaction.

Execution Flow

1. Begin shared transaction
2. Audit change start within transaction
3. Apply change to target system within same transaction
4. Audit execution result within same transaction
5. Commit transaction (both change and audit atomically)
6. On failure: attempt separate transaction to audit failure details

Target System State Outcomes

• Success: Change applied atomically with audit
• Failure: No changes persisted (transaction rolled back)

Audit Store State Outcomes

• STARTED → APPLIED: Successful atomic execution and audit
• STARTED → EXECUTION_FAILED → ROLLED_BACK: Failed execution with detailed failure audit
• No audit trail: Complete transaction failure (safe to retry)

Failure Handling

When execution fails, this strategy attempts to create a detailed failure audit trail in a separate transaction: STARTED → EXECUTION_FAILED → ROLLED_BACK. This provides comprehensive failure information while maintaining the safety guarantee that failed changes can be safely retried since nothing was committed in the original transaction.

Field Summary

Fields inherited from class io.flamingock.internal.core.task.navigation.navigator.strategy.AbstractChangeProcessStrategy

auditStoreOperations, change, executionContext, resultBuilder, stepLogger, targetSystemOps, timeService

Constructor Summary

Constructors

Constructor and Description
SharedTxChangeProcessStrategy(ExecutableTask change, ExecutionContext executionContext, TransactionalTargetSystemOps targetSystemOps, AuditStoreStepOperations auditStoreOperations, ChangeResultBuilder resultBuilder, LockGuardProxyFactory proxyFactory, io.flamingock.internal.common.core.context.ContextResolver baseContext, io.flamingock.internal.util.TimeService timeService)

Method Summary

Modifier and Type	Method and Description
protected void	auditAndLogAutoRollback()
protected ChangeProcessResult	doApplyChange() Strategy-specific implementation of change application.

Methods inherited from class io.flamingock.internal.core.task.navigation.navigator.strategy.AbstractChangeProcessStrategy

applyChange, auditAndLogAutoRollback, auditAndLogExecution, auditAndLogManualRollback, auditAndLogStartExecution, buildExecutionRuntime

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedTxChangeProcessStrategy

public SharedTxChangeProcessStrategy(ExecutableTask change,
                                     ExecutionContext executionContext,
                                     TransactionalTargetSystemOps targetSystemOps,
                                     AuditStoreStepOperations auditStoreOperations,
                                     ChangeResultBuilder resultBuilder,
                                     LockGuardProxyFactory proxyFactory,
                                     io.flamingock.internal.common.core.context.ContextResolver baseContext,
                                     io.flamingock.internal.util.TimeService timeService)

Method Detail

doApplyChange

protected ChangeProcessResult doApplyChange()

Description copied from class: AbstractChangeProcessStrategy

Strategy-specific implementation of change application.

Concrete strategies must implement this method to define their specific transaction handling, execution flow, and error recovery patterns.

Specified by:

doApplyChange in class AbstractChangeProcessStrategy<TransactionalTargetSystemOps>

Returns:

Task execution result with success/failure status and details

auditAndLogAutoRollback

protected void auditAndLogAutoRollback()