protected function MigrateMessageTestBase::createTables

Creates map and message tables for testing.

See also

\Drupal\migrate\Plugin\migrate\id_map\Sql::ensureTables

File

core/modules/migrate/tests/src/Functional/MigrateMessageTestBase.php, line 61

Class

MigrateMessageTestBase

Provides base class for testing migrate messages.

Namespace

Code

protected function createTables($migration_ids) : void {
  foreach ($migration_ids as $migration_id) {
    $map_table_name = "migrate_map_{$migration_id}";
    $message_table_name = "migrate_message_{$migration_id}";
    if (!$this->database
      ->schema()
      ->tableExists($map_table_name)) {
      $fields = [];
      $fields['source_ids_hash'] = [
        'type' => 'varchar',
        'length' => '64',
        'not null' => TRUE,
      ];
      $fields['sourceid1'] = [
        'type' => 'varchar',
        'length' => '255',
        'not null' => TRUE,
      ];
      $fields['destid1'] = [
        'type' => 'varchar',
        'length' => '255',
        'not null' => FALSE,
      ];
      $fields['source_row_status'] = [
        'type' => 'int',
        'size' => 'tiny',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => MigrateIdMapInterface::STATUS_IMPORTED,
      ];
      $fields['rollback_action'] = [
        'type' => 'int',
        'size' => 'tiny',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => MigrateIdMapInterface::ROLLBACK_DELETE,
      ];
      $fields['last_imported'] = [
        'type' => 'int',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => 0,
      ];
      $fields['hash'] = [
        'type' => 'varchar',
        'length' => '64',
        'not null' => FALSE,
      ];
      $schema = [
        'description' => '',
        'fields' => $fields,
        'primary key' => [
          'source_ids_hash',
        ],
      ];
      $this->database
        ->schema()
        ->createTable($map_table_name, $schema);
      $rows = [
        [
          'source_ids_hash' => '37c655d',
          'sourceid1' => 'navigation',
          'destid1' => 'tools',
          'source_row_status' => '0',
          'rollback_action' => '1',
          'last_imported' => '0',
          'hash' => '',
        ],
        [
          'source_ids_hash' => '3a34190',
          'sourceid1' => 'menu-fixed-lang',
          'destid1' => 'menu-fixed-lang',
          'source_row_status' => '0',
          'rollback_action' => '0',
          'last_imported' => '0',
          'hash' => '',
        ],
        [
          'source_ids_hash' => '3e51f67',
          'sourceid1' => 'management',
          'destid1' => 'admin',
          'source_row_status' => '0',
          'rollback_action' => '1',
          'last_imported' => '0',
          'hash' => '',
        ],
        [
          'source_ids_hash' => '94a5caa',
          'sourceid1' => 'user-menu',
          'destid1' => 'account',
          'source_row_status' => '0',
          'rollback_action' => '1',
          'last_imported' => '0',
          'hash' => '',
        ],
        [
          'source_ids_hash' => 'c0efbcca',
          'sourceid1' => 'main-menu',
          'destid1' => 'main',
          'source_row_status' => '0',
          'rollback_action' => '1',
          'last_imported' => '0',
          'hash' => '',
        ],
        [
          'source_ids_hash' => 'f64cb72f',
          'sourceid1' => 'menu-test-menu',
          'destid1' => 'menu-test-menu',
          'source_row_status' => '0',
          'rollback_action' => '0',
          'last_imported' => '0',
          'hash' => '',
        ],
      ];
      foreach ($rows as $row) {
        $this->database
          ->insert($map_table_name)
          ->fields($row)
          ->execute();
      }
    }
    if (!$this->database
      ->schema()
      ->tableExists($message_table_name)) {
      $fields = [];
      $fields['msgid'] = [
        'type' => 'serial',
        'unsigned' => TRUE,
        'not null' => TRUE,
      ];
      $fields['source_ids_hash'] = [
        'type' => 'varchar',
        'length' => '64',
        'not null' => TRUE,
      ];
      $fields['level'] = [
        'type' => 'int',
        'unsigned' => TRUE,
        'not null' => TRUE,
        'default' => 1,
      ];
      $fields['message'] = [
        'type' => 'text',
        'size' => 'medium',
        'not null' => TRUE,
      ];
      $schema = [
        'description' => '',
        'fields' => $fields,
        'primary key' => [
          'msgid',
        ],
      ];
      $this->database
        ->schema()
        ->createTable($message_table_name, $schema);
      $rows = [
        [
          'msgid' => '1',
          'source_ids_hash' => '28cfb3d1',
          'level' => (string) MigrationInterface::MESSAGE_ERROR,
          'message' => 'Config entities can not be stubbed.',
        ],
        [
          'msgid' => '2',
          'source_ids_hash' => '28cfb3d1',
          'level' => (string) MigrationInterface::MESSAGE_ERROR,
          'message' => 'Config entities can not be stubbed.',
        ],
        [
          'msgid' => '3',
          'source_ids_hash' => '05914d93',
          'level' => (string) MigrationInterface::MESSAGE_ERROR,
          'message' => 'Config entities can not be stubbed.',
        ],
        [
          'msgid' => '4',
          'source_ids_hash' => '05914d93',
          'level' => (string) MigrationInterface::MESSAGE_INFORMATIONAL,
          'message' => 'Config entities can not be stubbed.',
        ],
      ];
      foreach ($rows as $row) {
        $this->database
          ->insert($message_table_name)
          ->fields($row)
          ->execute();
      }
    }
  }
}