OpenSimulator GForge > Projects > realXtend Modules > SVN

Diff of /trunk/ModularRex/Tools/MigrationTool/RegionMigration.cs

-revision 178, Thu Jun  4 06:37:48 2009 UTC
+revision 179, Fri Jun  5 06:38:00 2009 UTC
 Line 5
  using System.Reflection;
  using OpenSim.Data;
  using log4net;
+ using ModularRex.RexFramework;
+ using OpenMetaverse;
+ using ModularRex.NHibernate;
  namespace ModularRex.Tools.MigrationTool
  {
-Line 13
+Line 16
          private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
          protected string m_connectionString = String.Empty;
+         protected string m_rexConnectionString = String.Empty;
          private const string addAuthbyerID = "ALTER TABLE land ADD COLUMN AuthbuyerID varchar(36) NOT NULL default  '00000000-0000-0000-0000-000000000000'";
-         public RegionMigration(string connectionString)
+         public RegionMigration(string connectionString, string rexConnectionString)
          {
              // default to something sensible
              if (connectionString == "")
-Line 27
+Line 31
              {
                  m_connectionString = connectionString;
              }
+             if (rexConnectionString == String.Empty)
+             {
+                 m_rexConnectionString = "SQLiteDialect;SQLite20Driver;Data Source=RexObjects.db;Version=3";
+             }
+             else
+             {
+                 m_rexConnectionString = rexConnectionString;
+             }
          }
          public bool Convert()
-Line 41
+Line 54
                  int version = m.Version;
-                 if (version <= 9)
+                 if (version <= 14)
                  {
                      if (version == 0)
                      {
+                         //read rex tables and add to rex database
+                         m_log.info("[regionstore] converting rex tables to rexobjectproperties");
+                         if (!convertlegacyrexdatatomodrex())
+                         {
+                             conn.close();
+                             return false;
+                         }
+                         m_log.Info("[RegionStore] Update region migrations");
                          //Add new field to Land table
                          SqliteCommand addAuthbyerIDCmd = new SqliteCommand(addAuthbyerID, conn);
                          addAuthbyerIDCmd.ExecuteNonQuery();
-Line 54
+Line 76
                      }
                      //Run migrations up to 9
+                     //Note: this run migrations only to point nine since only those files exist in application resources.
                      m.Update();
                      //Skip over 10. Change version to 10
                      //This skips adding of the ClickAction since that already exists in 0.4 database
-                     m.Version = 10;
+                     //m.Version = 10;
                  }
                  conn.Close();
-Line 70
+Line 93
                  return false;
              }
          }
+         protected bool ConvertLegacyRexDataToModreX()
+         {
+             NHibernateRexLegacyData legacydata = new NHibernateRexLegacyData();
+             //convert connnection string to NHibernate style
+             //parse string like this: "URI=file:OpenSim.db,version=3"
+             //and convert it to like this: "SQLiteDialect;SQLite20Driver;Data Source=RexObjects.db;Version=3"
+             string arg1 = String.Empty;
+             string arg2 = String.Empty;
+             string[] components = m_connectionString.Split(',');
+             if (components[0].StartsWith("URI=file:"))
+             {
+                 arg1 = components[0].Substring(9);
+             }
+             else
+             {
+                 m_log.ErrorFormat("[MODREXOBJECTS]: Error parseing connection string {0}", m_connectionString);
+                 return false;
+             }
+             if (components[1].StartsWith("version="))
+             {
+                 arg2 = components[1].Substring(8);
+             }
+             else
+             {
+                 m_log.ErrorFormat("[MODREXOBJECTS]: Error parseing connection string {0}", m_connectionString);
+                 return false;
+             }
+             StringBuilder sb = new StringBuilder();
+             sb.AppendFormat("SQLiteDialect;SQLite20Driver;Data Source={0};Version={1}", arg1, arg2);
+             legacydata.Initialise(sb.ToString());
+             if (!legacydata.Inizialized)
+             {
+                 m_log.Info("[MODREXOBJECTS]: Legacy database failed to initialize.");
+                 return false;
+             }
+             List<RexLegacyPrimData> rexprimdata = legacydata.LoadAllRexPrimData();
+             m_log.Info("[MODREXOBJECTS]: Legacy rexprimdata objects loaded:" + rexprimdata.Count.ToString());
+             List<RexLegacyPrimMaterialData> rexprimmaterialdata = legacydata.LoadAllRexPrimMaterialData();
+             m_log.Info("[MODREXOBJECTS]: Legacy rexprimmaterialdata objects loaded:" + rexprimmaterialdata.Count.ToString());
+             Dictionary<UUID, RexObjectProperties> rexObjects = new Dictionary<UUID, RexObjectProperties>();
+             foreach (RexLegacyPrimData prim in rexprimdata)
+             {
+                 RexObjectProperties p = new RexObjectProperties();
+                 p.SetRexPrimDataFromLegacyData(prim);
+                 rexObjects.Add(prim.UUID, p);
+             }
+             foreach (RexLegacyPrimMaterialData primmat in rexprimmaterialdata)
+             {
+                 if (rexObjects.ContainsKey(primmat.UUID) && rexObjects[primmat.UUID] != null)
+                 {
+                     rexObjects[primmat.UUID].RexMaterials.AddMaterial((uint)primmat.MaterialIndex, primmat.MaterialUUID);
+                 }
+                 else
+                 {
+                     m_log.WarnFormat("[MODREXOBJECTS]: Could not find RexObjectData for prim {0} while adding materials. Creating", primmat.UUID);
+                     RexObjectProperties p = new RexObjectProperties();
+                     p.ParentObjectID = primmat.UUID;
+                     p.RexMaterials.AddMaterial((uint)primmat.MaterialIndex, primmat.MaterialUUID);
+                     rexObjects.Add(primmat.UUID, p);
+                 }
+             }
+             //Add rex object to database
+             NHibernateRexObjectData rexObjectManager = new NHibernateRexObjectData();
+             rexObjectManager.Initialise(m_rexConnectionString);
+             foreach (KeyValuePair<UUID, RexObjectProperties> data in rexObjects)
+             {
+                 rexObjectManager.StoreObject(data.Value);
+             }
+             return true;
+         }
      }
  }

 Legend:



Removed from v.178
 


changed lines


 
Added in v.179
 Legend:



Removed from v.178
 


changed lines


 
Added in v.179
-Removed from v.178
+Added in v.179

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

realXtend Modules

Diff of /trunk/ModularRex/Tools/MigrationTool/RegionMigration.cs