class ContentEntity extends SourcePluginBase implements ContainerFactoryPluginInterface (View source)

Source plugin to get content entities from the current version of Drupal.

This plugin uses the Entity API to export entity data. If the source entity type has custom field storage fields or computed fields, this class will need to be extended and the new class will need to load/calculate the values for those fields.

Available configuration keys:

  • entity_type: The entity type ID of the entities being exported. This is calculated dynamically by the deriver so it is only needed if the deriver is not utilized, i.e., a custom source plugin.
  • bundle: (optional) If the entity type is bundleable, only return entities of this bundle.
  • include_translations: (optional) Indicates if the entity translations should be included, defaults to TRUE.
  • add_revision_id: (optional) Indicates if the revision key is added to the source IDs, defaults to TRUE.

Examples:

This will return the default revision for all nodes, from every bundle and every translation. The revision key is added to the source IDs.

Traits

The entity field definition trait.

Wrapper methods for \Drupal\Core\StringTranslation\TranslationInterface.

Provides dependency injection friendly methods for serialization.

Provides a trait for the messenger service.

Constants

DERIVATIVE_SEPARATOR

A string which is used to separate base plugin IDs from the derivative ID.

Properties

protected string $pluginId

The plugin_id.

from  PluginBase
protected array $pluginDefinition

The plugin implementation definition.

from  PluginBase
protected array $configuration

Configuration information passed into the plugin.

from  PluginBase
protected TranslationInterface $stringTranslation

The string translation service.

from  StringTranslationTrait
protected array $_serviceIds

An array of service IDs keyed by property name used for serialization.

from  DependencySerializationTrait
protected array $_entityStorages

An array of entity type IDs keyed by the property name of their storages.

from  DependencySerializationTrait
protected MessengerInterface $messenger

The messenger.

from  MessengerTrait
protected ModuleHandlerInterface $moduleHandler

The module handler service.

from  SourcePluginBase
protected MigrationInterface $migration

The entity migration object.

from  SourcePluginBase
protected Row $currentRow

The current row from the query.

from  SourcePluginBase
protected array $currentSourceIds

The primary key of the current row.

from  SourcePluginBase
protected array $highWaterProperty

Information on the property used as the high-water mark.

from  SourcePluginBase
protected KeyValueStoreInterface $highWaterStorage

The key-value storage for the high-water value.

from  SourcePluginBase
protected int $originalHighWater

The high water mark at the beginning of the import operation.

from  SourcePluginBase
protected bool $cacheCounts

Whether this instance should cache the source count.

from  SourcePluginBase
protected string $cacheKey

Key to use for caching counts.

from  SourcePluginBase
protected bool $skipCount

Whether this instance should not attempt to count the source.

from  SourcePluginBase
protected bool $trackChanges

Flags whether to track changes to incoming data.

from  SourcePluginBase
protected bool $mapRowAdded

Flags whether source plugin will read the map row and add to data row.

from  SourcePluginBase
protected CacheBackendInterface $cache

The backend cache.

from  SourcePluginBase
protected MigrateIdMapInterface $idMap

The migration ID map.

from  SourcePluginBase
protected Iterator $iterator

The iterator to iterate over the source rows.

from  SourcePluginBase
protected EntityTypeManagerInterface $entityTypeManager

The entity type manager.

protected EntityFieldManagerInterface $entityFieldManager

The entity field manager.

protected EntityTypeBundleInfoInterface $entityTypeBundleInfo

The entity type bundle info service.

protected EntityTypeInterface $entityType

The entity type definition.

protected array $defaultConfiguration

The plugin's default configuration.

Methods

__construct(array $configuration, string $plugin_id, mixed $plugin_definition, MigrationInterface $migration, EntityTypeManagerInterface $entity_type_manager, EntityFieldManagerInterface $entity_field_manager, EntityTypeBundleInfoInterface $entity_type_bundle_info)

Constructs a \Drupal\Component\Plugin\PluginBase object.

string
getPluginId()

Gets the plugin_id of the plugin instance.

string
getBaseId()

Gets the base_plugin_id of the plugin instance.

string|null
getDerivativeId()

Gets the derivative_id of the plugin instance.

array
getPluginDefinition()

Gets the definition of the plugin implementation.

bool
isConfigurable()

Determines if the plugin is configurable.

t(string $string, array $args = [], array $options = [])

Translates a string to the current language or to a given language.

