File tree Expand file tree Collapse file tree
accession-commons-mongodb/src/test/java/uk/ac/ebi/ampt2d/commons/accession
accession-commons-monotonic-generator-jpa/src/test/java/uk/ac/ebi/ampt2d/commons/accession/generators/monotonic Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2323import org .springframework .test .context .DynamicPropertyRegistry ;
2424import org .springframework .test .context .DynamicPropertySource ;
2525import org .testcontainers .containers .MongoDBContainer ;
26- import org .testcontainers .junit .jupiter .Container ;
27- import org .testcontainers .junit .jupiter .Testcontainers ;
2826import uk .ac .ebi .ampt2d .test .configuration .MongoDbCucumberTestConfiguration ;
2927
3028@ CucumberContextConfiguration
3129@ SpringBootTest (classes = {MongoDbCucumberTestConfiguration .class })
3230@ DirtiesContext
33- @ Testcontainers
3431public class CucumberSpringConfiguration {
3532
36- @ Container
3733 static MongoDBContainer mongoDBContainer = new MongoDBContainer ("mongo:6.0" );
3834
35+ static {
36+ mongoDBContainer .start ();
37+ }
38+
3939 @ DynamicPropertySource
4040 static void setProperties (DynamicPropertyRegistry registry ) {
41- mongoDBContainer .start ();
4241 registry .add ("spring.data.mongodb.uri" , mongoDBContainer ::getReplicaSetUrl );
4342 }
4443}
Original file line number Diff line number Diff line change 88import uk .ac .ebi .ampt2d .commons .accession .persistence .jpa .monotonic .entities .ContiguousIdBlock ;
99import uk .ac .ebi .ampt2d .commons .accession .persistence .jpa .monotonic .repositories .ContiguousIdBlockRepository ;
1010import uk .ac .ebi .ampt2d .commons .accession .persistence .jpa .monotonic .service .ContiguousIdBlockService ;
11+
12+ import jakarta .persistence .EntityManager ;
1113import uk .ac .ebi .ampt2d .commons .accession .service .BasicSpringDataRepositoryMonotonicDatabaseService ;
1214import uk .ac .ebi .ampt2d .test .configuration .MonotonicAccessionGeneratorTestConfiguration ;
1315import uk .ac .ebi .ampt2d .test .configuration .TestMonotonicDatabaseServiceTestConfiguration ;
@@ -37,6 +39,8 @@ public class MonotonicAccessionRecoveryAgentTest {
3739 private ContiguousIdBlockRepository repository ;
3840 @ Autowired
3941 private ContiguousIdBlockService service ;
42+ @ Autowired
43+ private EntityManager entityManager ;
4044
4145 @ Test
4246 public void testRunRecovery () throws InterruptedException {
@@ -69,6 +73,9 @@ public void testRunRecovery() throws InterruptedException {
6973 MonotonicAccessionRecoveryAgent recoveryAgent = new MonotonicAccessionRecoveryAgent (service , monotonicDBService );
7074 recoveryAgent .runRecovery (TEST_CATEGORY , TEST_RECOVERY_AGENT_APP_INSTANCE_ID , recoverCutOffTime );
7175
76+ // Clear the persistence context to ensure we fetch fresh data from the database
77+ entityManager .flush ();
78+ entityManager .clear ();
7279
7380 List <ContiguousIdBlock > blockList = StreamSupport .stream (repository .findAll ().spliterator (), false )
7481 .sorted (Comparator .comparing (ContiguousIdBlock ::getFirstValue ))
You can’t perform that action at this time.
0 commit comments