function HighWaterTest::testHighWater

Tests high water property of SqlBase.

File

core/modules/migrate/tests/src/Kernel/HighWaterTest.php, line 91

Class

HighWaterTest

Tests migration high water property.

Namespace

Code

public function testHighWater() : void {
  // Assert all of the nodes have been imported.
  $this->assertNodeExists('Item 1');
  $this->assertNodeExists('Item 2');
  $this->assertNodeExists('Item 3');
  // Update Item 1 setting its high_water_property to value that is below
  // current high water mark.
  $this->sourceDatabase
    ->update('high_water_node')
    ->fields([
    'title' => 'Item 1 updated',
    'changed' => 2,
  ])
    ->condition('title', 'Item 1')
    ->execute();
  // Update Item 2 setting its high_water_property to value equal to
  // current high water mark.
  $this->sourceDatabase
    ->update('high_water_node')
    ->fields([
    'title' => 'Item 2 updated',
    'changed' => 3,
  ])
    ->condition('title', 'Item 2')
    ->execute();
  // Update Item 3 setting its high_water_property to value that is above
  // current high water mark.
  $this->sourceDatabase
    ->update('high_water_node')
    ->fields([
    'title' => 'Item 3 updated',
    'changed' => 4,
  ])
    ->condition('title', 'Item 3')
    ->execute();
  // Execute migration again.
  $this->executeMigration('high_water_test');
  // Item with lower high water should not be updated.
  $this->assertNodeExists('Item 1');
  $this->assertNodeDoesNotExist('Item 1 updated');
  // Item with equal high water should not be updated.
  $this->assertNodeExists('Item 2');
  $this->assertNodeDoesNotExist('Item 2 updated');
  // Item with greater high water should be updated.
  $this->assertNodeExists('Item 3 updated');
  $this->assertNodeDoesNotExist('Item 3');
}