]> source.dussan.org Git - sonarqube.git/commitdiff
Refactor org.sonar.server.db.migrations.MassUpdater
authorSimon Brandhof <simon.brandhof@gmail.com>
Thu, 6 Mar 2014 14:18:35 +0000 (15:18 +0100)
committerSimon Brandhof <simon.brandhof@gmail.com>
Thu, 6 Mar 2014 14:18:35 +0000 (15:18 +0100)
32 files changed:
sonar-server/src/main/java/org/sonar/server/db/migrations/MassUpdater.java [new file with mode: 0644]
sonar-server/src/main/java/org/sonar/server/db/migrations/SqlUtil.java [new file with mode: 0644]
sonar-server/src/main/java/org/sonar/server/db/migrations/debt/DevelopmentCostMeasuresMigration.java
sonar-server/src/main/java/org/sonar/server/db/migrations/debt/IssueChangelogMigration.java
sonar-server/src/main/java/org/sonar/server/db/migrations/debt/IssueMigration.java
sonar-server/src/main/java/org/sonar/server/db/migrations/debt/MassUpdater.java [deleted file]
sonar-server/src/main/java/org/sonar/server/db/migrations/debt/TechnicalDebtMeasuresMigration.java
sonar-server/src/main/java/org/sonar/server/db/migrations/util/SqlUtil.java [deleted file]
sonar-server/src/main/java/org/sonar/server/db/migrations/violation/ViolationConverter.java
sonar-server/src/main/java/org/sonar/server/db/migrations/violation/ViolationMigration.java
sonar-server/src/main/webapp/WEB-INF/db/migrate/486_add_resource_path_column.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/488_add_project_deprecated_key_column.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/489_add_rule_tags.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/490_migrate_package_resources.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/492_remove_rule_notes_and_active_rule_notes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/493_delete_display_treemap_from_measure_filters.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/494_delete_properties_on_unknown_components.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/495_migrate_base_id_to_base_from_measure_filters.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/496_delete_language_property.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/497_update_issue_message_by_rule_name_when_no_message.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/498_remove_duplicate_active_rules.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/510_create_quality_gates.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/511_create_quality_gate_conditions.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/513_update_issue_debt_to_minutes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/514_update_issue_changelog_debt_to_minutes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/515_update_measures_debt_to_minutes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/516_update_development_cost_to_minutes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/517_update_work_units_by_size_point_property_to_minutes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/518_update_alerts_on_debt_to_minutes.rb
sonar-server/src/main/webapp/WEB-INF/db/migrate/519_update_measure_filters_on_debt_to_minutes.rb
sonar-server/src/test/java/org/sonar/server/db/migrations/SqlUtilTest.java [new file with mode: 0644]
sonar-server/src/test/java/org/sonar/server/db/migrations/util/SqlUtilTest.java [deleted file]

