From 689c8e71e38e7fbc431f3d0bd1ab1d596b9a551d Mon Sep 17 00:00:00 2001
From: Stephane Gamard <stephane.gamard@searchbox.com>
Date: Fri, 23 May 2014 20:25:23 +0200
Subject: [PATCH] SONAR-5007 - Implementation of IndexSynchronizer

---
 .../qualityprofile/db/ActiveRuleMapper.xml    | 10 +++----
 .../server/platform/ServerComponents.java     |  3 +++
 .../persistence/ActiveRuleDao.java            |  7 ++---
 .../server/search/IndexSynchronizer.java      | 26 +++++++++++++++++--
 4 files changed, 36 insertions(+), 10 deletions(-)

diff --git a/sonar-core/src/main/resources/org/sonar/core/qualityprofile/db/ActiveRuleMapper.xml b/sonar-core/src/main/resources/org/sonar/core/qualityprofile/db/ActiveRuleMapper.xml
index b6fc979e329..9f53644fd29 100644
--- a/sonar-core/src/main/resources/org/sonar/core/qualityprofile/db/ActiveRuleMapper.xml
+++ b/sonar-core/src/main/resources/org/sonar/core/qualityprofile/db/ActiveRuleMapper.xml
@@ -38,14 +38,14 @@
 
     <select id="selectAllKeysAfterTimestamp" parameterType="Date" resultType="map">
         SELECT
-        rule.plugin_rule_key as ruleField,
-        rule.plugin_name as repositoryField,
-        profile.name as profileField,
-        profile.language as languageField
+        r.plugin_rule_key as ruleField,
+        r.plugin_name as repositoryField,
+        qp.name as profileField,
+        qp.language as languageField
         FROM active_rules a
         <include refid="activeRuleKeyJoin"/>
         <where>
-            WHERE a.updated_at IS NULL or a.updated_at &gt;= #{id}
+            a.updated_at IS NULL or a.updated_at &gt;= #{id}
         </where>
     </select>
 
diff --git a/sonar-server/src/main/java/org/sonar/server/platform/ServerComponents.java b/sonar-server/src/main/java/org/sonar/server/platform/ServerComponents.java
index de2240db45e..58120327a55 100644
--- a/sonar-server/src/main/java/org/sonar/server/platform/ServerComponents.java
+++ b/sonar-server/src/main/java/org/sonar/server/platform/ServerComponents.java
@@ -538,6 +538,9 @@ class ServerComponents {
     startupContainer.addSingleton(CleanPreviewAnalysisCache.class);
     startupContainer.addSingleton(CopyRequirementsFromCharacteristicsToRules.class);
 
+    /** Index startup Synchronization */
+    startupContainer.addSingleton(IndexSynchronizer.class);
+
     DoPrivileged.execute(new DoPrivileged.Task() {
       @Override
       protected void doPrivileged() {
diff --git a/sonar-server/src/main/java/org/sonar/server/qualityprofile/persistence/ActiveRuleDao.java b/sonar-server/src/main/java/org/sonar/server/qualityprofile/persistence/ActiveRuleDao.java
index cbe56e8f7cc..2f0732dc05e 100644
--- a/sonar-server/src/main/java/org/sonar/server/qualityprofile/persistence/ActiveRuleDao.java
+++ b/sonar-server/src/main/java/org/sonar/server/qualityprofile/persistence/ActiveRuleDao.java
@@ -37,8 +37,8 @@ import org.sonar.core.qualityprofile.db.QualityProfileKey;
 import org.sonar.core.rule.RuleDto;
 import org.sonar.server.db.BaseDao;
 import org.sonar.server.qualityprofile.QProfile;
-import org.sonar.server.qualityprofile.index.ActiveRuleIndexDefinition;
 import org.sonar.server.rule2.persistence.RuleDao;
+import org.sonar.server.search.IndexDefinition;
 import org.sonar.server.search.action.IndexAction;
 import org.sonar.server.search.action.KeyIndexAction;
 
@@ -58,7 +58,7 @@ public class ActiveRuleDao extends BaseDao<ActiveRuleMapper, ActiveRuleDto, Acti
 
   @VisibleForTesting
   public ActiveRuleDao(QualityProfileDao profileDao, RuleDao ruleDao, System2 system) {
-    super(new ActiveRuleIndexDefinition(), ActiveRuleMapper.class, system);
+    super(IndexDefinition.ACTIVE_RULE, ActiveRuleMapper.class, system);
     this.ruleDao = ruleDao;
     this.profileDao = profileDao;
   }
@@ -75,6 +75,7 @@ public class ActiveRuleDao extends BaseDao<ActiveRuleMapper, ActiveRuleDto, Acti
         session.enqueue(new KeyIndexAction<ActiveRuleKey>(getIndexType(), IndexAction.Method.UPSERT, key));
       }
     });
+    session.commit();
   }
 
 
@@ -135,6 +136,7 @@ public class ActiveRuleDao extends BaseDao<ActiveRuleMapper, ActiveRuleDto, Acti
   @Override
   protected void doDeleteByKey(ActiveRuleKey key, DbSession session) {
     ActiveRuleDto rule = this.getByKey(key, session);
+    mapper(session).deleteParameters(rule.getId());
     mapper(session).delete(rule.getId());
   }
 
@@ -201,7 +203,6 @@ public class ActiveRuleDao extends BaseDao<ActiveRuleMapper, ActiveRuleDto, Acti
 
   public void deleteByProfileKey(QualityProfileKey profileKey, DbSession session) {
     /** Functional cascade for params */
-    this.removeParamByProfileKey(profileKey, session);
     for (ActiveRuleDto activeRule : this.findByProfileKey(profileKey, session)) {
       this.delete(activeRule, session);
     }
diff --git a/sonar-server/src/main/java/org/sonar/server/search/IndexSynchronizer.java b/sonar-server/src/main/java/org/sonar/server/search/IndexSynchronizer.java
index 63cb4dbf524..a457cbea058 100644
--- a/sonar-server/src/main/java/org/sonar/server/search/IndexSynchronizer.java
+++ b/sonar-server/src/main/java/org/sonar/server/search/IndexSynchronizer.java
@@ -19,12 +19,18 @@
  */
 package org.sonar.server.search;
 
-  import org.sonar.server.db.DbClient;
+import org.picocontainer.Startable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.sonar.core.persistence.DbSession;
+import org.sonar.server.db.DbClient;
 
 /**
  * @since 4.4
  */
-public class IndexSynchronizer {
+public class IndexSynchronizer implements Startable {
+
+  private static final Logger LOG = LoggerFactory.getLogger(IndexSynchronizer.class);
 
   private final DbClient db;
   private final IndexClient index;
@@ -33,4 +39,20 @@ public class IndexSynchronizer {
     this.db = db;
     this.index = index;
   }
+
+  @Override
+  public void start() {
+    /* synchronize all activeRules until we have mng tables in INDEX */
+    DbSession session = db.openSession(true);
+    LOG.info("Starting DB to Index synchronization");
+    long start = System.currentTimeMillis();
+    db.activeRuleDao().synchronizeAfter(0, session);
+    LOG.info("Synchronization done in {}ms...", (System.currentTimeMillis()-start));
+    session.close();
+  }
+
+  @Override
+  public void stop() {
+
+  }
 }
-- 
2.39.5