From c06b5051d2318e1334ab1d5554e2cd9a7e775f8a Mon Sep 17 00:00:00 2001 From: Jason Loux Date: Thu, 5 Nov 2026 10:57:10 -0500 Subject: [PATCH] Remove trait cache and rest of CRUD operations --- .../daos/impl/TraitDAOImpl.java | 35 ------------------- 1 file changed, 35 deletions(-) diff --git a/src/main/java/org/breedinginsight/daos/impl/TraitDAOImpl.java b/src/main/java/org/breedinginsight/daos/impl/TraitDAOImpl.java index b9c317db2..3b810cfe0 100644 --- a/src/main/java/org/breedinginsight/daos/impl/TraitDAOImpl.java +++ b/src/main/java/org/breedinginsight/daos/impl/TraitDAOImpl.java @@ -23,7 +23,6 @@ import com.google.gson.JsonDeserializer; import io.micronaut.context.annotation.Property; import io.micronaut.http.server.exceptions.InternalServerException; -import io.micronaut.scheduling.annotation.Scheduled; import lombok.extern.slf4j.Slf4j; import org.brapi.client.v2.ApiResponse; import org.brapi.client.v2.BrAPIClient; @@ -34,7 +33,6 @@ import org.brapi.v2.model.pheno.*; import org.brapi.v2.model.pheno.request.BrAPIObservationVariableSearchRequest; import org.brapi.v2.model.pheno.response.BrAPIObservationVariableListResponse; -import org.brapi.v2.model.pheno.response.BrAPIObservationVariableListResponseResult; import org.brapi.v2.model.pheno.response.BrAPIObservationVariableSingleResponse; import org.breedinginsight.brapps.importer.services.ExternalReferenceSource; import org.breedinginsight.dao.db.tables.BiUserTable; @@ -43,8 +41,6 @@ import org.breedinginsight.daos.ObservationDAO; import org.breedinginsight.daos.ProgramDAO; import org.breedinginsight.daos.TraitDAO; -import org.breedinginsight.daos.cache.ProgramCache; -import org.breedinginsight.daos.cache.ProgramCacheProvider; import org.breedinginsight.model.*; import org.breedinginsight.model.User; import org.breedinginsight.services.brapi.BrAPIEndpointProvider; @@ -74,7 +70,6 @@ public class TraitDAOImpl extends TraitDao implements TraitDAO { private final Boolean runScheduledTasks; private final ObservationDAO observationDao; private final BrAPIDAOUtil brAPIDAOUtil; - private final ProgramCache cache; private final ProgramDAO programDAO; private final BrAPIEndpointProvider brAPIEndpointProvider; private final Gson gson; @@ -89,7 +84,6 @@ public TraitDAOImpl(Configuration config, ObservationDAO observationDao, BrAPIDAOUtil brAPIDAOUtil, ProgramDAO programDAO, - ProgramCacheProvider programCacheProvider, BrAPIEndpointProvider brAPIEndpointProvider, @Property(name = "brapi.server.reference-source") String referenceSource, @Property(name = "micronaut.bi.api.run-scheduled-tasks") Boolean runScheduledTasks) { @@ -98,7 +92,6 @@ public TraitDAOImpl(Configuration config, this.brAPIProvider = brAPIProvider; this.observationDao = observationDao; this.brAPIDAOUtil = brAPIDAOUtil; - this.cache = programCacheProvider.getProgramCache(this::populateCache, Trait.class); this.programDAO = programDAO; this.brAPIEndpointProvider = brAPIEndpointProvider; this.gson = new GsonBuilder().registerTypeAdapter(OffsetDateTime.class, (JsonDeserializer) @@ -110,29 +103,6 @@ public TraitDAOImpl(Configuration config, this.runScheduledTasks = runScheduledTasks; } - @Scheduled(initialDelay = "${startup.delay.trait}") - public void setup() { - if(!runScheduledTasks) { - return; - } - // Populate trait cache for all programs on startup - log.debug("Populate traits cache"); - List programs = programDAO.getActive(); - if(programs != null) { - cache.populate(programs.stream().map(Program::getId).collect(Collectors.toList())); - } - } - - private Map populateCache(UUID programId) { - List programTraits = fetchTraitsFullByProgramId(programId); - Map traits = new HashMap<>(); - if (!programTraits.isEmpty()) { - programTraits.forEach(trait -> traits.put(trait.getId().toString(), trait)); - } - - return traits; - } - @Override public List getTraitsFullByProgramId(UUID programId) { List programIds = new ArrayList<>(); @@ -504,8 +474,6 @@ public List createTraitsBrAPI(List traits, User actingUser, Progra if (brApiExternalReference.getReferenceSource().equals(referenceSource) && brApiExternalReference.getReferenceID().equals(trait.getId().toString())){ saturateTrait(trait, variable); - - cache.set(program.getId(), trait.getId().toString(), trait); } } } @@ -568,9 +536,6 @@ public Trait updateTraitBrAPI(Trait trait, Program program) { // Retrieve our update trait from the db updatedTrait = getTrait(program.getId(), trait.getId()).get(); saturateTrait(updatedTrait, updatedVariable); - - //update cache - cache.set(program.getId(), updatedTrait.getId().toString(), updatedTrait); } return updatedTrait;