Package org.nuxeo.ecm.core.storage.dbs

Class BlobKeysBulkMigrator

java.lang.Object

org.nuxeo.ecm.core.migrator.AbstractBulkMigrator

org.nuxeo.ecm.core.storage.dbs.BlobKeysBulkMigrator

All Implemented Interfaces:

MigrationService.Migrator

public class BlobKeysBulkMigrator
extends AbstractBulkMigrator

Migrator to populate the ecm:blobKeys field in DBS repositories.

Since:

2023

Nested Class Summary

Nested classes/interfaces inherited from class org.nuxeo.ecm.core.migrator.AbstractBulkMigrator

AbstractBulkMigrator.MigrationAction, AbstractBulkMigrator.MigrationComputation

Field Summary

Fields

Modifier and Type	Field	Description
static final String	MIGRATION_AFTER_STATE
static final String	MIGRATION_BEFORE_STATE
static final String	MIGRATION_BEFORE_TO_AFTER_STEP
static final String	MIGRATION_ID
static final String	MIGRATION_UNSUPPORTED_STATE

Fields inherited from class org.nuxeo.ecm.core.migrator.AbstractBulkMigrator

descriptor, MIGRATION_PROCESSOR_NAME, PARAM_MIGRATION_ID, PARAM_MIGRATION_STEP

Constructor Summary

Constructors

Constructor	Description
BlobKeysBulkMigrator(MigrationDescriptor descriptor)

Method Summary

Modifier and Type	Method	Description
void	compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)	Executes the migration on the given batch.
protected String	getNXQLScrollQuery()
void	notifyStatusChange()	Allows notification of status change for a running step or new state.
protected String	probeSession(CoreSession session)	Probes the current state of a session by analyzing persistent data.

Methods inherited from class org.nuxeo.ecm.core.migrator.AbstractBulkMigrator

clearRunningBulkCommands, createBulkCommand, getBulkCommandsKey, getKeyValueStore, getRunningBulkCommands, probeState, run, saveRunningBulkCommands

Methods inherited from class java.lang.Object

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

Field Details

MIGRATION_ID

public static final String MIGRATION_ID

See Also:

• Constant Field Values

MIGRATION_BEFORE_STATE

public static final String MIGRATION_BEFORE_STATE

See Also:

• Constant Field Values

MIGRATION_AFTER_STATE

public static final String MIGRATION_AFTER_STATE

See Also:

• Constant Field Values

MIGRATION_UNSUPPORTED_STATE

public static final String MIGRATION_UNSUPPORTED_STATE

See Also:

• Constant Field Values

MIGRATION_BEFORE_TO_AFTER_STEP

public static final String MIGRATION_BEFORE_TO_AFTER_STEP

See Also:

• Constant Field Values

Constructor Details

BlobKeysBulkMigrator

public BlobKeysBulkMigrator(MigrationDescriptor descriptor)

Method Details

probeSession

protected String probeSession(CoreSession session)

Description copied from class: AbstractBulkMigrator

Probes the current state of a session by analyzing persistent data.

Assumes no migration step is currently running.

Specified by:

probeSession in class AbstractBulkMigrator

Returns:

the probed state, or null if it cannot be determined

getNXQLScrollQuery

protected String getNXQLScrollQuery()

Specified by:

getNXQLScrollQuery in class AbstractBulkMigrator

Returns:

the NXQL query to scroll for bulk migration

compute

public void compute(CoreSession session,
 List<String> ids,
 Map<String,Serializable> properties)

Description copied from class: AbstractBulkMigrator

Executes the migration on the given batch. The migration step is given through properties with the key AbstractBulkMigrator.PARAM_MIGRATION_STEP.

This method is called by the AbstractBulkMigrator.MigrationComputation, the transaction is handled by it.

Specified by:

compute in class AbstractBulkMigrator

notifyStatusChange

public void notifyStatusChange()

Description copied from interface: MigrationService.Migrator

Allows notification of status change for a running step or new state.