diff --git a/sonar-server/src/main/java/org/sonar/server/db/migrations/MassUpdater.java b/sonar-server/src/main/java/org/sonar/server/db/migrations/MassUpdater.java
new file mode 100644 (file)
index 0000000..6c244d2
--- /dev/null
@@ -0,0 +1,115 @@
+/*
+ * SonarQube, open source software quality management tool.
+ * Copyright (C) 2008-2013 SonarSource
+ * mailto:contact AT sonarsource DOT com
+ *
+ * SonarQube 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.
+ *
+ * SonarQube 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 this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ */
+
+package org.sonar.server.db.migrations;
+
+import org.apache.commons.dbutils.DbUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.sonar.api.utils.MessageException;
+import org.sonar.core.persistence.Database;
+import org.sonar.core.persistence.dialect.MySql;
+
+import java.sql.*;
+
+/**
+ * Update a table by iterating a sub-set of rows. For each row a SQL UPDATE request
+ * is executed.
+ */
+public class MassUpdater {
+
+  private static final Logger LOGGER = LoggerFactory.getLogger(MassUpdater.class);
+  private static final String FAILURE_MESSAGE = "Fail to migrate data";
+  private static final int GROUP_SIZE = 1000;
+  private final Database db;
+
+  public MassUpdater(Database db) {
+    this.db = db;
+  }
+
+  public static interface InputLoader<S> {
+    String selectSql();
+
+    S load(ResultSet rs) throws SQLException;
+  }
+
+  public static interface InputConverter<S> {
+    String updateSql();
+
+    void convert(S input, PreparedStatement updateStatement) throws SQLException;
+  }
+
+  public <S> void execute(InputLoader<S> inputLoader, InputConverter<S> converter) {
+    long count = 0;
+    try {
+      Connection readConnection = db.getDataSource().getConnection();
+      Statement stmt = null;
+      ResultSet rs = null;
+      Connection writeConnection = db.getDataSource().getConnection();
+      PreparedStatement writeStatement = null;
+      try {
+        readConnection.setAutoCommit(false);
+        writeConnection.setAutoCommit(false);
+        writeStatement = writeConnection.prepareStatement(converter.updateSql());
+        stmt = readConnection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
+        stmt.setFetchSize(GROUP_SIZE);
+        if (db.getDialect().getId().equals(MySql.ID)) {
+          stmt.setFetchSize(Integer.MIN_VALUE);
+        } else {
+          stmt.setFetchSize(GROUP_SIZE);
+        }
+        rs = stmt.executeQuery(inputLoader.selectSql());
+
+        int cursor = 0;
+        while (rs.next()) {
+          converter.convert(inputLoader.load(rs), writeStatement);
+          writeStatement.addBatch();
+
+          cursor++;
+          count++;
+          if (cursor == GROUP_SIZE) {
+            writeStatement.executeBatch();
+            writeConnection.commit();
+            cursor = 0;
+          }
+        }
+        if (cursor > 0) {
+          writeStatement.executeBatch();
+          writeConnection.commit();
+        }
+      } finally {
+        DbUtils.closeQuietly(writeStatement);
+        DbUtils.closeQuietly(writeConnection);
+        DbUtils.closeQuietly(readConnection, stmt, rs);
+
+        LOGGER.info("{} rows have been updated", count);
+      }
+    } catch (SQLException e) {
+      LOGGER.error(FAILURE_MESSAGE, e);
+      SqlUtil.log(LOGGER, e);
+      throw MessageException.of(FAILURE_MESSAGE);
+
+    } catch (Exception e) {
+      LOGGER.error(FAILURE_MESSAGE, e);
+      throw MessageException.of(FAILURE_MESSAGE);
+    }
+  }
+
+}
diff --git a/sonar-server/src/main/java/org/sonar/server/db/migrations/SqlUtil.java b/sonar-server/src/main/java/org/sonar/server/db/migrations/SqlUtil.java
new file mode 100644 (file)
index 0000000..5bdba07
--- /dev/null
@@ -0,0 +1,81 @@
+/*
+ * SonarQube, open source software quality management tool.
+ * Copyright (C) 2008-2013 SonarSource
+ * mailto:contact AT sonarsource DOT com
+ *
+ * SonarQube 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.
+ *
+ * SonarQube 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 this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ */
+package org.sonar.server.db.migrations;
+
+import org.slf4j.Logger;
+
+import javax.annotation.CheckForNull;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class SqlUtil {
+
+  private SqlUtil() {
+    // only static methods
+  }
+
+  /**
+   * Logback does not log exceptions associated to {@link java.sql.SQLException#getNextException()}.
+   * See http://jira.qos.ch/browse/LOGBACK-775
+   */
+  public static void log(Logger logger, SQLException e) {
+    SQLException next = e.getNextException();
+    while (next != null) {
+      logger.error("SQL error: {}. Message: {}", next.getSQLState(), next.getMessage());
+      next = next.getNextException();
+    }
+  }
+
+  @CheckForNull
+  public static Long getLong(ResultSet rs, int columnIndex) throws SQLException {
+    long l = rs.getLong(columnIndex);
+    return rs.wasNull() ? null : l;
+  }
+
+  @CheckForNull
+  public static Double getDouble(ResultSet rs, int columnIndex) throws SQLException {
+    double d = rs.getDouble(columnIndex);
+    return rs.wasNull() ? null : d;
+  }
+
+  @CheckForNull
+  public static Integer getInt(ResultSet rs, int columnIndex) throws SQLException {
+    int i = rs.getInt(columnIndex);
+    return rs.wasNull() ? null : i;
+  }
+
+  @CheckForNull
+  public static Long getLong(ResultSet rs, String columnName) throws SQLException {
+    long l = rs.getLong(columnName);
+    return rs.wasNull() ? null : l;
+  }
+
+  @CheckForNull
+  public static Double getDouble(ResultSet rs, String columnName) throws SQLException {
+    double d = rs.getDouble(columnName);
+    return rs.wasNull() ? null : d;
+  }
+
+  @CheckForNull
+  public static Integer getInt(ResultSet rs, String columnName) throws SQLException {
+    int i = rs.getInt(columnName);
+    return rs.wasNull() ? null : i;
+  }
+}
index 1fb759bbfaadd2c3886a1d5f548527c30e2fa613..717e3b660175596eeca9d21b21bb4bd38cfd09c0 100644 (file)
@@ -23,28 +23,20 @@ package org.sonar.server.db.migrations.debt;
 import org.sonar.api.config.Settings;
 import org.sonar.core.persistence.Database;
 import org.sonar.server.db.migrations.DatabaseMigration;
