SONAR-1850 delete unvalid snapshots during database upgrade

diff --git a/sonar-core/src/main/java/org/sonar/jpa/entity/SchemaMigration.java b/sonar-core/src/main/java/org/sonar/jpa/entity/SchemaMigration.java
index a79209364817a7376579741d8db44a1a61448ca5..5a6ec38be20be8c8364ba5fd610b61ad3f946e91 100644 (file)
--- a/sonar-core/src/main/java/org/sonar/jpa/entity/SchemaMigration.java
+++ b/sonar-core/src/main/java/org/sonar/jpa/entity/SchemaMigration.java
@@ -30,7 +30,7 @@ import java.sql.Statement;
 public class SchemaMigration {
 
   public final static int VERSION_UNKNOWN = -1;
-  public static final int LAST_VERSION = 151; 
+  public static final int LAST_VERSION = 152; 
 
   public final static String TABLE_NAME = "schema_migrations";
 

diff --git a/sonar-server/src/main/webapp/WEB-INF/db/migrate/152_delete_duplicated_lib_snapshots.rb b/sonar-server/src/main/webapp/WEB-INF/db/migrate/152_delete_duplicated_lib_snapshots.rb
new file mode 100644 (file)
index 0000000..640ab06
--- /dev/null
+++ b/sonar-server/src/main/webapp/WEB-INF/db/migrate/152_delete_duplicated_lib_snapshots.rb
@@ -0,0 +1,54 @@
+#
+# Sonar, entreprise quality control tool.
+# Copyright (C) 2009 SonarSource SA
+# mailto:contact AT sonarsource DOT com
+#
+# Sonar is free software; you can redistribute it and/or
+# modify it under the terms of the GNU Lesser General Public
+# License as published by the Free Software Foundation; either
+# version 3 of the License, or (at your option) any later version.
+#
+# Sonar is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+# Lesser General Public License for more details.
+#
+# You should have received a copy of the GNU Lesser General Public
+# License along with Sonar; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02
+#
+class DeleteDuplicatedLibSnapshots < ActiveRecord::Migration
+  def self.up
+   metric=Metric.find(:first, :conditions => ['name=?','lines'])
+   if metric
+     snapshots=select_snapshots_without_measures(metric)
+     delete_snapshots(snapshots)
+   end
+  end
+
+  def self.select_snapshots_without_measures(metric)
+   snapshots=[]
+   say_with_time "Select project snapshots without measures..." do
+     snapshots=Snapshot.find_by_sql ["SELECT s.id FROM snapshots s WHERE s.scope='PRJ' and s.qualifier IN ('TRK', 'BRC') AND status='P' AND NOT EXISTS (select m.id from project_measures m WHERE m.snapshot_id=s.id AND m.metric_id=?) and not exists(select * from dependencies d where d.to_snapshot_id=s.id)", metric.id]
+   end
+   snapshots
+  end
+
+  def self.filter_involved_in_dependencies(snapshots)
+   result=[]
+   if snapshots.size>0
+     say_with_time "Filter #{snapshots.size} snapshots..." do
+       result=Snapshot.find_by_sql ["SELECT s.id FROM snapshots s where s.id in (?) and not exists(select * from dependencies d where d.to_snapshot_id=s.id", snapshots.map{|s| s.id}]
+     end
+   end
+   return result
+  end
+
+  def self.delete_snapshots(snapshots)
+   if snapshots.size > 0
+     say_with_time "Deleting #{snapshots.size} orphan snapshots..." do
+       Snapshot.delete(snapshots.map{|s| s.id})
+     end
+   end
+  end
+end