io.flamingock.internal.core.external.targets.operations

Class TransactionalTargetSystemOpsImpl

java.lang.Object

io.flamingock.internal.core.external.targets.operations.TargetSystemOpsImpl

io.flamingock.internal.core.external.targets.operations.TransactionalTargetSystemOpsImpl

All Implemented Interfaces:

io.flamingock.api.external.ExternalSystem, io.flamingock.api.external.TargetSystem, TargetSystemAuditMarker, TargetSystemOps, TransactionalTargetSystemOps

public class TransactionalTargetSystemOpsImpl
extends TargetSystemOpsImpl
implements TransactionalTargetSystemOps

Constructor Summary

Constructors

Constructor and Description
TransactionalTargetSystemOpsImpl(TransactionalTargetSystem<?> targetSystem, AbstractTargetSystem<?> auditStoreTargetSystem)

Method Summary

Modifier and Type	Method and Description
<T> T	applyChangeTransactional(java.util.function.Function<ExecutionRuntime,T> changeApplier, ExecutionRuntime executionRuntime) Applies a change operation within a transaction.
void	clearMark(java.lang.String changeId) Removes the local audit mark for the given change identifier.
java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader>	getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type) Returns an audit history reader for importing audit entries from external migration sources.
java.lang.String	getId()
io.flamingock.internal.common.core.targets.OperationType	getOperationType() Returns the type of operations supported by this target system.
java.util.Set<TargetSystemAuditMark>	listAll() Returns all known local audit marks for the Target System.
void	mark(TargetSystemAuditMark auditMark) Creates or updates a local audit mark.

Methods inherited from class io.flamingock.internal.core.external.targets.operations.TargetSystemOpsImpl

applyChange, rollbackChange

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.internal.core.external.targets.operations.TargetSystemOps

applyChange, rollbackChange

Methods inherited from interface io.flamingock.internal.core.external.targets.mark.TargetSystemAuditMarker

markApplied

Constructor Detail

TransactionalTargetSystemOpsImpl

public TransactionalTargetSystemOpsImpl(TransactionalTargetSystem<?> targetSystem,
                                        AbstractTargetSystem<?> auditStoreTargetSystem)

Method Detail

getOperationType

public io.flamingock.internal.common.core.targets.OperationType getOperationType()

Description copied from interface: TargetSystemOps

Returns the type of operations supported by this target system.

Specified by:

getOperationType in interface TargetSystemOps

Overrides:

getOperationType in class TargetSystemOpsImpl

Returns:

the operation type (e.g., NON_TX, TX_AUDIT_STORE_SYNC, TX_NON_SYNC)

applyChangeTransactional

public final <T> T applyChangeTransactional(java.util.function.Function<ExecutionRuntime,T> changeApplier,
                                            ExecutionRuntime executionRuntime)

Description copied from interface: TransactionalTargetSystemOps

Applies a change operation within a transaction.

This method coordinates transactional execution by:

• Injecting session-scoped dependencies via the target system
• Starting a transaction and injecting transaction-scoped dependencies
• Executing the change function within the transaction
• Committing or rolling back based on the operation result

Specified by:

applyChangeTransactional in interface TransactionalTargetSystemOps

Type Parameters:

T - the return type of the change operation

Parameters:

changeApplier - the function that executes the actual change

executionRuntime - the runtime context for dependency resolution

Returns:

the result of the change operation

getAuditAuditReader

public java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader> getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)

Description copied from interface: TransactionalTargetSystemOps

Returns an audit history reader for importing audit entries from external migration sources.

This method enables Flamingock to import audit history from legacy migration tools or other Flamingock installations, preventing re-execution of already-applied changes. The returned reader provides access to historical audit entries that can be written to Flamingock's audit store.

Common use cases include:

• Mongock migration: Import Mongock change history when migrating from Mongock to Flamingock
• Community to Cloud migration: Import audit history from local database to Flamingock Cloud backend
• Future extensibility: Support for other migration tools (Liquibase, Flyway, etc.)

The default implementation returns Optional.empty(), indicating no audit reader is available. Target system implementations should override this method to provide database-specific readers when migration support is needed.

Specified by:

getAuditAuditReader in interface TransactionalTargetSystemOps

Parameters:

type - the type of audit reader to retrieve (e.g., AuditReaderType.MONGOCK)

Returns:

an Optional containing the audit history reader if supported for the given type, or Optional.empty() if this target system does not support audit reading for the specified type

See Also:

AuditHistoryReader, AuditReaderType

getId

public java.lang.String getId()

Specified by:

getId in interface io.flamingock.api.external.ExternalSystem

Overrides:

getId in class TargetSystemOpsImpl

listAll

public java.util.Set<TargetSystemAuditMark> listAll()

Description copied from interface: TargetSystemAuditMarker

Returns all known local audit marks for the Target System.

Specified by:

listAll in interface TargetSystemAuditMarker

Returns:

a non-null, possibly empty set of TargetSystemAuditMark.

clearMark

public void clearMark(java.lang.String changeId)

Description copied from interface: TargetSystemAuditMarker

Removes the local audit mark for the given change identifier.

This is a hygienic cleanup step that should be invoked after the remote Audit Store has acknowledged the change, but not critical. It is idempotent: if no mark exists for changeId, the call completes without error.

Specified by:

clearMark in interface TargetSystemAuditMarker

Parameters:

changeId - the identifier of the change whose local mark should be removed.

mark

public void mark(TargetSystemAuditMark auditMark)

Description copied from interface: TargetSystemAuditMarker

Creates or updates a local audit mark.

Implementations should ensure this operation is idempotent. The write operation must participate in the same transaction as the Target System operation that is being confirmed.

Specified by:

mark in interface TargetSystemAuditMarker

Parameters:

auditMark - the mark to persist.