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 theecm: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 String
MIGRATION_AFTER_STATE
static String
MIGRATION_BEFORE_STATE
static String
MIGRATION_BEFORE_TO_AFTER_STEP
static String
MIGRATION_ID
static 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
All Methods Instance Methods Concrete Methods 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 asession
by analyzing persistent data.-
Methods inherited from class org.nuxeo.ecm.core.migrator.AbstractBulkMigrator
clearRunningBulkCommands, createBulkCommand, getBulkCommandsKey, getKeyValueStore, getRunningBulkCommands, probeState, run, saveRunningBulkCommands
-
-
-
-
Field Detail
-
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 Detail
-
BlobKeysBulkMigrator
public BlobKeysBulkMigrator(MigrationDescriptor descriptor)
-
-
Method Detail
-
probeSession
protected String probeSession(CoreSession session)
Description copied from class:AbstractBulkMigrator
Probes the current state of asession
by analyzing persistent data.Assumes no migration step is currently running.
- Specified by:
probeSession
in classAbstractBulkMigrator
- Returns:
- the probed state, or
null
if it cannot be determined
-
getNXQLScrollQuery
protected String getNXQLScrollQuery()
- Specified by:
getNXQLScrollQuery
in classAbstractBulkMigrator
- 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 throughproperties
with the keyAbstractBulkMigrator.PARAM_MIGRATION_STEP
.This method is called by the
AbstractBulkMigrator.MigrationComputation
, the transaction is handled by it.- Specified by:
compute
in classAbstractBulkMigrator
-
notifyStatusChange
public void notifyStatusChange()
Description copied from interface:MigrationService.Migrator
Allows notification of status change for a running step or new state.
-
-