diff --git a/registry-integration-tests/src/test/java/org/gbif/registry/ws/it/OccurrenceDownloadIT.java b/registry-integration-tests/src/test/java/org/gbif/registry/ws/it/OccurrenceDownloadIT.java
index b05354144..198335809 100644
--- a/registry-integration-tests/src/test/java/org/gbif/registry/ws/it/OccurrenceDownloadIT.java
+++ b/registry-integration-tests/src/test/java/org/gbif/registry/ws/it/OccurrenceDownloadIT.java
@@ -548,6 +548,28 @@ public void testDownloadUsages(ServiceType serviceType) {
             occurrenceDownload.getKey(), null, null, null, new PagingRequest());
     assertEquals(2, organizationUsages.getResults().size());
     assertEquals(2, organizationUsages.getCount());
+
+    organizationUsages =
+        service.listOrganizationUsages(
+            occurrenceDownload.getKey(),
+            null,
+            OrganizationUsageSortField.COUNTRY_CODE,
+            null,
+            new PagingRequest(0, 1));
+    assertEquals(1, organizationUsages.getResults().size());
+    assertEquals(2, organizationUsages.getCount());
+
+    organizationUsages =
+        service.listOrganizationUsages(
+            occurrenceDownload.getKey(),
+            null,
+            OrganizationUsageSortField.COUNTRY_CODE,
+            SortOrder.DESC,
+            new PagingRequest(1, 1));
+    assertEquals(1, organizationUsages.getResults().size());
+    assertEquals(2, organizationUsages.getCount());
+    assertEquals(o.getKey(), organizationUsages.getResults().get(0).getOrganizationKey());
+
     organizationUsages =
         service.listOrganizationUsages(
             occurrenceDownload.getKey(),
@@ -579,6 +601,18 @@ public void testDownloadUsages(ServiceType serviceType) {
     assertEquals(2, countryUsages.getResults().size());
     assertEquals(2, countryUsages.getCount());
 
+    countryUsages =
+        service.listCountryUsages(
+            occurrenceDownload.getKey(),
+            CountryUsageSortField.COUNTRY_CODE,
+            SortOrder.DESC,
+            new PagingRequest(1, 1));
+    assertEquals(1, countryUsages.getResults().size());
+    assertEquals(2, countryUsages.getCount());
+    assertEquals(
+        Country.DENMARK.getIso2LetterCode(),
+        countryUsages.getResults().get(0).getPublishingCountryCode());
+
     countryUsages =
         service.listCountryUsages(
             occurrenceDownload.getKey(),
diff --git a/registry-persistence/src/main/java/org/gbif/registry/persistence/config/MyBatisConfiguration.java b/registry-persistence/src/main/java/org/gbif/registry/persistence/config/MyBatisConfiguration.java
index e2e07639d..4ac8154ce 100644
--- a/registry-persistence/src/main/java/org/gbif/registry/persistence/config/MyBatisConfiguration.java
+++ b/registry-persistence/src/main/java/org/gbif/registry/persistence/config/MyBatisConfiguration.java
@@ -86,8 +86,6 @@
 import java.net.URI;
 import java.util.UUID;
 
-import org.gbif.registry.persistence.mapper.params.OrganizationOccurrenceDownloadDto;
-
 import org.mybatis.spring.boot.autoconfigure.ConfigurationCustomizer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -128,10 +126,6 @@ ConfigurationCustomizer mybatisConfigCustomizer() {
       configuration.getTypeAliasRegistry().registerAlias("Metadata", Metadata.class);
       configuration.getTypeAliasRegistry().registerAlias("Download", Download.class);
       configuration.getTypeAliasRegistry().registerAlias("DownloadRequest", DownloadRequest.class);
-      configuration
-          .getTypeAliasRegistry()
-          .registerAlias(
-              "OrganizationOccurrenceDownloadDto", OrganizationOccurrenceDownloadDto.class);
       configuration
           .getTypeAliasRegistry()
           .registerAlias("PredicateDownloadRequest", PredicateDownloadRequest.class);
diff --git a/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.java b/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.java
index 1fa6eec71..ebf613b91 100644
--- a/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.java
+++ b/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.java
@@ -15,10 +15,13 @@
 
 import org.gbif.api.model.common.paging.Pageable;
 import org.gbif.api.model.occurrence.DownloadType;
+import org.gbif.api.model.registry.CountryOccurrenceDownloadUsage;
 import org.gbif.api.model.registry.DatasetOccurrenceDownloadUsage;
+import org.gbif.api.model.registry.OrganizationOccurrenceDownloadUsage;
+import org.gbif.api.vocabulary.CountryUsageSortField;
 import org.gbif.api.vocabulary.DatasetUsageSortField;
+import org.gbif.api.vocabulary.OrganizationUsageSortField;
 import org.gbif.api.vocabulary.SortOrder;
-import org.gbif.registry.persistence.mapper.params.OrganizationOccurrenceDownloadDto;
 
 import java.util.List;
 import java.util.Map;
@@ -55,16 +58,22 @@ void createOrUpdateUsages(
       @Param("downloadKey") String downloadKey,
       @Param("citationMap") Map<UUID, Long> downloadDataset);
 
-  List<OrganizationOccurrenceDownloadDto> listOrganizationsByDownload(
+  List<OrganizationOccurrenceDownloadUsage> listOrganizationsByDownload(
       @Param("downloadKey") String downloadKey,
       @Param("organizationTitle") String organizationTitle,
+      @Param("sortBy") OrganizationUsageSortField sortBy,
+      @Param("sortOrder") SortOrder sortOrder,
       @Nullable @Param("page") Pageable page);
 
-  int countOrganizationsByDownload(
+  List<CountryOccurrenceDownloadUsage> listCountriesByDownload(
       @Param("downloadKey") String downloadKey,
-      @Param("organizationTitle") String organizationTitle);
+      @Param("sortBy") CountryUsageSortField sortBy,
+      @Param("sortOrder") SortOrder sortOrder,
+      @Nullable @Param("page") Pageable page);
 
-  int countCountriesByDownload(
+  int countOrganizationsByDownload(
       @Param("downloadKey") String downloadKey,
       @Param("organizationTitle") String organizationTitle);
+
+  int countCountriesByDownload(@Param("downloadKey") String downloadKey);
 }
diff --git a/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/params/OrganizationOccurrenceDownloadDto.java b/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/params/OrganizationOccurrenceDownloadDto.java
deleted file mode 100644
index ee5085a85..000000000
--- a/registry-persistence/src/main/java/org/gbif/registry/persistence/mapper/params/OrganizationOccurrenceDownloadDto.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package org.gbif.registry.persistence.mapper.params;
-
-import java.util.UUID;
-
-import lombok.Data;
-
-@Data
-public class OrganizationOccurrenceDownloadDto {
-
-  private String downloadKey;
-  private UUID datasetKey;
-  private UUID organizationKey;
-  private String organizationTitle;
-  private long numberRecords;
-  private String publishingCountryCode;
-}
diff --git a/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.xml b/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.xml
index 60d100070..ec8f49f84 100644
--- a/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.xml
+++ b/registry-persistence/src/main/resources/org/gbif/registry/persistence/mapper/DatasetOccurrenceDownloadMapper.xml
@@ -24,23 +24,24 @@
     <!-- The download is null -->
   </resultMap>
 
-  <resultMap id="ORGANIZATION_OCCURRENCE_MAP" type="OrganizationOccurrenceDownloadDto" autoMapping="false">
+  <resultMap id="ORGANIZATION_OCCURRENCE_DOWNLOAD_MAP" type="org.gbif.api.model.registry.OrganizationOccurrenceDownloadUsage" autoMapping="false">
     <id property="downloadKey" column="download_key"/>
-    <id property="datasetKey" column="dataset_key"/>
-    <result property="organizationKey" column="orgKey"/>
-    <result property="organizationTitle" column="orgTitle"/>
-    <result property="numberRecords" column="number_records"/>
-    <result property="publishingCountryCode" column="country"/>
+    <id property="organizationKey" column="organizationKey"/>
+    <result property="organizationTitle" column="organizationTitle"/>
+    <result property="numberRecords" column="numberRecords"/>
+    <result property="publishingCountryCode" column="publishingCountryCode"/>
+  </resultMap>
+
+  <resultMap id="COUNTRY_OCCURRENCE_DOWNLOAD_MAP" type="org.gbif.api.model.registry.CountryOccurrenceDownloadUsage" autoMapping="false">
+    <id property="downloadKey" column="download_key"/>
+    <id property="publishingCountryCode" column="publishingCountryCode"/>
+    <result property="numberRecords" column="numberRecords"/>
   </resultMap>
 
   <sql id="DATASET_OCCURRENCE_DOWNLOAD_FIELDS">
     dod.download_key,dod.dataset_key,dod.dataset_title,dod.dataset_doi,dod.dataset_citation,dod.number_records
   </sql>
 
-  <sql id="ORGANIZATION_OCCURRENCE_DOWNLOAD_FIELDS">
-    dod.download_key,dod.dataset_key,dod.number_records,o.key AS orgKey,o.title AS orgTitle,o.country
-  </sql>
-
   <select id="listByDataset" resultMap="DATASET_OCCURRENCE_DOWNLOAD_MAP" parameterType="map">
     SELECT <include refid="DATASET_OCCURRENCE_DOWNLOAD_FIELDS"/>,<include refid="org.gbif.registry.persistence.mapper.OccurrenceDownloadMapper.OCCURRENCE_DOWNLOAD_FIELDS"/>
     FROM dataset_occurrence_download dod
@@ -97,8 +98,10 @@
     </if>
   </select>
 
-  <select id="listOrganizationsByDownload" resultMap="ORGANIZATION_OCCURRENCE_MAP" parameterType="org.gbif.api.model.common.paging.Pageable">
-    SELECT <include refid="ORGANIZATION_OCCURRENCE_DOWNLOAD_FIELDS"/>
+  <select id="listOrganizationsByDownload" resultMap="ORGANIZATION_OCCURRENCE_DOWNLOAD_MAP"
+          parameterType="org.gbif.api.model.common.paging.Pageable">
+    SELECT o.key AS organizationKey, o.title AS organizationTitle, o.country AS publishingCountryCode, dod.download_key,
+    sum(dod.number_records) AS numberRecords
     FROM dataset_occurrence_download dod
     INNER JOIN occurrence_download od ON dod.download_key = od.key
     INNER JOIN dataset d on d.key = dod.dataset_key
@@ -107,7 +110,75 @@
     <if test="organizationTitle != null" >
       AND o.title = #{organizationTitle,jdbcType=VARCHAR}
     </if>
-    ORDER BY od.created DESC, od.key
+    GROUP BY o.key, o.title, o.country, dod.download_key, od.created, od.key
+    ORDER BY
+    <if test="sortBy != null">
+      <choose>
+        <when test="sortBy.name.equals('ORGANIZATION_TITLE')">
+          o.title
+        </when>
+        <when test="sortBy.name.equals('COUNTRY_CODE')">
+          o.country
+        </when>
+        <when test="sortBy.name.equals('RECORD_COUNT')">
+          numberRecords
+        </when>
+        <otherwise/>
+      </choose>
+      <if test="sortOrder != null">
+        <choose>
+          <when test="sortOrder.name.equals('DESC')">
+            DESC
+          </when>
+          <otherwise>
+            ASC
+          </otherwise>
+        </choose>
+      </if>
+      ,
+    </if>
+    od.created DESC, od.key, o.key
+    <if test="page != null" >
+      LIMIT #{page.limit} OFFSET #{page.offset}
+    </if>
+  </select>
+
+  <select id="listCountriesByDownload" resultMap="COUNTRY_OCCURRENCE_DOWNLOAD_MAP"
+          parameterType="org.gbif.api.model.common.paging.Pageable">
+    SELECT o.country AS publishingCountryCode, dod.download_key, sum(dod.number_records) AS numberRecords
+    FROM dataset_occurrence_download dod
+    INNER JOIN occurrence_download od ON dod.download_key = od.key
+    INNER JOIN dataset d on d.key = dod.dataset_key
+    INNER JOIN organization o ON o.key = d.publishing_organization_key
+    WHERE dod.download_key = #{downloadKey,jdbcType=OTHER}
+    GROUP BY o.country,dod.download_key,od.created,od.key
+    ORDER BY
+    <if test="sortBy != null">
+      <choose>
+        <when test="sortBy.name.equals('COUNTRY_CODE')">
+          o.country
+        </when>
+        <when test="sortBy.name.equals('RECORD_COUNT')">
+          numberRecords
+        </when>
+        <otherwise/>
+      </choose>
+      <if test="sortOrder != null">
+        <choose>
+          <when test="sortOrder.name.equals('DESC')">
+            DESC
+          </when>
+          <otherwise>
+            ASC
+          </otherwise>
+        </choose>
+      </if>
+      ,
+    </if>
+    od.created DESC, od.key
+    <if test="sortBy != null and sortBy.name.equals('RECORD_COUNT')">
+      ,o.country
+    </if>
     <if test="page != null" >
       LIMIT #{page.limit} OFFSET #{page.offset}
     </if>
@@ -132,9 +203,6 @@
     INNER JOIN dataset d on d.key = dod.dataset_key
     INNER JOIN organization o ON o.key = d.publishing_organization_key
     WHERE dod.download_key = #{downloadKey,jdbcType=OTHER}
-    <if test="organizationTitle != null" >
-      AND o.title = #{organizationTitle,jdbcType=VARCHAR}
-    </if>
   </select>
 
   <select id="countByDataset" resultType="Integer" parameterType="map">
diff --git a/registry-ws/src/main/java/org/gbif/registry/ws/resources/BaseDownloadResource.java b/registry-ws/src/main/java/org/gbif/registry/ws/resources/BaseDownloadResource.java
index 7c799b00b..a3d7aa966 100644
--- a/registry-ws/src/main/java/org/gbif/registry/ws/resources/BaseDownloadResource.java
+++ b/registry-ws/src/main/java/org/gbif/registry/ws/resources/BaseDownloadResource.java
@@ -43,7 +43,6 @@
 import org.gbif.registry.doi.DownloadDoiDataCiteHandlingService;
 import org.gbif.registry.persistence.mapper.DatasetOccurrenceDownloadMapper;
 import org.gbif.registry.persistence.mapper.OccurrenceDownloadMapper;
-import org.gbif.registry.persistence.mapper.params.OrganizationOccurrenceDownloadDto;
 import org.gbif.registry.ws.export.CsvWriter;
 import org.gbif.registry.ws.provider.PartialDate;
 import org.gbif.registry.ws.util.DateUtils;
@@ -58,10 +57,8 @@
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 import java.text.SimpleDateFormat;
-import java.util.Comparator;
 import java.util.Date;
 import java.util.EnumSet;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
@@ -70,7 +67,6 @@
 import java.util.Set;
 import java.util.TreeMap;
 import java.util.UUID;
-import java.util.function.Supplier;
 import java.util.stream.Collectors;
 
 import javax.servlet.http.HttpServletResponse;
@@ -598,62 +594,15 @@ public PagingResponse<OrganizationOccurrenceDownloadUsage> listOrganizationUsage
     if (download != null) {
       page = page != null ? page : new PagingRequest();
 
-      List<OrganizationOccurrenceDownloadDto> dtos =
+      List<OrganizationOccurrenceDownloadUsage> results =
           datasetOccurrenceDownloadMapper.listOrganizationsByDownload(
-              downloadKey, Strings.emptyToNull(organizationTitle), page);
-
-      Map<UUID, OrganizationOccurrenceDownloadUsage> orgsMap = new HashMap<>();
-      for (OrganizationOccurrenceDownloadDto dto : dtos) {
-        OrganizationOccurrenceDownloadUsage usage =
-            orgsMap.computeIfAbsent(
-                dto.getOrganizationKey(),
-                k -> {
-                  OrganizationOccurrenceDownloadUsage newUsage =
-                      new OrganizationOccurrenceDownloadUsage();
-                  newUsage.setDownloadKey(dto.getDownloadKey());
-                  newUsage.setOrganizationKey(dto.getOrganizationKey());
-                  newUsage.setOrganizationTitle(dto.getOrganizationTitle());
-                  newUsage.setPublishingCountryCode(dto.getPublishingCountryCode());
-                  return newUsage;
-                });
-
-        usage.setNumberRecords(usage.getNumberRecords() + dto.getNumberRecords());
-      }
-
-      // we sort it manually because we group the DB results manually
-      Supplier<Comparator<OrganizationOccurrenceDownloadUsage>> comparatorSupplier =
-          () -> {
-            Comparator<OrganizationOccurrenceDownloadUsage> comparator;
-            if (sortBy == OrganizationUsageSortField.ORGANIZATION_TITLE) {
-              comparator =
-                  Comparator.comparing(OrganizationOccurrenceDownloadUsage::getOrganizationTitle);
-            } else if (sortBy == OrganizationUsageSortField.COUNTRY_CODE) {
-              comparator =
-                  Comparator.comparing(
-                      OrganizationOccurrenceDownloadUsage::getPublishingCountryCode);
-            } else if (sortBy == OrganizationUsageSortField.RECORD_COUNT) {
-              comparator =
-                  Comparator.comparing(OrganizationOccurrenceDownloadUsage::getNumberRecords);
-            } else {
-              comparator =
-                  Comparator.comparing(OrganizationOccurrenceDownloadUsage::getOrganizationKey);
-            }
-
-            if (sortOrder == SortOrder.DESC) {
-              comparator = comparator.reversed();
-            }
-
-            return comparator;
-          };
+              downloadKey, Strings.emptyToNull(organizationTitle), sortBy, sortOrder, page);
 
       int count =
           datasetOccurrenceDownloadMapper.countOrganizationsByDownload(
               downloadKey, Strings.emptyToNull(organizationTitle));
 
-      return new PagingResponse<>(
-          page,
-          (long) count,
-          orgsMap.values().stream().sorted(comparatorSupplier.get()).collect(Collectors.toList()));
+      return new PagingResponse<>(page, (long) count, results);
     }
     throw new WebApplicationException("Download was not found", HttpStatus.NOT_FOUND);
   }
@@ -698,50 +647,13 @@ public PagingResponse<CountryOccurrenceDownloadUsage> listCountryUsages(
     if (download != null) {
       page = page != null ? page : new PagingRequest();
 
-      List<OrganizationOccurrenceDownloadDto> dtos =
-          datasetOccurrenceDownloadMapper.listOrganizationsByDownload(downloadKey, null, page);
-
-      Map<String, CountryOccurrenceDownloadUsage> countriesMap = new HashMap<>();
-      for (OrganizationOccurrenceDownloadDto dto : dtos) {
-        CountryOccurrenceDownloadUsage usage =
-            countriesMap.computeIfAbsent(
-                dto.getPublishingCountryCode(),
-                k -> {
-                  CountryOccurrenceDownloadUsage newUsage = new CountryOccurrenceDownloadUsage();
-                  newUsage.setDownloadKey(dto.getDownloadKey());
-                  newUsage.setPublishingCountryCode(dto.getPublishingCountryCode());
-                  return newUsage;
-                });
-
-        usage.setNumberRecords(usage.getNumberRecords() + dto.getNumberRecords());
-      }
-
-      // we sort it manually because we group the DB results manually
-      Supplier<Comparator<CountryOccurrenceDownloadUsage>> comparatorSupplier =
-          () -> {
-            Comparator<CountryOccurrenceDownloadUsage> comparator;
-            if (sortBy == CountryUsageSortField.RECORD_COUNT) {
-              comparator = Comparator.comparing(CountryOccurrenceDownloadUsage::getNumberRecords);
-            } else {
-              comparator =
-                  Comparator.comparing(CountryOccurrenceDownloadUsage::getPublishingCountryCode);
-            }
-
-            if (sortOrder == SortOrder.DESC) {
-              comparator = comparator.reversed();
-            }
-
-            return comparator;
-          };
-
-      int count = datasetOccurrenceDownloadMapper.countCountriesByDownload(downloadKey, null);
-
-      return new PagingResponse<>(
-          page,
-          (long) count,
-          countriesMap.values().stream()
-              .sorted(comparatorSupplier.get())
-              .collect(Collectors.toList()));
+      List<CountryOccurrenceDownloadUsage> results =
+          datasetOccurrenceDownloadMapper.listCountriesByDownload(
+              downloadKey, sortBy, sortOrder, page);
+
+      int count = datasetOccurrenceDownloadMapper.countCountriesByDownload(downloadKey);
+
+      return new PagingResponse<>(page, (long) count, results);
     }
     throw new WebApplicationException("Download was not found", HttpStatus.NOT_FOUND);
   }