Same name in other branches

1. 8.9.x core/modules/migrate/tests/src/Kernel/MigrateSqlSourceTestBase.php \Drupal\Tests\migrate\Kernel\MigrateSqlSourceTestBase::testSource()
2. 10 core/modules/migrate/tests/src/Kernel/MigrateSqlSourceTestBase.php \Drupal\Tests\migrate\Kernel\MigrateSqlSourceTestBase::testSource()
3. 11.x core/modules/migrate/tests/src/Kernel/MigrateSqlSourceTestBase.php \Drupal\Tests\migrate\Kernel\MigrateSqlSourceTestBase::testSource()

Tests the source plugin against a particular data set.

@dataProvider providerSource

@requires extension pdo_sqlite

Parameters

array $source_data: The source data that the plugin will read. See getDatabase() for the expected format.

array $expected_data: The result rows the plugin is expected to return.

int $expected_count: (optional) How many rows the source plugin is expected to return.

array $configuration: (optional) Configuration for the source plugin.

mixed $high_water: (optional) The value of the high water field.

string|null $expected_cache_key: (optional) The expected cache key.

Overrides MigrateSourceTestBase::testSource

File

core/modules/migrate/tests/src/Kernel/MigrateSqlSourceTestBase.php, line 87

Class

MigrateSqlSourceTestBase

Base class for tests of Migrate source plugins that use a database.

Namespace

Drupal\Tests\migrate\Kernel

Code

public function testSource(array $source_data, array $expected_data, $expected_count = NULL, array $configuration = [], $high_water = NULL, $expected_cache_key = NULL) {
    $plugin = $this->getPlugin($configuration);
    // Since we don't yet inject the database connection, we need to use a
    // reflection hack to set it in the plugin instance.
    $reflector = new \ReflectionObject($plugin);
    $property = $reflector->getProperty('database');
    $property->setAccessible(TRUE);
    $property->setValue($plugin, $this->getDatabase($source_data));
    
    /** @var MemoryCounterBackend $cache **/
    $cache = \Drupal::cache('migrate');
    if ($expected_cache_key) {
        // Verify the computed cache key.
        $property = $reflector->getProperty('cacheKey');
        $property->setAccessible(TRUE);
        $this->assertSame($expected_cache_key, $property->getValue($plugin));
        // Cache miss prior to calling ::count().
        $this->assertFalse($cache->get($expected_cache_key, 'cache'));
        $this->assertSame([], $cache->getCounter('set'));
        $count = $plugin->count();
        $this->assertSame($expected_count, $count);
        $this->assertSame([
            $expected_cache_key => 1,
        ], $cache->getCounter('set'));
        // Cache hit afterwards.
        $cache_item = $cache->get($expected_cache_key, 'cache');
        $this->assertNotSame(FALSE, $cache_item, 'This is not a cache hit.');
        $this->assertSame($expected_count, $cache_item->data);
    }
    else {
        $this->assertSame([], $cache->getCounter('set'));
        $plugin->count();
        $this->assertSame([], $cache->getCounter('set'));
    }
    parent::testSource($source_data, $expected_data, $expected_count, $configuration, $high_water);
}

---