formatPlural($count, $singular, $plural, array $args = [], array $options = [])

Formats a string containing a count of items.

getNumberOfPlurals($langcode = NULL)

Returns the number of plurals supported by a given language.

getStringTranslation()

Gets the string translation service.

$this
setStringTranslation(TranslationInterface $translation)

Sets the string translation service to use.

__sleep()

{@inheritdoc}

__wakeup()

{@inheritdoc}

setMessenger(MessengerInterface $messenger)

Sets the messenger.

messenger()

Gets the messenger.

initializeIterator()

Initializes the iterator with the source data.

getModuleHandler()

Gets the module handler.

bool
prepareRow(Row $row)

Adds additional data to the row.

getIterator()

Returns the iterator that will yield the row arrays to be processed.

current()

{@inheritdoc}

key()

Gets the iterator key.

valid()

Checks whether the iterator is currently valid.

rewind()

Rewinds the iterator.

next()

{@inheritdoc}

fetchNextRow()

Position the iterator to the following row.

bool
aboveHighWater(Row $row)

Check if the incoming data is newer than what we've previously imported.

bool
rowChanged(Row $row)

Checks if the incoming row has changed since our last import.

getCurrentIds()

Gets the currentSourceIds data member.

int
count(bool $refresh = FALSE)

Gets the source count.

getCache()

Gets the cache object.

int
doCount()

Gets the source count checking if the source is countable or using the iterator_count function.

getHighWaterStorage()

Get the high water storage object.

int|null
getHighWater()

The current value of the high water mark.

saveHighWater(int $high_water)

Save the new high water mark.

array
getHighWaterProperty()

Get information on the property used as the high watermark.

string|null
getHighWaterField()

Get the name of the field used as the high watermark.

preRollback(MigrateRollbackEvent $event)

Performs pre-rollback tasks.

postRollback(MigrateRollbackEvent $event)

Performs post-rollback tasks.

string|null
getSourceModule()

Gets the source module providing the source data.

array
getDefinitionFromEntity(string $key)

Gets the field definition from a specific entity base field.

static string
getEntityTypeId(string $plugin_id)

Finds the entity type from configuration or plugin ID.

create(ContainerInterface $container, array $configuration, string $plugin_id, mixed $plugin_definition, MigrationInterface $migration = NULL)

Creates an instance of the plugin.

__toString()

Allows class to decide how it will react when it is treated like a string.

yieldEntities(array $ids)

Loads and yields entities, one at a time.

array
toArray(ContentEntityInterface $entity)

Converts an entity to an array.

query()

Query to retrieve the entities.

array
fields()

Returns available fields on the source.

array[]
getIds()

Defines the source fields uniquely identifying a source row.

Details

__construct(array $configuration, string $plugin_id, mixed $plugin_definition, MigrationInterface $migration, EntityTypeManagerInterface $entity_type_manager, EntityFieldManagerInterface $entity_field_manager, EntityTypeBundleInfoInterface $entity_type_bundle_info)

Constructs a \Drupal\Component\Plugin\PluginBase object.

Parameters

array $configuration

A configuration array containing information about the plugin instance.

string $plugin_id

The plugin_id for the plugin instance.

mixed $plugin_definition

The plugin implementation definition.

MigrationInterface $migration
EntityTypeManagerInterface $entity_type_manager
EntityFieldManagerInterface $entity_field_manager
EntityTypeBundleInfoInterface $entity_type_bundle_info

string getPluginId()

Gets the plugin_id of the plugin instance.

Return Value

string

The plugin_id of the plugin instance.

string getBaseId()

Gets the base_plugin_id of the plugin instance.

Return Value

string

The base_plugin_id of the plugin instance.

string|null getDerivativeId()

Gets the derivative_id of the plugin instance.

Return Value

string|null

The derivative_id of the plugin instance NULL otherwise.

array getPluginDefinition()

Gets the definition of the plugin implementation.

Return Value

array

The plugin definition, as returned by the discovery object used by the plugin manager.

bool isConfigurable()

Determines if the plugin is configurable.

Return Value

bool

A boolean indicating whether the plugin is configurable.

protected TranslatableMarkup t(string $string, array $args = [], array $options = [])

Translates a string to the current language or to a given language.

See \Drupal\Core\StringTranslation\TranslatableMarkup::__construct() for important security information and usage guidelines.

In order for strings to be localized, make them available in one of the ways supported by the

Parameters

string $string

A string containing the English text to translate.

