get( ProductCatalogMirrorRepository::WORK_PLATFORM_PRICE_DATASET_KEY, ); $this->assertSame('jiansun.dbo.pm_priceAdjustment', $dataset->key()); $this->assertSame('jiansun', $dataset->sourceKey()); $this->assertSame('dbo', $dataset->sourceSchema()); $this->assertSame('pm_priceAdjustment', $dataset->sourceObject()); $this->assertSame('js_pm_price_adjustment', $dataset->targetTable()); $this->assertSame(['Id'], $dataset->keyColumns()); $this->assertNull($dataset->watermarkColumn()); $this->assertContains(['skuCode(64)', 'effectTime', 'Id'], $dataset->indexDefinitions()); $selection = array_map('strtolower', (new BusinessMirrorDatasetRegistry())->columnSelection($dataset->key()) ?? []); foreach (['id', 'skucode', 'purchaseprice', 'effecttime'] as $column) { $this->assertContains($column, $selection); } } }