-import org.sonar.server.db.migrations.util.SqlUtil;
+import org.sonar.server.db.migrations.MassUpdater;
+import org.sonar.server.db.migrations.SqlUtil;
 
 import javax.annotation.CheckForNull;
-
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
 /**
  * Used in the Active Record Migration 516
+ * @since 4.3
  */
 public class DevelopmentCostMeasuresMigration implements DatabaseMigration {
 
-  private static final String ID = "id";
-  private static final String VALUE = "value";
-
-  private static final String SELECT_SQL = "SELECT pm.id AS " + ID + ", pm.value AS " + VALUE +
-    " FROM project_measures pm INNER JOIN metrics m on m.id=pm.metric_id " +
-    " WHERE m.name='development_cost' AND pm.value IS NOT NULL";
-
-  private static final String UPDATE_SQL = "UPDATE project_measures SET value=NULL,text_value=? WHERE id=?";
-
   private final WorkDurationConvertor workDurationConvertor;
   private final Database db;
 
@@ -59,27 +51,29 @@ public class DevelopmentCostMeasuresMigration implements DatabaseMigration {
       new MassUpdater.InputLoader<Row>() {
         @Override
         public String selectSql() {
-          return SELECT_SQL;
+          return "SELECT pm.id, pm.value " +
+            " FROM project_measures pm INNER JOIN metrics m on m.id=pm.metric_id " +
+            " WHERE m.name='development_cost' AND pm.value IS NOT NULL";
         }
 
         @Override
         public Row load(ResultSet rs) throws SQLException {
           Row row = new Row();
-          row.id = SqlUtil.getLong(rs, ID);
-          row.value = SqlUtil.getDouble(rs, VALUE);
+          row.id = SqlUtil.getLong(rs, 1);
+          row.value = SqlUtil.getDouble(rs, 2);
           return row;
         }
       },
       new MassUpdater.InputConverter<Row>() {
         @Override
         public String updateSql() {
-          return UPDATE_SQL;
+          return "UPDATE project_measures SET value=NULL,text_value=? WHERE id=?";
         }
 
         @Override
-        public void convert(Row row, PreparedStatement statement) throws SQLException {
-          statement.setString(1, convertDebtForDays(row.value));
-          statement.setLong(2, row.id);
+        public void convert(Row row, PreparedStatement updateStatement) throws SQLException {
+          updateStatement.setString(1, convertDebtForDays(row.value));
+          updateStatement.setLong(2, row.id);
         }
       }
     );
index 4b0d487cdd891c3cece0d8cb3cdce7cf6f9c75a1..720d6113f7fc974fe7a1454eb3a40f87676c231e 100644 (file)
@@ -26,7 +26,8 @@ import org.sonar.api.config.Settings;
 import org.sonar.api.utils.System2;
 import org.sonar.core.persistence.Database;
 import org.sonar.server.db.migrations.DatabaseMigration;
-import org.sonar.server.db.migrations.util.SqlUtil;
+import org.sonar.server.db.migrations.MassUpdater;
+import org.sonar.server.db.migrations.SqlUtil;
 
 import java.sql.Date;
 import java.sql.PreparedStatement;
@@ -37,18 +38,10 @@ import java.util.regex.Pattern;
 
 /**
  * Used in the Active Record Migration 514
+ * @since 4.3
  */
 public class IssueChangelogMigration implements DatabaseMigration {
 
-  private static final String ID = "id";
-  private static final String CHANGE_DATA = "changeData";
-
-  private static final String SELECT_SQL = "SELECT ic.id AS " + ID + ", ic.change_data AS " + CHANGE_DATA +
-    " FROM issue_changes ic " +
-    " WHERE ic.change_type = 'diff' AND ic.change_data LIKE '%technicalDebt%'";
-
-  private static final String UPDATE_SQL = "UPDATE issue_changes SET change_data=?,updated_at=? WHERE id=?";
-
   private final WorkDurationConvertor workDurationConvertor;
   private final System2 system2;
   private final Database db;
@@ -70,28 +63,29 @@ public class IssueChangelogMigration implements DatabaseMigration {
       new MassUpdater.InputLoader<Row>() {
         @Override
         public String selectSql() {
-          return SELECT_SQL;
+          return "SELECT ic.id, ic.change_data  FROM issue_changes ic " +
+            " WHERE ic.change_type = 'diff' AND ic.change_data LIKE '%technicalDebt%'";
         }
 
         @Override
         public Row load(ResultSet rs) throws SQLException {
           Row row = new Row();
-          row.id = SqlUtil.getLong(rs, ID);
-          row.changeData = rs.getString(CHANGE_DATA);
+          row.id = SqlUtil.getLong(rs, 1);
+          row.changeData = rs.getString(2);
           return row;
         }
       },
       new MassUpdater.InputConverter<Row>() {
         @Override
         public String updateSql() {
-          return UPDATE_SQL;
+          return "UPDATE issue_changes SET change_data=?,updated_at=? WHERE id=?";
         }
 
         @Override
-        public void convert(Row row, PreparedStatement statement) throws SQLException {
-          statement.setString(1, convertChangelog(row.changeData));
-          statement.setDate(2, new Date(system2.now()));
-          statement.setLong(3, row.id);
+        public void convert(Row row, PreparedStatement updateStatement) throws SQLException {
+          updateStatement.setString(1, convertChangelog(row.changeData));
+          updateStatement.setDate(2, new Date(system2.now()));
+          updateStatement.setLong(3, row.id);
         }
       }
     );
index f9b4fa40f8ce9d6bc448a51120b07698bbe8f27f..c8f379b55c6b3033bef880ffc412011dd629432c 100644 (file)
@@ -25,7 +25,8 @@ import org.sonar.api.config.Settings;
 import org.sonar.api.utils.System2;
 import org.sonar.core.persistence.Database;
 import org.sonar.server.db.migrations.DatabaseMigration;
-import org.sonar.server.db.migrations.util.SqlUtil;
+import org.sonar.server.db.migrations.MassUpdater;
+import org.sonar.server.db.migrations.SqlUtil;
 
 import java.sql.Date;
 import java.sql.PreparedStatement;
@@ -34,16 +35,10 @@ import java.sql.SQLException;
 
 /**
  * Used in the Active Record Migration 513
+ * @since 4.3
  */
 public class IssueMigration implements DatabaseMigration {
 
-  private static final String ID = "id";
-  private static final String DEBT = "debt";
-
-  private static final String SELECT_SQL = "SELECT i.id AS " + ID + ", i.technical_debt AS " + DEBT +
-    " FROM issues i WHERE i.technical_debt IS NOT NULL";
-  private static final String UPDATE_SQL = "UPDATE issues SET technical_debt=?,updated_at=? WHERE id=?";
-
   private final WorkDurationConvertor workDurationConvertor;
   private final System2 system2;
   private final Database db;
@@ -65,28 +60,28 @@ public class IssueMigration implements DatabaseMigration {
       new MassUpdater.InputLoader<Row>() {
         @Override
         public String selectSql() {
-          return SELECT_SQL;
+          return "SELECT i.id, i.technical_debt FROM issues i WHERE i.technical_debt IS NOT NULL";
         }
 
         @Override
         public Row load(ResultSet rs) throws SQLException {
           Row row = new Row();
-          row.id = SqlUtil.getLong(rs, ID);
-          row.debt = SqlUtil.getLong(rs, DEBT);
+          row.id = SqlUtil.getLong(rs, 1);
+          row.debt = SqlUtil.getLong(rs, 2);
           return row;
         }
       },
       new MassUpdater.InputConverter<Row>() {
         @Override
         public String updateSql() {
-          return UPDATE_SQL;
+          return "UPDATE issues SET technical_debt=?,updated_at=? WHERE id=?";
         }
 
         @Override
-        public void convert(Row row, PreparedStatement statement) throws SQLException {
-          statement.setLong(1, workDurationConvertor.createFromLong(row.debt));
-          statement.setDate(2, new Date(system2.now()));
-          statement.setLong(3, row.id);
+        public void convert(Row row, PreparedStatement updateStatement) throws SQLException {
+          updateStatement.setLong(1, workDurationConvertor.createFromLong(row.debt));
+          updateStatement.setDate(2, new Date(system2.now()));
+          updateStatement.setLong(3, row.id);
         }
       }
     );
diff --git a/sonar-server/src/main/java/org/sonar/server/db/migrations/debt/MassUpdater.java b/sonar-server/src/main/java/org/sonar/server/db/migrations/debt/MassUpdater.java
deleted file mode 100644 (file)
index 0852ed8..0000000
+++ /dev/null
@@ -1,120 +0,0 @@
-/*
- * SonarQube, open source software quality management tool.
- * Copyright (C) 2008-2013 SonarSource
- * mailto:contact AT sonarsource DOT com
- *
- * SonarQube 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.
- *
- * SonarQube 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 this program; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
- */
-
-package org.sonar.server.db.migrations.debt;
-
-import org.apache.commons.dbutils.DbUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.sonar.api.utils.MessageException;
-import org.sonar.core.persistence.Database;
-import org.sonar.core.persistence.dialect.MySql;
-import org.sonar.server.db.migrations.util.SqlUtil;
-
-import java.sql.*;
-
-public class MassUpdater {
-
-  private static final Logger LOGGER = LoggerFactory.getLogger(MassUpdater.class);
-
-  static final int GROUP_SIZE = 1000;
-
-  private static final String FAILURE_MESSAGE = "Fail to migrate data";
-
-  private final Database db;
-
-  public MassUpdater(Database db) {
-    this.db = db;
-  }
-
-  interface InputLoader<S> {
-    String selectSql();
-
-    S load(ResultSet rs) throws SQLException;
-  }
-
-  interface InputConverter<S> {
-    String updateSql();
-
-    void convert(S input, PreparedStatement statement) throws SQLException;
-  }
-
-  public <S> void execute(InputLoader<S> inputLoader, InputConverter<S> converter) {
-    long count = 0;
-    try {
-      Connection readConnection = db.getDataSource().getConnection();
-      Statement stmt = null;
-      ResultSet rs = null;
-
-      Connection writeConnection = db.getDataSource().getConnection();
-      PreparedStatement writeStatement = null;
-      try {
-        writeConnection.setAutoCommit(false);
-        writeStatement = writeConnection.prepareStatement(converter.updateSql());
-
-        readConnection.setAutoCommit(false);
-
-        stmt = readConnection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
-        stmt.setFetchSize(GROUP_SIZE);
-        if (db.getDialect().getId().equals(MySql.ID)) {
-          stmt.setFetchSize(Integer.MIN_VALUE);
-        } else {
-          stmt.setFetchSize(GROUP_SIZE);
-        }
-        rs = stmt.executeQuery(inputLoader.selectSql());
-
-        int cursor = 0;
-        while (rs.next()) {
-          converter.convert(inputLoader.load(rs), writeStatement);
-          writeStatement.addBatch();
-
-          cursor++;
-          count++;
-          if (cursor == GROUP_SIZE) {
-            writeStatement.executeBatch();
-            writeConnection.commit();
-            cursor = 0;
-          }
-        }
-        if (cursor > 0) {
-          writeStatement.executeBatch();
-          writeConnection.commit();
-        }
-      } finally {
-        if (writeStatement != null) {
-          writeStatement.close();
-        }
-        DbUtils.closeQuietly(writeConnection);
-        DbUtils.closeQuietly(readConnection, stmt, rs);
-
-        LOGGER.info("{} rows have been updated", count);
-      }
-    } catch (SQLException e) {
-      LOGGER.error(FAILURE_MESSAGE, e);
-      SqlUtil.log(LOGGER, e);
-      throw MessageException.of(FAILURE_MESSAGE);
-
-    } catch (Exception e) {
-      LOGGER.error(FAILURE_MESSAGE, e);
-      throw MessageException.of(FAILURE_MESSAGE);
-    }
-  }
-
-}
index bebc3f9b0a8a8dbe478629c443bc44484fdb8f38..b1772092e168127fd59f1f7786f04270ab25fd1c 100644 (file)
@@ -23,7 +23,8 @@ package org.sonar.server.db.migrations.debt;
 import org.sonar.api.config.Settings;
 import org.sonar.core.persistence.Database;
 import org.sonar.server.db.migrations.DatabaseMigration;
-import org.sonar.server.db.migrations.util.SqlUtil;
+import org.sonar.server.db.migrations.MassUpdater;
+import org.sonar.server.db.migrations.SqlUtil;
 
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
@@ -32,20 +33,13 @@ import java.sql.Types;
 
 /**
  * Used in the Active Record Migration 515
+ * @since 4.3
  */
 public class TechnicalDebtMeasuresMigration implements DatabaseMigration {
 
-  private static final String ID = "id";
-  private static final String VALUE = "value";
-  private static final String VAR1 = "var1";
-  private static final String VAR2 = "var2";
-  private static final String VAR3 = "var3";
-  private static final String VAR4 = "var4";
-  private static final String VAR5 = "var5";
-
-  private static final String SELECT_SQL = "SELECT pm.id AS " + ID + ", pm.value AS " + VALUE +
-    ", pm.variation_value_1 AS " + VAR1 + ", pm.variation_value_2 AS " + VAR2 + ", pm.variation_value_3 AS " + VAR3 +
-    ", pm.variation_value_4 AS " + VAR4 + ", pm.variation_value_5 AS " + VAR5 +
+  private static final String SELECT_SQL = "SELECT pm.id, pm.value " +
+    ", pm.variation_value_1 , pm.variation_value_2, pm.variation_value_3 " +
+    ", pm.variation_value_4 , pm.variation_value_5 " +
     " FROM project_measures pm INNER JOIN metrics m on m.id=pm.metric_id " +
     " WHERE (m.name='sqale_index' or m.name='new_technical_debt' " +
     // SQALE measures
@@ -77,13 +71,13 @@ public class TechnicalDebtMeasuresMigration implements DatabaseMigration {
         @Override
         public Row load(ResultSet rs) throws SQLException {
           Row row = new Row();
-          row.id = SqlUtil.getLong(rs, ID);
-          row.value = SqlUtil.getDouble(rs, VALUE);
-          row.var1 = SqlUtil.getDouble(rs, VAR1);
-          row.var2 = SqlUtil.getDouble(rs, VAR2);
-          row.var3 = SqlUtil.getDouble(rs, VAR3);
-          row.var4 = SqlUtil.getDouble(rs, VAR4);
-          row.var5 = SqlUtil.getDouble(rs, VAR5);
+          row.id = SqlUtil.getLong(rs, 1);
+          row.value = SqlUtil.getDouble(rs, 2);
+          row.var1 = SqlUtil.getDouble(rs, 3);
+          row.var2 = SqlUtil.getDouble(rs, 4);
+          row.var3 = SqlUtil.getDouble(rs, 5);
+          row.var4 = SqlUtil.getDouble(rs, 6);
+          row.var5 = SqlUtil.getDouble(rs, 7);
           return row;
         }
       },
@@ -94,14 +88,14 @@ public class TechnicalDebtMeasuresMigration implements DatabaseMigration {
         }
 
         @Override
-        public void convert(Row row, PreparedStatement statement) throws SQLException {
-          setDouble(statement, 1, row.value);
-          setDouble(statement, 2, row.var1);
-          setDouble(statement, 3, row.var2);
-          setDouble(statement, 4, row.var3);
-          setDouble(statement, 5, row.var4);
-          setDouble(statement, 6, row.var5);
-          statement.setLong(7, row.id);
+        public void convert(Row row, PreparedStatement updateStatement) throws SQLException {
+          setDouble(updateStatement, 1, row.value);
+          setDouble(updateStatement, 2, row.var1);
+          setDouble(updateStatement, 3, row.var2);
+          setDouble(updateStatement, 4, row.var3);
+          setDouble(updateStatement, 5, row.var4);
+          setDouble(updateStatement, 6, row.var5);
+          updateStatement.setLong(7, row.id);
         }
       }
     );
diff --git a/sonar-server/src/main/java/org/sonar/server/db/migrations/util/SqlUtil.java b/sonar-server/src/main/java/org/sonar/server/db/migrations/util/SqlUtil.java
deleted file mode 100644 (file)
index 2229a41..0000000
+++ /dev/null
@@ -1,63 +0,0 @@
-/*
- * SonarQube, open source software quality management tool.
- * Copyright (C) 2008-2013 SonarSource
- * mailto:contact AT sonarsource DOT com
- *
- * SonarQube 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.
- *
- * SonarQube 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 this program; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
- */
-package org.sonar.server.db.migrations.util;
-
-import org.slf4j.Logger;
-
-import javax.annotation.CheckForNull;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-
-public class SqlUtil {
-
-  private SqlUtil() {
-    // only static methods
-  }
-
-  /**
-   * Logback does not log exceptions associated to {@link java.sql.SQLException#getNextException()}.
-   * See http://jira.qos.ch/browse/LOGBACK-775
-   */
-  public static void log(Logger logger, SQLException e) {
-    SQLException next = e.getNextException();
-    while (next != null) {
-      logger.error("SQL error: {}. Message: {}", next.getSQLState(), next.getMessage());
-      next = next.getNextException();
-    }
-  }
-
-  @CheckForNull
-  public static Long getLong(ResultSet rs, String columnName) throws SQLException {
-    long l = rs.getLong(columnName);
-    return rs.wasNull() ? null : l;
-  }
-
-  @CheckForNull
-  public static Double getDouble(ResultSet rs, String columnName) throws SQLException {
-    double d = rs.getDouble(columnName);
-    return rs.wasNull() ? null : d;
-  }
-
-  @CheckForNull
-  public static Integer getInt(ResultSet rs, String columnName) throws SQLException {
-    int i = rs.getInt(columnName);
-    return rs.wasNull() ? null : i;
-  }
-}
index e23bdcced8723f87c57bad819a2d4d7e0256edb8..1cc1496a8c05462f641a507d023df443c1547981 100644 (file)
@@ -28,7 +28,7 @@ import org.apache.commons.dbutils.QueryRunner;
 import org.apache.commons.dbutils.handlers.AbstractListHandler;
 import org.sonar.api.rule.Severity;
 import org.sonar.core.persistence.Database;
-import org.sonar.server.db.migrations.util.SqlUtil;
+import org.sonar.server.db.migrations.SqlUtil;
 
 import java.sql.Connection;
 import java.sql.Date;
index b35dd88484cd28c18560f82354a9f9e4b15c636d..d534b0169b1a20638c5a2bb1c50ec7fe8670c6dd 100644 (file)
@@ -25,7 +25,7 @@ import org.sonar.api.config.Settings;
 import org.sonar.api.utils.MessageException;
 import org.sonar.core.persistence.Database;
 import org.sonar.server.db.migrations.DatabaseMigration;
-import org.sonar.server.db.migrations.util.SqlUtil;
+import org.sonar.server.db.migrations.SqlUtil;
 
 import java.sql.SQLException;
 
index 6ae9514930e1cb077f0dc1d977e04c533f7b05a0..96913af5a11d7e2dcebd3b5bfa2f960a793f2df2 100644 (file)
@@ -25,6 +25,6 @@
 class AddResourcePathColumn < ActiveRecord::Migration
 
   def self.up
-      add_column 'projects', :path, :string, :null => true, :limit => 2000
+    add_column 'projects', :path, :string, :null => true, :limit => 2000
   end
 end
index 9d22d40d9b9d1f5b18d762524f0a8edc10f14f23..1fb5f53f72315e507580835396d24d3a4689b2e3 100644 (file)
@@ -25,6 +25,6 @@
 class AddProjectDeprecatedKeyColumn < ActiveRecord::Migration
 
   def self.up
-      add_column 'projects', 'deprecated_kee', :string, :null => true, :limit => 400
+    add_column 'projects', 'deprecated_kee', :string, :null => true, :limit => 400
   end
 end
index 83098a0b3d159d955beff7ea2d0313923ebe2785..368b9ae1243a81747fbc62c6132e1b3bcb5979f6 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 #
 class AddRuleTags < ActiveRecord::Migration
 
@@ -32,11 +32,7 @@ class AddRuleTags < ActiveRecord::Migration
       t.column :rule_tag_id,        :integer,     :null => false
       t.column :tag_type,           :string,      :null => true,    :limit => 20
     end
-    begin
-      add_index 'rules_rule_tags', ['rule_id', 'rule_tag_id'], :unique => true, :name => 'uniq_rule_tags'
-    rescue
-      # ignore
-    end
+    add_index 'rules_rule_tags', ['rule_id', 'rule_tag_id'], :unique => true, :name => 'uniq_rule_tags'
   end
 
 end
index 4e217a595741be14cf7dd3f888c194d3cea7c50c..9acb81749bf27771140f37bb509db93d189098dd 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-926
 #
 class MigratePackageResources < ActiveRecord::Migration
index f3e4c8494e8666730d7c14b80ccb5d25edc90c3f..4a6e95dc9f8099aebdd8f248a6dd826898878d27 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-4923
 #
 class RemoveRuleNotesAndActiveRuleNotes < ActiveRecord::Migration
index a1beba69a7ec467120ec2aaf1d6748b3d41480cb..2af2d50595a0417490c2483d8cc90284f13e0dc9 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-4997
 #
 class DeleteDisplayTreemapFromMeasureFilters < ActiveRecord::Migration
index b43db8d3290c7c1d5732c89ddc5b5010905fb4b1..a83d18a7995a6609ce853bc71c9a333615ee8422 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-5013
 #
 class DeletePropertiesOnUnknownComponents < ActiveRecord::Migration
index 8df6d80e63cf689de3ee7355f7eaddf2a605929f..da18e7a46629cff54aa558977437608a4517029b 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-4921
 #
 class MigrateBaseIdToBaseFromMeasureFilters < ActiveRecord::Migration
index 11c858cb84999da33ecdb3b39fd8f09bbe9b94c3..6b3386afdee402a1dc1b6f31881459cb721e0aba 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-926
 # The property sonar.language must not be set in global settings
 #
index ceaa5c60c82ade9a6b405a517e67ce13c132f51c..bd78e4df76c94de728643a0526cb9c586d09528b 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.2
+# SonarQube 4.2
 # SONAR-5067
 #
 class RemoveDuplicateActiveRules < ActiveRecord::Migration
index 14083cf71a126706568790d48adee198c614a0ea..f6d48aad6939eb6c90634ea4b492827328f7c0b0 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 #
 class CreateQualityGates < ActiveRecord::Migration
 
index cdf967166a9ac6c4e34ba36b714cb2ec672b1a80..9dcefe4fb18e3a803330cf3395c02e37c2018dc0 100644 (file)
 # along with this program; if not, write to the Free Software Foundation,
 # Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 #
+
+#
+# SonarQube 4.3
+#
 class CreateQualityGateConditions < ActiveRecord::Migration
 
   def self.up
index 7984fae85a681661e08907667de69ad23bf73046..8c2bc9aab70188b931b8acf30ab2921295fb03af 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 # SONAR-4996
 #
 class UpdateIssueDebtToMinutes < ActiveRecord::Migration
index a974294ec6900363d350260d267ae494e04f3a73..6ca54b8adde3f5a49352ea6d26694bd776e9c6cc 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 # SONAR-4996
 #
 class UpdateIssueChangelogDebtToMinutes < ActiveRecord::Migration
index 9c4423a7d2d5c4c1b199fd928192ff37ebd668d4..e3edd5ec3f4f21addd5359a0148c89def6bac055 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 # SONAR-4996
 #
 class UpdateMeasuresDebtToMinutes < ActiveRecord::Migration
index 8c2ba6a2a08ee7faabc7972c3549f3326c047319..1997feda9829787aaec11f204a09a6e60492d2c4 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 # SONAR-4996
 #
 class UpdateDevelopmentCostToMinutes < ActiveRecord::Migration
index 6b7817f7f66b0bbec59a30ec7a0de522271ba546..f2ce51756840d3b482abbbd58857d605c5305c1d 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 # SONAR-4996
 #
 class UpdateAlertsOnDebtToMinutes < ActiveRecord::Migration
index 0668cce61187229d39a9747c0b7357537a67aa2a..68ecc84a3118eff1d69c309d2b27323bcc5b26bd 100644 (file)
@@ -19,7 +19,7 @@
 #
 
 #
-# Sonar 4.3
+# SonarQube 4.3
 # SONAR-4996
 #
 class UpdateMeasureFiltersOnDebtToMinutes < ActiveRecord::Migration
diff --git a/sonar-server/src/test/java/org/sonar/server/db/migrations/SqlUtilTest.java b/sonar-server/src/test/java/org/sonar/server/db/migrations/SqlUtilTest.java
new file mode 100644 (file)
index 0000000..e84cc33
--- /dev/null
@@ -0,0 +1,44 @@
+/*
+ * SonarQube, open source software quality management tool.
+ * Copyright (C) 2008-2013 SonarSource
+ * mailto:contact AT sonarsource DOT com
+ *
+ * SonarQube 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.
+ *
+ * SonarQube 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 this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ */
+package org.sonar.server.db.migrations;
+
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.sonar.server.db.migrations.SqlUtil;
+
+import java.sql.SQLException;
+
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+
+public class SqlUtilTest {
+
+  @Test
+  public void log_all_sql_exceptions() {
+    SQLException root = new SQLException("this is root", "123");
+    SQLException next = new SQLException("this is next", "456");
+    root.setNextException(next);
+
+    Logger logger = mock(Logger.class);
+    SqlUtil.log(logger, root);
+
+    verify(logger).error("SQL error: {}. Message: {}", "456", "this is next");
+  }
+}
diff --git a/sonar-server/src/test/java/org/sonar/server/db/migrations/util/SqlUtilTest.java b/sonar-server/src/test/java/org/sonar/server/db/migrations/util/SqlUtilTest.java
deleted file mode 100644 (file)
index 944da4e..0000000
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * SonarQube, open source software quality management tool.
- * Copyright (C) 2008-2013 SonarSource
- * mailto:contact AT sonarsource DOT com
- *
- * SonarQube 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.
- *
- * SonarQube 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 this program; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
- */
-package org.sonar.server.db.migrations.util;
-
-import org.junit.Test;
-import org.slf4j.Logger;
-
-import java.sql.SQLException;
-
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
-
-public class SqlUtilTest {
-
-  @Test
-  public void log_all_sql_exceptions() {
-    SQLException root = new SQLException("this is root", "123");
-    SQLException next = new SQLException("this is next", "456");
-    root.setNextException(next);
-
-    Logger logger = mock(Logger.class);
-    SqlUtil.log(logger, root);
-
-    verify(logger).error("SQL error: {}. Message: {}", "456", "this is next");
-  }
-}