Incremental indexing of activities

diff --git a/server/sonar-server/src/main/java/org/sonar/server/activity/db/ActivityDao.java b/server/sonar-server/src/main/java/org/sonar/server/activity/db/ActivityDao.java
index f2c9b9561e3487e52a06c224fb0364d93674ef4f..7d4a636947f7f7c9e2258ac33ce229e41cf10ff8 100644 (file)
--- a/server/sonar-server/src/main/java/org/sonar/server/activity/db/ActivityDao.java
+++ b/server/sonar-server/src/main/java/org/sonar/server/activity/db/ActivityDao.java
@@ -58,11 +58,6 @@ public class ActivityDao extends BaseDao<ActivityMapper, ActivityDto, String> {
     throw new IllegalStateException("Cannot delete Log!");
   }
 
-  @Override
-  protected String getSynchronizationStatementName() {
-    return "selectAll";
-  }
-
   public List<ActivityDto> findAll(DbSession session) {
     return mapper(session).selectAll();
   }

diff --git a/sonar-core/src/main/java/org/sonar/core/activity/db/ActivityMapper.java b/sonar-core/src/main/java/org/sonar/core/activity/db/ActivityMapper.java
index 0d507e08a832b08eb140a2de76d952b7a8ade88c..d7f5959c42234756086507518b4405b0d5c4aa5b 100644 (file)
--- a/sonar-core/src/main/java/org/sonar/core/activity/db/ActivityMapper.java
+++ b/sonar-core/src/main/java/org/sonar/core/activity/db/ActivityMapper.java
@@ -19,6 +19,11 @@
  */
 package org.sonar.core.activity.db;
 
+import org.apache.ibatis.annotations.Param;
+
+import javax.annotation.Nullable;
+
+import java.sql.Timestamp;
 import java.util.List;
 
 /**
@@ -29,4 +34,6 @@ public interface ActivityMapper {
   void insert(ActivityDto rule);
 
   List<ActivityDto> selectAll();
+
+  List<ActivityDto> selectAfterDate(@Nullable @Param("date") Timestamp timestamp);
 }

diff --git a/sonar-core/src/main/resources/org/sonar/core/activity/db/ActivityMapper.xml b/sonar-core/src/main/resources/org/sonar/core/activity/db/ActivityMapper.xml
index 0c516fa3f89ed419b13b56c96633fad8ebfbaa50..fecd0b0210f58470ea63aa76d5740c803ec9d7cf 100644 (file)
--- a/sonar-core/src/main/resources/org/sonar/core/activity/db/ActivityMapper.xml
+++ b/sonar-core/src/main/resources/org/sonar/core/activity/db/ActivityMapper.xml
@@ -9,7 +9,7 @@
     values (#{createdAt}, #{key}, #{type}, #{action}, #{author}, #{data}, #{message})
   </insert>
 
-  <select id="selectAll" parameterType="map" resultType="Activity" >
+  <select id="selectAll" parameterType="map" resultType="Activity" fetchSize="${_scrollFetchSize}" resultSetType="FORWARD_ONLY">
     SELECT
     created_at as "createdAt",
     log_type as "type",
@@ -21,5 +21,22 @@
     FROM activities
   </select>
 
+
+  <select id="selectAfterDate" parameterType="map" resultType="Activity" fetchSize="${_scrollFetchSize}" resultSetType="FORWARD_ONLY">
+    SELECT
+    created_at as "createdAt",
+    log_type as "type",
+    user_login as "author",
+    data_field as "data",
+    log_message as "message",
+    log_key as "key",
+    log_action as "action"
+    FROM activities
+    <where>
+      <if test="date != null">
+        created_at &gt;= #{date}
+      </if>
+    </where>
+  </select>
 </mapper>