treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

swt-importer fix test

Browse source
This commit is contained in:
AKurakin 2023-09-12 17:46:34 +03:00
parent 9507dc10be
commit 9f32cd93a4
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
clearing-parent/swt-importer/src/test/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDBTest.java
View file

@ -19,6 +19,7 @@ import ru.spcex.clearing.test.config.ImdgTestConfig;
import ru.spcex.clearing.test.config.KafkaTestConfig;
import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgProvider;
import ru.spcex.platform.imdg.iml.hazelcast.adapter.ImdgHazelcast;
import javax.annotation.PostConstruct;
import java.io.File;
@ -97,8 +98,9 @@ class ImportToDBTest {
ResultContainer resultContainer = createNewTask(eTable, swtFile);
resultContainer.setSwtSource(Files.readAllBytes(Paths.get(swtFile.getAbsolutePath())));
importToDB.process(resultContainer);
Imdg<SDf21> df21Imdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SDf21, SDf21.class);
((ImdgHazelcast)df21Imdg).clear();
importToDB.process(resultContainer);
Collection<SDf21> values = df21Imdg.getAllValues();
Assertions.assertEquals(13, values.size());
}
@ -111,8 +113,9 @@ class ImportToDBTest {
ResultContainer resultContainer = createNewTask(eTable, swtFile);
resultContainer.setSwtSource(Files.readAllBytes(Paths.get(swtFile.getAbsolutePath())));
importToDB.process(resultContainer);
Imdg<SDf21> df21Imdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SDf21, SDf21.class);
((ImdgHazelcast)df21Imdg).clear();
importToDB.process(resultContainer);
Collection<SDf21> values = df21Imdg.getAllValues();
Assertions.assertEquals(3, values.size());
}