Skip to content

Commit ab46add

Browse files
committed
revert moving to join
1 parent c1d4d88 commit ab46add

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

server/src/main/java/com/cloud/api/query/QueryManagerImpl.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3448,7 +3448,7 @@ private Ternary<List<Long>, Integer, String[]> searchForDiskOfferingsIdsAndCount
34483448

34493449
Filter searchFilter = new Filter(DiskOfferingVO.class, "sortKey", SortKeyAscending.value(), cmd.getStartIndex(), cmd.getPageSizeVal());
34503450
searchFilter.addOrderBy(DiskOfferingVO.class, "id", true);
3451-
SearchBuilder<DiskOfferingJoinVO> diskOfferingSearch = _diskOfferingJoinDao.createSearchBuilder();
3451+
SearchBuilder<DiskOfferingVO> diskOfferingSearch = _diskOfferingDao.createSearchBuilder();
34523452
diskOfferingSearch.select(null, Func.DISTINCT, diskOfferingSearch.entity().getId()); // select distinct
34533453

34543454
diskOfferingSearch.and("computeOnly", diskOfferingSearch.entity().isComputeOnly(), Op.EQ);
@@ -3476,17 +3476,17 @@ private Ternary<List<Long>, Integer, String[]> searchForDiskOfferingsIdsAndCount
34763476
domainDetailsSearch.entity().getName(), diskOfferingSearch.entity().setString(ApiConstants.DOMAIN_ID));
34773477

34783478
if (!isRootAdmin) {
3479-
diskOfferingSearch.and("displayOffering", diskOfferingSearch.entity().isDisplayOffering(), Op.EQ);
3479+
diskOfferingSearch.and("displayOffering", diskOfferingSearch.entity().getDisplayOffering(), Op.EQ);
34803480
}
34813481

3482-
SearchCriteria<DiskOfferingJoinVO> sc = diskOfferingSearch.create();
3482+
SearchCriteria<DiskOfferingVO> sc = diskOfferingSearch.create();
34833483
sc.setParameters("computeOnly", false);
34843484
sc.setParameters("activeState", DiskOffering.State.Active);
34853485

34863486
sc.setJoinParameters("domainDetailsSearch", "domainId", domainId);
34873487

3488-
Pair<List<DiskOfferingJoinVO>, Integer> uniquePairs = _diskOfferingJoinDao.searchAndCount(sc, searchFilter);
3489-
List<Long> idsArray = uniquePairs.first().stream().map(DiskOfferingJoinVO::getId).collect(Collectors.toList());
3488+
Pair<List<DiskOfferingVO>, Integer> uniquePairs = _diskOfferingDao.searchAndCount(sc, searchFilter);
3489+
List<Long> idsArray = uniquePairs.first().stream().map(DiskOfferingVO::getId).collect(Collectors.toList());
34903490
return new Ternary<>(idsArray, uniquePairs.second(), new String[0]);
34913491
} else {
34923492
throw new PermissionDeniedException("The account:" + account.getAccountName() + " does not fall in the same domain hierarchy as the disk offering");
@@ -3569,7 +3569,7 @@ private Ternary<List<Long>, Integer, String[]> searchForDiskOfferingsIdsAndCount
35693569
domainDetailsSearch.entity().getName(), diskOfferingSearch.entity().setString(ApiConstants.DOMAIN_ID));
35703570
}
35713571

3572-
SearchCriteria<DiskOfferingJoinVO> sc = diskOfferingSearch.create();
3572+
SearchCriteria<DiskOfferingVO> sc = diskOfferingSearch.create();
35733573

35743574
sc.setParameters("computeOnly", false);
35753575

@@ -3629,7 +3629,7 @@ private Ternary<List<Long>, Integer, String[]> searchForDiskOfferingsIdsAndCount
36293629
sc.setJoinParameters("domainDetailsSearch", "domainIdIN", domainIds.toArray());
36303630
}
36313631

3632-
Pair<List<DiskOfferingJoinVO>, Integer> uniquePairs = _diskOfferingJoinDao.searchAndCount(sc, searchFilter);
3632+
Pair<List<DiskOfferingVO>, Integer> uniquePairs = _diskOfferingDao.searchAndCount(sc, searchFilter);
36333633
String[] requiredTagsArray = new String[0];
36343634
if (CollectionUtils.isNotEmpty(uniquePairs.first()) && VolumeApiServiceImpl.MatchStoragePoolTagsWithDiskOffering.valueIn(zoneId)) {
36353635
if (volumeId != null) {
@@ -3638,7 +3638,7 @@ private Ternary<List<Long>, Integer, String[]> searchForDiskOfferingsIdsAndCount
36383638
requiredTagsArray = _storageTagDao.getStoragePoolTags(storagePoolId).toArray(new String[0]);
36393639
}
36403640
}
3641-
List<Long> idsArray = uniquePairs.first().stream().map(DiskOfferingJoinVO::getId).collect(Collectors.toList());
3641+
List<Long> idsArray = uniquePairs.first().stream().map(DiskOfferingVO::getId).collect(Collectors.toList());
36423642

36433643
return new Ternary<>(idsArray, uniquePairs.second(), requiredTagsArray);
36443644
}

0 commit comments

Comments
 (0)