From 504ab4477dc21e2fb3ef319d45eeb5e69a6e7227 Mon Sep 17 00:00:00 2001
From: Sean Dague
Date: Mon, 9 Jun 2008 21:40:16 +0000
Subject: move Migration support into OpenSim.Data, because it really turned
out to be small enough to not need it's own assembly
---
OpenSim/Data/Migration.cs | 198 +++++++++++++++++++++++++++++++++++
OpenSim/Data/Migrations/Migration.cs | 198 -----------------------------------
2 files changed, 198 insertions(+), 198 deletions(-)
create mode 100644 OpenSim/Data/Migration.cs
delete mode 100644 OpenSim/Data/Migrations/Migration.cs
(limited to 'OpenSim')
diff --git a/OpenSim/Data/Migration.cs b/OpenSim/Data/Migration.cs
new file mode 100644
index 0000000..8487db8
--- /dev/null
+++ b/OpenSim/Data/Migration.cs
@@ -0,0 +1,198 @@
+/*
+ * Copyright (c) Contributors, http://opensimulator.org/
+ * See CONTRIBUTORS.TXT for a full list of copyright holders.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ * * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * * Neither the name of the OpenSim Project nor the
+ * names of its contributors may be used to endorse or promote products
+ * derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.Common;
+using System.IO;
+using System.Reflection;
+using System.Text.RegularExpressions;
+using log4net;
+
+namespace OpenSim.Data
+{
+ ///
+ ///
+ /// The Migration theory is based on the ruby on rails concept.
+ /// Each database driver is going to be allowed to have files in
+ /// Resources that specify the database migrations. They will be
+ /// of the form:
+ ///
+ /// 001_Users.sql
+ /// 002_Users.sql
+ /// 003_Users.sql
+ /// 001_Prims.sql
+ /// 002_Prims.sql
+ /// ...etc...
+ ///
+ /// When a database driver starts up, it specifies a resource that
+ /// needs to be brought up to the current revision. For instance:
+ ///
+ /// Migration um = new Migration(DbConnection, "Users");
+ /// um.Upgrade();
+ ///
+ /// This works out which version Users is at, and applies all the
+ /// revisions past it to it. If there is no users table, all
+ /// revisions are applied in order. Consider each future
+ /// migration to be an incremental roll forward of the tables in
+ /// question.
+ ///
+ ///
+
+ public class Migration
+ {
+ private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
+
+ private string _type;
+ private DbConnection _conn;
+ private string _subtype;
+ private Assembly _assem;
+
+ private static readonly string _migrations_create = "create table migrations(name varchar(100), version int)";
+ private static readonly string _migrations_init = "insert into migrations values('migrations', 1)";
+ private static readonly string _migrations_find = "select version from migrations where name='migrations'";
+
+ public Migration(DbConnection conn, Assembly assem, string type)
+ {
+ _type = type;
+ _conn = conn;
+ _assem = assem;
+ }
+
+ private void Initialize()
+ {
+ // clever, eh, we figure out which migrations version we are
+ int migration_version = FindVersion("migrations");
+
+ if (migration_version > 0)
+ return;
+
+ // If not, create the migration tables
+ DbCommand cmd = _conn.CreateCommand();
+ cmd.CommandText = _migrations_create;
+ cmd.ExecuteNonQuery();
+
+ UpdateVersion("migrations", 1);
+ }
+
+ public void Update()
+ {
+ int version = 0;
+ version = FindVersion(_type);
+
+ List migrations = GetMigrationsAfter(version);
+ DbCommand cmd = _conn.CreateCommand();
+ foreach (string m in migrations)
+ {
+ cmd.CommandText = m;
+ cmd.ExecuteNonQuery();
+ }
+ UpdateVersion(_type, MaxVersion());
+ }
+
+ private int MaxVersion()
+ {
+ int max = 0;
+
+ string[] names = _assem.GetManifestResourceNames();
+ List migrations = new List();
+ Regex r = new Regex(@"^(\d\d\d)_" + _type + @"\.sql");
+
+ foreach (string s in names)
+ {
+ Match m = r.Match(s);
+ int MigrationVersion = int.Parse(m.Groups[1].ToString());
+ if ( MigrationVersion > max )
+ max = MigrationVersion;
+ }
+ return max;
+ }
+
+ private int FindVersion(string type)
+ {
+ int version = 0;
+ DbCommand cmd = _conn.CreateCommand();
+ cmd.CommandText = "select version from migrations where name='" + type + "' limit 1";
+ using (IDataReader reader = cmd.ExecuteReader())
+ {
+ if (reader.Read())
+ {
+ version = Convert.ToInt32(reader["version"]);
+ }
+ reader.Close();
+ }
+ return version;
+ }
+
+ private void UpdateVersion(string type, int version)
+ {
+ DbCommand cmd = _conn.CreateCommand();
+ cmd.CommandText = "update migrations set version=" + version + " where name='" + type + "'";
+ cmd.ExecuteNonQuery();
+ }
+
+ private List GetAllMigrations()
+ {
+ return GetMigrationsAfter(0);
+ }
+
+ private List GetMigrationsAfter(int version)
+ {
+ string[] names = _assem.GetManifestResourceNames();
+ List migrations = new List();
+
+ Regex r = new Regex(@"^(\d\d\d)_" + _type + @"\.sql");
+
+ foreach (string s in names)
+ {
+ m_log.Info("MIGRATION: Resources: " + s);
+ if (s.EndsWith(_type + @"\.sql"))
+ {
+ Match m = r.Match(s);
+ m_log.Info("MIGRATION: Match: " + m.Groups[1].ToString());
+ int MigrationVersion = int.Parse(m.Groups[1].ToString());
+ using (Stream resource = _assem.GetManifestResourceStream(s))
+ {
+ using (StreamReader resourceReader = new StreamReader(resource))
+ {
+ string resourceString = resourceReader.ReadToEnd();
+ migrations.Add(resourceString);
+ }
+ }
+ }
+ }
+
+ // TODO: once this is working, get rid of this
+ if (migrations.Count < 1) {
+ throw new Exception(string.Format("Resource '{0}' was not found", _type));
+ }
+
+ return migrations;
+ }
+ }
+}
\ No newline at end of file
diff --git a/OpenSim/Data/Migrations/Migration.cs b/OpenSim/Data/Migrations/Migration.cs
deleted file mode 100644
index aaf6dab..0000000
--- a/OpenSim/Data/Migrations/Migration.cs
+++ /dev/null
@@ -1,198 +0,0 @@
-/*
- * Copyright (c) Contributors, http://opensimulator.org/
- * See CONTRIBUTORS.TXT for a full list of copyright holders.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * * Neither the name of the OpenSim Project nor the
- * names of its contributors may be used to endorse or promote products
- * derived from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
- * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
- * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
- * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
- * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
- * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
- * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
- * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
- * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
-
-using System;
-using System.Collections.Generic;
-using System.Data;
-using System.Data.Common;
-using System.IO;
-using System.Reflection;
-using System.Text.RegularExpressions;
-using log4net;
-
-namespace OpenSim.Data.Migrations
-{
- ///
- ///
- /// The Migration theory is based on the ruby on rails concept.
- /// Each database driver is going to be allowed to have files in
- /// Resources that specify the database migrations. They will be
- /// of the form:
- ///
- /// 001_Users.sql
- /// 002_Users.sql
- /// 003_Users.sql
- /// 001_Prims.sql
- /// 002_Prims.sql
- /// ...etc...
- ///
- /// When a database driver starts up, it specifies a resource that
- /// needs to be brought up to the current revision. For instance:
- ///
- /// Migration um = new Migration(DbConnection, "Users");
- /// um.Upgrade();
- ///
- /// This works out which version Users is at, and applies all the
- /// revisions past it to it. If there is no users table, all
- /// revisions are applied in order. Consider each future
- /// migration to be an incremental roll forward of the tables in
- /// question.
- ///
- ///
-
- public class Migration
- {
- private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
-
- private string _type;
- private DbConnection _conn;
- private string _subtype;
- private Assembly _assem;
-
- private static readonly string _migrations_create = "create table migrations(name varchar(100), version int)";
- private static readonly string _migrations_init = "insert into migrations values('migrations', 1)";
- private static readonly string _migrations_find = "select version from migrations where name='migrations'";
-
- public Migration(DbConnection conn, Assembly assem, string type)
- {
- _type = type;
- _conn = conn;
- _assem = assem;
- }
-
- private void Initialize()
- {
- // clever, eh, we figure out which migrations version we are
- int migration_version = FindVersion("migrations");
-
- if (migration_version > 0)
- return;
-
- // If not, create the migration tables
- DbCommand cmd = _conn.CreateCommand();
- cmd.CommandText = _migrations_create;
- cmd.ExecuteNonQuery();
-
- UpdateVersion("migrations", 1);
- }
-
- public void Update()
- {
- int version = 0;
- version = FindVersion(_type);
-
- List migrations = GetMigrationsAfter(version);
- DbCommand cmd = _conn.CreateCommand();
- foreach (string m in migrations)
- {
- cmd.CommandText = m;
- cmd.ExecuteNonQuery();
- }
- UpdateVersion(_type, MaxVersion());
- }
-
- private int MaxVersion()
- {
- int max = 0;
-
- string[] names = _assem.GetManifestResourceNames();
- List migrations = new List();
- Regex r = new Regex(@"^(\d\d\d)_" + _type + @"\.sql");
-
- foreach (string s in names)
- {
- Match m = r.Match(s);
- int MigrationVersion = int.Parse(m.Groups[1].ToString());
- if ( MigrationVersion > max )
- max = MigrationVersion;
- }
- return max;
- }
-
- private int FindVersion(string type)
- {
- int version = 0;
- DbCommand cmd = _conn.CreateCommand();
- cmd.CommandText = "select version from migrations where name='" + type + "' limit 1";
- using (IDataReader reader = cmd.ExecuteReader())
- {
- if (reader.Read())
- {
- version = Convert.ToInt32(reader["version"]);
- }
- reader.Close();
- }
- return version;
- }
-
- private void UpdateVersion(string type, int version)
- {
- DbCommand cmd = _conn.CreateCommand();
- cmd.CommandText = "update migrations set version=" + version + " where name='" + type + "'";
- cmd.ExecuteNonQuery();
- }
-
- private List GetAllMigrations()
- {
- return GetMigrationsAfter(0);
- }
-
- private List GetMigrationsAfter(int version)
- {
- string[] names = _assem.GetManifestResourceNames();
- List migrations = new List();
-
- Regex r = new Regex(@"^(\d\d\d)_" + _type + @"\.sql");
-
- foreach (string s in names)
- {
- m_log.Info("MIGRATION: Resources: " + s);
- if (s.EndsWith(_type + @"\.sql"))
- {
- Match m = r.Match(s);
- m_log.Info("MIGRATION: Match: " + m.Groups[1].ToString());
- int MigrationVersion = int.Parse(m.Groups[1].ToString());
- using (Stream resource = _assem.GetManifestResourceStream(s))
- {
- using (StreamReader resourceReader = new StreamReader(resource))
- {
- string resourceString = resourceReader.ReadToEnd();
- migrations.Add(resourceString);
- }
- }
- }
- }
-
- // TODO: once this is working, get rid of this
- if (migrations.Count < 1) {
- throw new Exception(string.Format("Resource '{0}' was not found", _type));
- }
-
- return migrations;
- }
- }
-}
\ No newline at end of file
--
cgit v1.1