SONAR-7187 Rename CeActivityQuery to CeTaskQuery

8 files changed, 44 insertions, 41 deletions

diff --git a/sonar-db/src/main/java/org/sonar/db/ce/CeActivityDao.java b/sonar-db/src/main/java/org/sonar/db/ce/CeActivityDao.java
index 97bf1f41c4f..6bb9b68aff0 100644
--- a/sonar-db/src/main/java/org/sonar/db/ce/CeActivityDao.java
+++ b/sonar-db/src/main/java/org/sonar/db/ce/CeActivityDao.java
@@ -64,7 +64,7 @@ public class CeActivityDao implements Dao {
   /**
    * Ordered by id desc -> newest to oldest
    */
-  public List<CeActivityDto> selectByQuery(DbSession dbSession, CeActivityQuery query, int offset, int pageSize) {
+  public List<CeActivityDto> selectByQuery(DbSession dbSession, CeTaskQuery query, int offset, int pageSize) {
     if (query.isShortCircuitedByComponentUuids()) {
       return Collections.emptyList();
     }
@@ -72,7 +72,7 @@ public class CeActivityDao implements Dao {
     return mapper(dbSession).selectByQuery(query, new RowBounds(offset, pageSize));
   }
 
-  public int countByQuery(DbSession dbSession, CeActivityQuery query) {
+  public int countByQuery(DbSession dbSession, CeTaskQuery query) {
     if (query.isShortCircuitedByComponentUuids()) {
       return 0;
     }
diff --git a/sonar-db/src/main/java/org/sonar/db/ce/CeActivityMapper.java b/sonar-db/src/main/java/org/sonar/db/ce/CeActivityMapper.java
index 6ee4221193f..a59254827ed 100644
--- a/sonar-db/src/main/java/org/sonar/db/ce/CeActivityMapper.java
+++ b/sonar-db/src/main/java/org/sonar/db/ce/CeActivityMapper.java
@@ -33,11 +33,11 @@ public interface CeActivityMapper {
 
   List<CeActivityDto> selectByComponentUuid(@Param("componentUuid") String componentUuid);
 
-  List<CeActivityDto> selectByQuery(@Param("query") CeActivityQuery query, RowBounds rowBounds);
+  List<CeActivityDto> selectByQuery(@Param("query") CeTaskQuery query, RowBounds rowBounds);
 
   List<CeActivityDto> selectOlderThan(@Param("beforeDate") long beforeDate);
 
-  int countByQuery(@Param("query") CeActivityQuery query);
+  int countByQuery(@Param("query") CeTaskQuery query);
 
   void insert(CeActivityDto dto);
 
diff --git a/sonar-db/src/main/java/org/sonar/db/ce/CeQueueDao.java b/sonar-db/src/main/java/org/sonar/db/ce/CeQueueDao.java
index 09f0b964ea6..543a8f4956d 100644
--- a/sonar-db/src/main/java/org/sonar/db/ce/CeQueueDao.java
+++ b/sonar-db/src/main/java/org/sonar/db/ce/CeQueueDao.java
@@ -46,7 +46,7 @@ public class CeQueueDao implements Dao {
     return mapper(session).selectAllInAscOrder();
   }
 
-  public List<CeQueueDto> selectByQueryInDescOrder(DbSession dbSession, CeActivityQuery query, Paging paging) {
+  public List<CeQueueDto> selectByQueryInDescOrder(DbSession dbSession, CeTaskQuery query, Paging paging) {
     if (query.isShortCircuitedByComponentUuids()
       || query.isOnlyCurrents()
       || query.getMaxExecutedAt() != null) {
@@ -56,7 +56,7 @@ public class CeQueueDao implements Dao {
     return mapper(dbSession).selectByQueryInDescOrder(query, new RowBounds(paging.offset(), paging.pageSize()));
   }
 
-  public int countByQuery(DbSession dbSession, CeActivityQuery query) {
+  public int countByQuery(DbSession dbSession, CeTaskQuery query) {
     if (query.isShortCircuitedByComponentUuids()
       || query.isOnlyCurrents()
       || query.getMaxExecutedAt() != null) {
diff --git a/sonar-db/src/main/java/org/sonar/db/ce/CeQueueMapper.java b/sonar-db/src/main/java/org/sonar/db/ce/CeQueueMapper.java
index fb803a73fa8..64bcadb1cb7 100644
--- a/sonar-db/src/main/java/org/sonar/db/ce/CeQueueMapper.java
+++ b/sonar-db/src/main/java/org/sonar/db/ce/CeQueueMapper.java
@@ -31,9 +31,9 @@ public interface CeQueueMapper {
 
   List<CeQueueDto> selectAllInAscOrder();
 
-  List<CeQueueDto> selectByQueryInDescOrder(@Param("query") CeActivityQuery query, RowBounds rowBounds);
+  List<CeQueueDto> selectByQueryInDescOrder(@Param("query") CeTaskQuery query, RowBounds rowBounds);
 
-  int countByQuery(@Param("query") CeActivityQuery query);
+  int countByQuery(@Param("query") CeTaskQuery query);
 
   List<String> selectEligibleForPeek();
 
diff --git a/sonar-db/src/main/java/org/sonar/db/ce/CeActivityQuery.java b/sonar-db/src/main/java/org/sonar/db/ce/CeTaskQuery.java
index 2681554dcab..17862ce6996 100644
--- a/sonar-db/src/main/java/org/sonar/db/ce/CeActivityQuery.java
+++ b/sonar-db/src/main/java/org/sonar/db/ce/CeTaskQuery.java
@@ -26,7 +26,10 @@ import org.sonar.db.DatabaseUtils;
 
 import static java.util.Collections.singletonList;
 
-public class CeActivityQuery {
+/**
+ * Db Query used for CE_QUEUE and CE_ACTIVITY tables
+ */
+public class CeTaskQuery {
 
   public static final int MAX_COMPONENT_UUIDS = DatabaseUtils.PARTITION_SIZE_FOR_ORACLE;
 
@@ -42,7 +45,7 @@ public class CeActivityQuery {
     return componentUuids;
   }
 
-  public CeActivityQuery setComponentUuids(@Nullable List<String> l) {
+  public CeTaskQuery setComponentUuids(@Nullable List<String> l) {
     this.componentUuids = l;
     return this;
   }
@@ -51,7 +54,7 @@ public class CeActivityQuery {
     return componentUuids != null && (componentUuids.isEmpty() || componentUuids.size() > MAX_COMPONENT_UUIDS);
   }
 
-  public CeActivityQuery setComponentUuid(@Nullable String s) {
+  public CeTaskQuery setComponentUuid(@Nullable String s) {
     if (s == null) {
       this.componentUuids = null;
     } else {
@@ -64,7 +67,7 @@ public class CeActivityQuery {
     return onlyCurrents;
   }
 
-  public CeActivityQuery setOnlyCurrents(boolean onlyCurrents) {
+  public CeTaskQuery setOnlyCurrents(boolean onlyCurrents) {
     this.onlyCurrents = onlyCurrents;
     return this;
   }
@@ -74,7 +77,7 @@ public class CeActivityQuery {
     return statuses;
   }
 
-  public CeActivityQuery setStatuses(@Nullable List<String> statuses) {
+  public CeTaskQuery setStatuses(@Nullable List<String> statuses) {
     this.statuses = statuses;
     return this;
   }
@@ -84,7 +87,7 @@ public class CeActivityQuery {
     return type;
   }
 
-  public CeActivityQuery setType(@Nullable String type) {
+  public CeTaskQuery setType(@Nullable String type) {
     this.type = type;
     return this;
   }
@@ -94,7 +97,7 @@ public class CeActivityQuery {
     return maxExecutedAt;
   }
 
-  public CeActivityQuery setMaxExecutedAt(@Nullable Long l) {
+  public CeTaskQuery setMaxExecutedAt(@Nullable Long l) {
     this.maxExecutedAt = l;
     return this;
   }
@@ -104,7 +107,7 @@ public class CeActivityQuery {
     return minSubmittedAt;
   }
 
-  public CeActivityQuery setMinSubmittedAt(@Nullable Long l) {
+  public CeTaskQuery setMinSubmittedAt(@Nullable Long l) {
     this.minSubmittedAt = l;
     return this;
   }
diff --git a/sonar-db/src/test/java/org/sonar/db/ce/CeActivityDaoTest.java b/sonar-db/src/test/java/org/sonar/db/ce/CeActivityDaoTest.java
index cf726322310..05ab62daee3 100644
--- a/sonar-db/src/test/java/org/sonar/db/ce/CeActivityDaoTest.java
+++ b/sonar-db/src/test/java/org/sonar/db/ce/CeActivityDaoTest.java
@@ -96,30 +96,30 @@ public class CeActivityDaoTest {
     insert("TASK_4", "views", null, CeActivityDto.Status.SUCCESS);
 
     // no filters
-    CeActivityQuery query = new CeActivityQuery().setStatuses(Collections.<String>emptyList());
+    CeTaskQuery query = new CeTaskQuery().setStatuses(Collections.<String>emptyList());
     List<CeActivityDto> dtos = underTest.selectByQuery(db.getSession(), query, 0, 10);
     assertThat(dtos).extracting("uuid").containsExactly("TASK_4", "TASK_3", "TASK_2", "TASK_1");
 
     // select by component uuid
-    query = new CeActivityQuery().setComponentUuid("PROJECT_1");
+    query = new CeTaskQuery().setComponentUuid("PROJECT_1");
     dtos = underTest.selectByQuery(db.getSession(), query, 0, 100);
     assertThat(dtos).extracting("uuid").containsExactly("TASK_2", "TASK_1");
 
     // select by status
-    query = new CeActivityQuery().setStatuses(singletonList(CeActivityDto.Status.SUCCESS.name()));
+    query = new CeTaskQuery().setStatuses(singletonList(CeActivityDto.Status.SUCCESS.name()));
     dtos = underTest.selectByQuery(db.getSession(), query, 0, 100);
     assertThat(dtos).extracting("uuid").containsExactly("TASK_4", "TASK_3", "TASK_1");
 
     // select by type
-    query = new CeActivityQuery().setType(REPORT);
+    query = new CeTaskQuery().setType(REPORT);
     dtos = underTest.selectByQuery(db.getSession(), query, 0, 100);
     assertThat(dtos).extracting("uuid").containsExactly("TASK_3", "TASK_2", "TASK_1");
-    query = new CeActivityQuery().setType("views");
+    query = new CeTaskQuery().setType("views");
     dtos = underTest.selectByQuery(db.getSession(), query, 0, 100);
     assertThat(dtos).extracting("uuid").containsExactly("TASK_4");
 
     // select by multiple conditions
-    query = new CeActivityQuery().setType(REPORT).setOnlyCurrents(true).setComponentUuid("PROJECT_1");
+    query = new CeTaskQuery().setType(REPORT).setOnlyCurrents(true).setComponentUuid("PROJECT_1");
     dtos = underTest.selectByQuery(db.getSession(), query, 0, 100);
     assertThat(dtos).extracting("uuid").containsExactly("TASK_2");
   }
@@ -132,25 +132,25 @@ public class CeActivityDaoTest {
     insert("TASK_4", "views", null, CeActivityDto.Status.SUCCESS);
 
     // no filters
-    CeActivityQuery query = new CeActivityQuery();
+    CeTaskQuery query = new CeTaskQuery();
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(4);
 
     // select by component uuid
-    query = new CeActivityQuery().setComponentUuid("PROJECT_1");
+    query = new CeTaskQuery().setComponentUuid("PROJECT_1");
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(2);
 
     // select by status
-    query = new CeActivityQuery().setStatuses(singletonList(CeActivityDto.Status.SUCCESS.name()));
+    query = new CeTaskQuery().setStatuses(singletonList(CeActivityDto.Status.SUCCESS.name()));
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(3);
 
     // select by type
-    query = new CeActivityQuery().setType(REPORT);
+    query = new CeTaskQuery().setType(REPORT);
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(3);
-    query = new CeActivityQuery().setType("views");
+    query = new CeTaskQuery().setType("views");
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(1);
 
     // select by multiple conditions
-    query = new CeActivityQuery().setType(REPORT).setOnlyCurrents(true).setComponentUuid("PROJECT_1");
+    query = new CeTaskQuery().setType(REPORT).setOnlyCurrents(true).setComponentUuid("PROJECT_1");
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(1);
   }
 
@@ -158,7 +158,7 @@ public class CeActivityDaoTest {
   public void selectByQuery_no_results_if_shortcircuited_by_component_uuids() {
     insert("TASK_1", REPORT, "PROJECT_1", CeActivityDto.Status.SUCCESS);
 
-    CeActivityQuery query = new CeActivityQuery();
+    CeTaskQuery query = new CeTaskQuery();
     query.setComponentUuids(Collections.<String>emptyList());
     assertThat(underTest.selectByQuery(db.getSession(), query, 0, 0)).isEmpty();
   }
@@ -167,7 +167,7 @@ public class CeActivityDaoTest {
   public void countByQuery_no_results_if_shortcircuited_by_component_uuids() {
     insert("TASK_1", REPORT, "PROJECT_1", CeActivityDto.Status.SUCCESS);
 
-    CeActivityQuery query = new CeActivityQuery();
+    CeTaskQuery query = new CeTaskQuery();
     query.setComponentUuids(Collections.<String>emptyList());
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(0);
   }
@@ -178,17 +178,17 @@ public class CeActivityDaoTest {
     insertWithDates("UUID2", 1_460_000_000_000L, 1_480_000_000_000L);
 
     // search by min submitted date
-    CeActivityQuery query = new CeActivityQuery().setMinSubmittedAt(1_455_000_000_000L);
+    CeTaskQuery query = new CeTaskQuery().setMinSubmittedAt(1_455_000_000_000L);
     assertThat(underTest.selectByQuery(db.getSession(), query, 0, 5)).extracting("uuid").containsOnly("UUID2");
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(1);
 
     // search by max executed date
-    query = new CeActivityQuery().setMaxExecutedAt(1_475_000_000_000L);
+    query = new CeTaskQuery().setMaxExecutedAt(1_475_000_000_000L);
     assertThat(underTest.selectByQuery(db.getSession(), query, 0, 5)).extracting("uuid").containsOnly("UUID1");
     assertThat(underTest.countByQuery(db.getSession(), query)).isEqualTo(1);
 
     // search by both dates
-    query = new CeActivityQuery()
+    query = new CeTaskQuery()
       .setMinSubmittedAt(1_400_000_000_000L)
       .setMaxExecutedAt(1_475_000_000_000L);
     assertThat(underTest.selectByQuery(db.getSession(), query, 0, 5)).extracting("uuid").containsOnly("UUID1");
diff --git a/sonar-db/src/test/java/org/sonar/db/ce/CeQueueDaoTest.java b/sonar-db/src/test/java/org/sonar/db/ce/CeQueueDaoTest.java
index f051fef6284..471c0a29944 100644
--- a/sonar-db/src/test/java/org/sonar/db/ce/CeQueueDaoTest.java
+++ b/sonar-db/src/test/java/org/sonar/db/ce/CeQueueDaoTest.java
@@ -213,7 +213,7 @@ public class CeQueueDaoTest {
       .setCreatedAt(120_000L));
 
     // select by component uuid, status, task type and minimum submitted at
-    CeActivityQuery query = new CeActivityQuery()
+    CeTaskQuery query = new CeTaskQuery()
       .setComponentUuids(newArrayList("PROJECT_1", "PROJECT_2"))
       .setStatuses(singletonList(CeQueueDto.Status.PENDING.name()))
       .setType(CeTaskTypes.REPORT)
@@ -234,7 +234,7 @@ public class CeQueueDaoTest {
       .setTaskType(CeTaskTypes.REPORT)
       .setCreatedAt(100_000L));
 
-    CeActivityQuery query = new CeActivityQuery().setOnlyCurrents(true);
+    CeTaskQuery query = new CeTaskQuery().setOnlyCurrents(true);
 
     List<CeQueueDto> result = underTest.selectByQueryInDescOrder(db.getSession(), query, Paging.forPageIndex(1).withPageSize(1_000).andTotal(1_000));
     int total = underTest.countByQuery(db.getSession(), query);
@@ -251,7 +251,7 @@ public class CeQueueDaoTest {
       .setTaskType(CeTaskTypes.REPORT)
       .setCreatedAt(100_000L));
 
-    CeActivityQuery query = new CeActivityQuery().setMaxExecutedAt(1_000_000_000_000L);
+    CeTaskQuery query = new CeTaskQuery().setMaxExecutedAt(1_000_000_000_000L);
 
     List<CeQueueDto> result = underTest.selectByQueryInDescOrder(db.getSession(), query, Paging.forPageIndex(1).withPageSize(1_000).andTotal(1_000));
     int total = underTest.countByQuery(db.getSession(), query);
@@ -268,7 +268,7 @@ public class CeQueueDaoTest {
       .setTaskType(CeTaskTypes.REPORT)
       .setCreatedAt(100_000L));
 
-    CeActivityQuery query = new CeActivityQuery().setComponentUuids(Collections.<String>emptyList());
+    CeTaskQuery query = new CeTaskQuery().setComponentUuids(Collections.<String>emptyList());
 
     List<CeQueueDto> result = underTest.selectByQueryInDescOrder(db.getSession(), query, Paging.forPageIndex(1).withPageSize(1_000).andTotal(1_000));
     int total = underTest.countByQuery(db.getSession(), query);
diff --git a/sonar-db/src/test/java/org/sonar/db/ce/CeActivityQueryTest.java b/sonar-db/src/test/java/org/sonar/db/ce/CeTaskQueryTest.java
index f490e71dd36..83d8173c9ac 100644
--- a/sonar-db/src/test/java/org/sonar/db/ce/CeActivityQueryTest.java
+++ b/sonar-db/src/test/java/org/sonar/db/ce/CeTaskQueryTest.java
@@ -27,9 +27,9 @@ import org.junit.Test;
 import static java.util.Arrays.asList;
 import static org.assertj.core.api.Assertions.assertThat;
 
-public class CeActivityQueryTest {
+public class CeTaskQueryTest {
 
-  CeActivityQuery underTest = new CeActivityQuery();
+  CeTaskQuery underTest = new CeTaskQuery();
 
   @Test
   public void no_filter_on_component_uuids_by_default() {
@@ -69,11 +69,11 @@ public class CeActivityQueryTest {
   @Test
   public void short_circuited_if_too_many_component_uuid_filters() {
     List<String> uuids = new ArrayList<>();
-    for (int i = 0; i < CeActivityQuery.MAX_COMPONENT_UUIDS + 2; i++) {
+    for (int i = 0; i < CeTaskQuery.MAX_COMPONENT_UUIDS + 2; i++) {
       uuids.add(String.valueOf(i));
     }
     underTest.setComponentUuids(uuids);
-    assertThat(underTest.getComponentUuids()).hasSize(CeActivityQuery.MAX_COMPONENT_UUIDS + 2);
+    assertThat(underTest.getComponentUuids()).hasSize(CeTaskQuery.MAX_COMPONENT_UUIDS + 2);
     assertThat(underTest.isShortCircuitedByComponentUuids()).isTrue();
   }
 }