// Copyright (C) Stichting Deltares 2017. All rights reserved. // // This file is part of Ringtoets. // // Ringtoets is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program 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 General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program. If not, see . // // All names, logos, and references to "Deltares" are registered trademarks of // Stichting Deltares and remain full property of Stichting Deltares at all times. // All rights reserved. using System; using System.Data.SQLite; using Application.Ringtoets.Migration.Core.Properties; using Migration.Scripts.Data; using Migration.Scripts.Data.Exceptions; using Ringtoets.Common.Utils; namespace Application.Ringtoets.Migration.Core { /// /// Class that provides methods for the upgrading a for a specific version. /// public class RingtoetsUpgradeScript : UpgradeScript { private readonly string upgradeQuery; private readonly string logDatabaseLocation; /// /// Creates a new instance of the class. /// /// The source version was designed for. /// The target version was designed for. /// The SQL query to upgrade from to . /// The location to the log database. /// Thrown when: /// /// is not a valid Ringtoets database version, /// is not a valid Ringtoets database version, /// is empty, null, or consists out of only whitespace characters. /// public RingtoetsUpgradeScript(string fromVersion, string toVersion, string query, string logDatabaseLocation) : base(fromVersion, toVersion) { if (string.IsNullOrWhiteSpace(query)) { throw new ArgumentException(@"Query must have a value.", nameof(query)); } RingtoetsVersionHelper.ValidateVersion(fromVersion); RingtoetsVersionHelper.ValidateVersion(toVersion); upgradeQuery = query; this.logDatabaseLocation = logDatabaseLocation; } protected override void PerformUpgrade(string sourceLocation, string targetLocation) { try { string query = string.Format(upgradeQuery, sourceLocation, logDatabaseLocation); using (var databaseFile = new RingtoetsDatabaseFile(targetLocation)) { databaseFile.OpenDatabaseConnection(); databaseFile.ExecuteQuery(query); } } catch (SQLiteException exception) { throw new CriticalMigrationException(string.Format(Resources.RingtoetsUpgradeScript_Upgrading_Version_0_To_Version_1_Failed, FromVersion(), ToVersion()), exception); } } } }