array $args

(optional) An associative array of replacements to make after translation. Based on the first character of the key, the value is escaped and/or themed. See \Drupal\Component\Render\FormattableMarkup::placeholderFormat() for details.

array $options

(optional) An associative array of additional options, with the following elements:

  • 'langcode' (defaults to the current language): A language code, to translate to a language other than what is used to display the page.
  • 'context' (defaults to the empty context): The context the source string belongs to. See the @link i18n Internationalization topic @endlink for more information about string contexts.

Return Value

TranslatableMarkup

An object that, when cast to a string, returns the translated string.

See also

FormattableMarkup::placeholderFormat
TranslatableMarkup::__construct

protected formatPlural($count, $singular, $plural, array $args = [], array $options = [])

Formats a string containing a count of items.

Parameters

$count
$singular
$plural
array $args
array $options

See also

TranslationInterface::formatPlural

protected getNumberOfPlurals($langcode = NULL)

Returns the number of plurals supported by a given language.

Parameters

$langcode

See also

PluralFormulaInterface::getNumberOfPlurals

protected TranslationInterface getStringTranslation()

Gets the string translation service.

Return Value

TranslationInterface

The string translation service.

$this setStringTranslation(TranslationInterface $translation)

Sets the string translation service to use.

Parameters

TranslationInterface $translation

The string translation service.

Return Value

$this

__sleep()

{@inheritdoc}

__wakeup()

{@inheritdoc}

setMessenger(MessengerInterface $messenger)

Sets the messenger.

Parameters

MessengerInterface $messenger

The messenger.

MessengerInterface messenger()

Gets the messenger.

Return Value

MessengerInterface

The messenger.

protected Iterator initializeIterator()

Initializes the iterator with the source data.

Return Value

Iterator

Returns an iterable object of data for this source.

protected ModuleHandlerInterface getModuleHandler()

Gets the module handler.

Return Value

ModuleHandlerInterface

The module handler.

bool prepareRow(Row $row)

Adds additional data to the row.

Parameters

Row $row

The row object.

Return Value

bool

FALSE if this row needs to be skipped.

protected Iterator getIterator()

Returns the iterator that will yield the row arrays to be processed.

Return Value

Iterator

The iterator that will yield the row arrays to be processed.

current()

{@inheritdoc}

key()

Gets the iterator key.

Implementation of \Iterator::key() - called when entering a loop iteration, returning the key of the current row. It must be a scalar - we will serialize to fulfill the requirement, but using getCurrentIds() is preferable.

valid()

Checks whether the iterator is currently valid.

Implementation of \Iterator::valid() - called at the top of the loop, returning TRUE to process the loop and FALSE to terminate it.

rewind()

Rewinds the iterator.

Implementation of \Iterator::rewind() - subclasses of SourcePluginBase should implement initializeIterator() to do any class-specific setup for iterating source records.

next()

{@inheritdoc}

protected fetchNextRow()

Position the iterator to the following row.

protected bool aboveHighWater(Row $row)

Check if the incoming data is newer than what we've previously imported.

Parameters

Row $row

The row we're importing.

Return Value

bool

TRUE if the high-water value in the row is greater than our current value.

protected bool rowChanged(Row $row)

Checks if the incoming row has changed since our last import.

Parameters

Row $row

The row we're importing.

Return Value

bool

TRUE if the row has changed otherwise FALSE.

getCurrentIds()

Gets the currentSourceIds data member.

int count(bool $refresh = FALSE)

Gets the source count.

Return a count of available source records, from the cache if appropriate. Returns MigrateSourceInterface::NOT_COUNTABLE if the source is not countable.

Parameters

bool $refresh

(optional) Whether or not to refresh the count. Defaults to FALSE. Not all implementations support the reset flag. In such instances this parameter is ignored and the result of calling the method will always be up to date.

Return Value

int

The count.

protected CacheBackendInterface getCache()

Gets the cache object.

Return Value

CacheBackendInterface

The cache object.

protected int doCount()

Gets the source count checking if the source is countable or using the iterator_count function.

Return Value

int

protected KeyValueStoreInterface getHighWaterStorage()

Get the high water storage object.

Return Value

KeyValueStoreInterface

The storage object.

protected int|null getHighWater()

The current value of the high water mark.

The high water mark defines a timestamp stating the time the import was last run. If the mark is set, only content with a higher timestamp will be imported.

Return Value

int|null

