Refactor to prevent adding additional signatures to expungeEverythingByType.
This commit is contained in:
parent
7001272e4b
commit
0724e652bb
|
@ -126,37 +126,37 @@ public class ExpungeEverythingService {
|
||||||
counter.addAndGet(doExpungeEverythingQuery("UPDATE " + TermCodeSystem.class.getSimpleName() + " d SET d.myCurrentVersion = null"));
|
counter.addAndGet(doExpungeEverythingQuery("UPDATE " + TermCodeSystem.class.getSimpleName() + " d SET d.myCurrentVersion = null"));
|
||||||
return null;
|
return null;
|
||||||
});
|
});
|
||||||
counter.addAndGet(expungeEverythingByType(NpmPackageVersionResourceEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(NpmPackageVersionResourceEntity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(NpmPackageVersionEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(NpmPackageVersionEntity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(NpmPackageEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(NpmPackageEntity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(SearchParamPresent.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(SearchParamPresent.class));
|
||||||
counter.addAndGet(expungeEverythingByType(BulkImportJobFileEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(BulkImportJobFileEntity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(BulkImportJobEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(BulkImportJobEntity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ForcedId.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ForcedId.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamDate.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamDate.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamNumber.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamNumber.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamQuantity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamQuantity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamQuantityNormalized.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamQuantityNormalized.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamString.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamString.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamToken.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamToken.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamUri.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamUri.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedSearchParamCoords.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedSearchParamCoords.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedComboStringUnique.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedComboStringUnique.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceIndexedComboTokenNonUnique.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceIndexedComboTokenNonUnique.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceLink.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceLink.class));
|
||||||
counter.addAndGet(expungeEverythingByType(SearchResult.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(SearchResult.class));
|
||||||
counter.addAndGet(expungeEverythingByType(SearchInclude.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(SearchInclude.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermValueSetConceptDesignation.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermValueSetConceptDesignation.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermValueSetConcept.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermValueSetConcept.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermValueSet.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermValueSet.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptParentChildLink.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptParentChildLink.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptMapGroupElementTarget.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptMapGroupElementTarget.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptMapGroupElement.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptMapGroupElement.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptMapGroup.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptMapGroup.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptMap.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptMap.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptProperty.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptProperty.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConceptDesignation.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConceptDesignation.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermConcept.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermConcept.class));
|
||||||
myTxTemplate.execute(t -> {
|
myTxTemplate.execute(t -> {
|
||||||
for (TermCodeSystem next : myEntityManager.createQuery("SELECT c FROM " + TermCodeSystem.class.getName() + " c", TermCodeSystem.class).getResultList()) {
|
for (TermCodeSystem next : myEntityManager.createQuery("SELECT c FROM " + TermCodeSystem.class.getName() + " c", TermCodeSystem.class).getResultList()) {
|
||||||
next.setCurrentVersion(null);
|
next.setCurrentVersion(null);
|
||||||
|
@ -164,44 +164,34 @@ public class ExpungeEverythingService {
|
||||||
}
|
}
|
||||||
return null;
|
return null;
|
||||||
});
|
});
|
||||||
counter.addAndGet(expungeEverythingByType(TermCodeSystemVersion.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermCodeSystemVersion.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TermCodeSystem.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TermCodeSystem.class));
|
||||||
counter.addAndGet(expungeEverythingByType(SubscriptionTable.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(SubscriptionTable.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceHistoryTag.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceHistoryTag.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceTag.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceTag.class));
|
||||||
counter.addAndGet(expungeEverythingByType(TagDefinition.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(TagDefinition.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceHistoryProvenanceEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceHistoryProvenanceEntity.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceHistoryTable.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceHistoryTable.class));
|
||||||
counter.addAndGet(expungeEverythingByType(ResourceTable.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(ResourceTable.class));
|
||||||
counter.addAndGet(expungeEverythingByType(PartitionEntity.class, false));
|
counter.addAndGet(expungeEverythingByTypeWithoutPurging(PartitionEntity.class));
|
||||||
myTxTemplate.execute(t -> {
|
myTxTemplate.execute(t -> {
|
||||||
counter.addAndGet(doExpungeEverythingQuery("DELETE from " + Search.class.getSimpleName() + " d"));
|
counter.addAndGet(doExpungeEverythingQuery("DELETE from " + Search.class.getSimpleName() + " d"));
|
||||||
return null;
|
return null;
|
||||||
});
|
});
|
||||||
|
|
||||||
myTxTemplate.execute(t -> {
|
purgeAllCaches();
|
||||||
myMemoryCacheService.invalidateAllCaches();
|
|
||||||
return null;
|
|
||||||
});
|
|
||||||
|
|
||||||
ourLog.info("COMPLETED GLOBAL $expunge - Deleted {} rows", counter.get());
|
ourLog.info("COMPLETED GLOBAL $expunge - Deleted {} rows", counter.get());
|
||||||
}
|
}
|
||||||
|
|
||||||
public int expungeEverythingByType(Class<?> theEntityType, boolean purgeMemoryCache) {
|
private void purgeAllCaches() {
|
||||||
int outcome = expungeEverythingByType(theEntityType);
|
|
||||||
|
|
||||||
if (purgeMemoryCache) {
|
|
||||||
myTxTemplate.execute(t -> {
|
myTxTemplate.execute(t -> {
|
||||||
myMemoryCacheService.invalidateAllCaches();
|
myMemoryCacheService.invalidateAllCaches();
|
||||||
return null;
|
return null;
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
return outcome;
|
private int expungeEverythingByTypeWithoutPurging(Class<?> theEntityType) {
|
||||||
}
|
|
||||||
|
|
||||||
public int expungeEverythingByType(Class<?> theEntityType) {
|
|
||||||
|
|
||||||
int outcome = 0;
|
int outcome = 0;
|
||||||
while (true) {
|
while (true) {
|
||||||
StopWatch sw = new StopWatch();
|
StopWatch sw = new StopWatch();
|
||||||
|
@ -230,6 +220,12 @@ public class ExpungeEverythingService {
|
||||||
return outcome;
|
return outcome;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public int expungeEverythingByType(Class<?> theEntityType) {
|
||||||
|
int result = expungeEverythingByTypeWithoutPurging(theEntityType);
|
||||||
|
purgeAllCaches();
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
private int doExpungeEverythingQuery(String theQuery) {
|
private int doExpungeEverythingQuery(String theQuery) {
|
||||||
StopWatch sw = new StopWatch();
|
StopWatch sw = new StopWatch();
|
||||||
int outcome = myEntityManager.createQuery(theQuery).executeUpdate();
|
int outcome = myEntityManager.createQuery(theQuery).executeUpdate();
|
||||||
|
|
Loading…
Reference in New Issue