@RunWithCustomExecutor @Test public void mongoDataUpdate_checkGraphMigration() throws Exception { String unitDataSetFile = "DataMigrationR6/30UnitDataSet/R6UnitDataSet.json"; importUnitDataSetFile(unitDataSetFile); String ogDataSetFile = "DataMigrationR6/15ObjectGroupDataSet/R6ObjectGroupDataSet.json"; importObjectGroupDataSetFile(ogDataSetFile); DataMigrationService instance = new DataMigrationService(dataMigrationRepository, graphLoader); instance.mongoDataUpdate(); awaitTermination(instance); String expectedUnitDataSetFile = "DataMigrationR6/30UnitDataSet/ExpectedR7UnitDataSet.json"; assertDataSetEqualsExpectedFile(MetadataCollections.UNIT.getCollection(), expectedUnitDataSetFile); String expectedOGDataSetFile = "DataMigrationR6/15ObjectGroupDataSet/ExpectedR7ObjectGroupDataSet.json"; assertDataSetEqualsExpectedFile(MetadataCollections.OBJECTGROUP.getCollection(), expectedOGDataSetFile); }
void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } DataMigrationService(); @VisibleForTesting  DataMigrationService(DataMigrationRepository dataMigrationRepository, GraphLoader graphLoader); }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } DataMigrationService(); @VisibleForTesting  DataMigrationService(DataMigrationRepository dataMigrationRepository, GraphLoader graphLoader); boolean isMongoDataUpdateInProgress(); boolean tryStartMongoDataUpdate(); }
DataMigrationService { void mongoDataUpdate() throws InterruptedException { processUnits(); processObjectGroups(); } DataMigrationService(); @VisibleForTesting  DataMigrationService(DataMigrationRepository dataMigrationRepository, GraphLoader graphLoader); boolean isMongoDataUpdateInProgress(); boolean tryStartMongoDataUpdate();  }