function TrackChangesTest::testTrackChanges

Tests track changes property of SqlBase.

File

core/modules/migrate/tests/src/Kernel/TrackChangesTest.php, line 94

Class

TrackChangesTest

Tests migration track changes property.

Namespace

Code

public function testTrackChanges() : void {
  // Assert all of the terms have been imported.
  $this->assertTermExists('name', 'Item 1');
  $this->assertTermExists('name', 'Item 2');
  $this->assertTermExists('description', 'Text item 3');
  $this->assertTermExists('description', 'Text item 4');
  // Save the original hash, rerun the migration and check that the hashes
  // are the same.
  $id_map = $this->migration
    ->getIdMap();
  for ($i = 1; $i < 5; $i++) {
    $row = $id_map->getRowBySource([
      'tid' => $i,
    ]);
    $original_hash[$i] = $row['hash'];
  }
  $this->executeMigration($this->migration);
  for ($i = 1; $i < 5; $i++) {
    $row = $id_map->getRowBySource([
      'tid' => $i,
    ]);
    $new_hash[$i] = $row['hash'];
  }
  $this->assertEquals($original_hash, $new_hash);
  // Update Item 1 triggering its track_changes by name.
  $this->sourceDatabase
    ->update('track_changes_term')
    ->fields([
    'name' => 'Item 1 updated',
  ])
    ->condition('name', 'Item 1')
    ->execute();
  // Update Item 2 keeping it's track_changes name the same.
  $this->sourceDatabase
    ->update('track_changes_term')
    ->fields([
    'name' => 'Item 2',
  ])
    ->condition('name', 'Item 2')
    ->execute();
  // Update Item 3 triggering its track_changes by field.
  $this->sourceDatabase
    ->update('track_changes_term')
    ->fields([
    'description' => 'Text item 3 updated',
  ])
    ->condition('name', 'Item 3')
    ->execute();
  // Update Item 2 keeping it's track_changes field the same.
  $this->sourceDatabase
    ->update('track_changes_term')
    ->fields([
    'description' => 'Text item 4',
  ])
    ->condition('name', 'Item 4')
    ->execute();
  // Execute migration again.
  $this->executeMigration($this->migration);
  // Check that the all the hashes except for 'Item 2'and 'Item 4' have
  // changed.
  for ($i = 1; $i < 5; $i++) {
    $row = $id_map->getRowBySource([
      'tid' => $i,
    ]);
    $new_hash[$i] = $row['hash'];
  }
  $this->assertNotEquals($original_hash[1], $new_hash[1]);
  $this->assertEquals($original_hash[2], $new_hash[2]);
  $this->assertNotEquals($original_hash[3], $new_hash[3]);
  $this->assertEquals($original_hash[4], $new_hash[4]);
  // Item with name changes should be updated.
  $this->assertTermExists('name', 'Item 1 updated');
  $this->assertTermDoesNotExist('name', 'Item 1');
  // Item without name changes should not be updated.
  $this->assertTermExists('name', 'Item 2');
  // Item with field changes should be updated.
  $this->assertTermExists('description', 'Text item 3 updated');
  $this->assertTermDoesNotExist('description', 'Text item 3');
  // Item without field changes should not be updated.
  $this->assertTermExists('description', 'Text item 4');
  // Test hashes again after forcing all rows to be re-imported.
  $id_map->prepareUpdate();
  // Execute migration again.
  $this->executeMigration('track_changes_test');
  for ($i = 1; $i < 5; $i++) {
    $row = $id_map->getRowBySource([
      'tid' => $i,
    ]);
    $newer_hash[$i] = $row['hash'];
  }
  $this->assertEquals($new_hash[1], $newer_hash[1]);
  $this->assertEquals($new_hash[2], $newer_hash[2]);
  $this->assertEquals($new_hash[3], $newer_hash[3]);
  $this->assertEquals($new_hash[4], $newer_hash[4]);
}