diff --git a/src/Plugin/migrate/destination/Table.php b/src/Plugin/migrate/destination/Table.php index 2217fa0..64a6e88 100755 --- a/src/Plugin/migrate/destination/Table.php +++ b/src/Plugin/migrate/destination/Table.php @@ -3,6 +3,7 @@ namespace Drupal\migrate_plus\Plugin\migrate\destination; use Drupal\Core\Database\Connection; +use Drupal\Core\Database\Database; use Drupal\Core\Plugin\ContainerFactoryPluginInterface; use Drupal\migrate\MigrateException; use Drupal\migrate\MigrateSkipProcessException; @@ -63,12 +64,14 @@ class Table extends DestinationBase implements ContainerFactoryPluginInterface { * {@inheritdoc} */ public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition, MigrationInterface $migration = NULL) { + $db_key = !empty($configuration['database_key']) ? $configuration['database_key'] : NULL; + return new static( $configuration, $plugin_id, $plugin_definition, $migration, - $container->get('database') + Database::getConnection('default', $db_key) ); }