clean up the nhibernate definitions to work with mysql

integrate migration support into nhibernate

1 files changed, 5 insertions, 33 deletions

diff --git a/OpenSim/Data/NHibernate/NHibernateUserData.cs b/OpenSim/Data/NHibernate/NHibernateUserData.cs
index af9020d..044c14a 100644
--- a/OpenSim/Data/NHibernate/NHibernateUserData.cs
+++ b/OpenSim/Data/NHibernate/NHibernateUserData.cs
@@ -61,6 +61,7 @@ namespace OpenSim.Data.NHibernate
                 // TODO: make this a real exception type
                 throw new Exception("Malformed Inventory connection string '" + connect + "'");
             }
+            string dialect = parts[0];
 
             // This is stubbing for now, it will become dynamic later and support different db backends
             cfg = new Configuration();
@@ -73,41 +74,12 @@ namespace OpenSim.Data.NHibernate
             cfg.SetProperty(Environment.ConnectionString, parts[2]);
             cfg.AddAssembly("OpenSim.Data.NHibernate");
 
-            HbmSerializer.Default.Validate = true;
-            using (MemoryStream stream =
-                   HbmSerializer.Default.Serialize(Assembly.GetExecutingAssembly()))
-                cfg.AddInputStream(stream);
-
-            // new SchemaExport(cfg).Create(true, true);
-
             factory  = cfg.BuildSessionFactory();
-            InitDB();
-        }
 
-        private void InitDB()
-        {
-            string regex = @"no such table: UserProfiles";
-            Regex RE = new Regex(regex, RegexOptions.Multiline);
-            try
-            {
-                using (ISession session = factory.OpenSession())
-                {
-                    session.Load(typeof(UserProfileData), LLUUID.Zero);
-                }
-            }
-            catch (ObjectNotFoundException)
-            {
-                // yes, we know it's not there, but that's ok
-            }
-            catch (ADOException e)
-            {
-                Match m = RE.Match(e.ToString());
-                if (m.Success)
-                {
-                    // We don't have this table, so create it.
-                    new SchemaExport(cfg).Create(true, true);
-                }
-            }
+            // This actually does the roll forward assembly stuff
+            Assembly assem = GetType().Assembly;
+            Migration m = new Migration((System.Data.Common.DbConnection)factory.ConnectionProvider.GetConnection(), assem, dialect, "AssetStore");
+            m.Update();
         }
 
         private bool ExistsUser(LLUUID uuid)