A Unix timestamp representing the high water mark, or NULL if no high water mark has been stored.

protected saveHighWater(int $high_water)

Save the new high water mark.

Parameters

int $high_water

The high water timestamp.

protected array getHighWaterProperty()

Get information on the property used as the high watermark.

Array of 'name' & (optional) db 'alias' properties used for high watermark.

Return Value

array

The property used as the high watermark.

See also

SqlBase::initializeIterator

protected string|null getHighWaterField()

Get the name of the field used as the high watermark.

The name of the field qualified with an alias if available.

Return Value

string|null

The name of the field for the high water mark, or NULL if not set.

See also

SqlBase::initializeIterator

preRollback(MigrateRollbackEvent $event)

Performs pre-rollback tasks.

Parameters

MigrateRollbackEvent $event

The pre-rollback event object.

postRollback(MigrateRollbackEvent $event)

Performs post-rollback tasks.

Parameters

MigrateRollbackEvent $event

The post-rollback event object.

string|null getSourceModule()

Gets the source module providing the source data.

Return Value

string|null

The source module or NULL if not found.

protected array getDefinitionFromEntity(string $key)

Gets the field definition from a specific entity base field.

The method takes the field ID as an argument and returns the field storage definition to be used in getIds() by querying the destination entity base field definition.

Parameters

string $key

The field ID key.

Return Value

array

An associative array with a structure that contains the field type, keyed as 'type', together with field storage settings as they are returned by FieldStorageDefinitionInterface::getSettings().

See also

FieldStorageDefinitionInterface::getSettings

static protected string getEntityTypeId(string $plugin_id)

Finds the entity type from configuration or plugin ID.

Parameters

string $plugin_id

The plugin ID.

Return Value

string

The entity type.

static ContainerFactoryPluginInterface create(ContainerInterface $container, array $configuration, string $plugin_id, mixed $plugin_definition, MigrationInterface $migration = NULL)

Creates an instance of the plugin.

Parameters

ContainerInterface $container

The container to pull out services used in the plugin.

array $configuration

A configuration array containing information about the plugin instance.

string $plugin_id

The plugin ID for the plugin instance.

mixed $plugin_definition

The plugin implementation definition.

MigrationInterface $migration

Return Value

ContainerFactoryPluginInterface

Returns an instance of this plugin.

__toString()

Allows class to decide how it will react when it is treated like a string.

protected Generator yieldEntities(array $ids)

Loads and yields entities, one at a time.

Parameters

array $ids

The entity IDs.

Return Value

Generator

An iterable of the loaded entities.

protected array toArray(ContentEntityInterface $entity)

Converts an entity to an array.

Makes all IDs into flat values. All other values are returned as per $entity->toArray(), which is a nested array.

Parameters

ContentEntityInterface $entity

The entity to convert.

Return Value

array

The entity, represented as an array.

QueryInterface query()

Query to retrieve the entities.

Return Value

QueryInterface

The query.

array fields()

Returns available fields on the source.

Return Value

array

Available fields in the source, keys are the field machine names as used in field mappings, values are descriptions.

array[] getIds()

Defines the source fields uniquely identifying a source row.

None of these fields should contain a NULL value. If necessary, use prepareRow() or hook_migrate_prepare_row() to rewrite NULL values to appropriate empty values (such as '' or 0).

Return Value

array[]

An associative array of field definitions keyed by field ID. Values are associative arrays with a structure that contains the field type ('type' key). The other keys are the field storage settings as they are returned by FieldStorageDefinitionInterface::getSettings().

Examples:

A composite source primary key that is defined by an integer and a string might look like this: @code return [ 'id' => [ 'type' => 'integer', 'unsigned' => FALSE, 'size' => 'big', ], 'version' => [ 'type' => 'string', 'max_length' => 64, 'is_ascii' => TRUE, ], ]; @endcode

If 'type' points to a field plugin with multiple columns and needs to refer to a column different than 'value', the key of that column will be appended as a suffix to the plugin name, separated by dot ('.'). Example: @code return [ 'format' => [ 'type' => 'text.format', ], ]; @endcode

Additional custom keys/values that are not part of field storage definition can be added as shown below. The most common setting passed along to the ID definition is table 'alias', used by the SqlBase source plugin in order to distinguish between ambiguous column names - for example, when a SQL source query joins two tables with the same column names. @code return [ 'nid' => [ 'type' => 'integer', 'alias' => 'n', ], ]; @endcode