From 7634c1311efe82129f18cc8aada1d5f9995b6a9e Mon Sep 17 00:00:00 2001 From: Sean Dague Date: Mon, 7 Jul 2008 20:40:14 +0000 Subject: added skeleton (no function) region store component --- OpenSim/Data/NHibernate/NHibernateRegionData.cs | 268 ++++++++++++++++++++++++ 1 file changed, 268 insertions(+) create mode 100644 OpenSim/Data/NHibernate/NHibernateRegionData.cs diff --git a/OpenSim/Data/NHibernate/NHibernateRegionData.cs b/OpenSim/Data/NHibernate/NHibernateRegionData.cs new file mode 100644 index 0000000..2a2745f --- /dev/null +++ b/OpenSim/Data/NHibernate/NHibernateRegionData.cs @@ -0,0 +1,268 @@ +/* + * 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.IO; +using System.Reflection; +using System.Text.RegularExpressions; +using libsecondlife; +using log4net; +using NHibernate; +using NHibernate.Cfg; +using NHibernate.Mapping.Attributes; +using NHibernate.Tool.hbm2ddl; +using OpenSim.Framework; +using OpenSim.Region.Environment.Interfaces; +using OpenSim.Region.Environment.Scenes; +using Environment=NHibernate.Cfg.Environment; + +namespace OpenSim.Data.NHibernate +{ + /// + /// A RegionData Interface to the NHibernate database + /// + public class NHibernateRegionData : IRegionDataStore + { + private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); + + private Configuration cfg; + private ISessionFactory factory; + private ISession session; + + public void Initialise() + { + Initialise("SQLiteDialect;SqliteClientDriver;URI=file:OpenSim.db,version=3", true); + } + + public void Initialise(string connect, bool persistpriminventories) + { + // Split out the dialect, driver, and connect string + char[] split = {';'}; + string[] parts = connect.Split(split, 3); + if (parts.Length != 3) + { + // TODO: make this a real exception type + throw new Exception("Malformed Inventory connection string '" + connect + "'"); + } + + string dialect = parts[0]; + + // NHibernate setup + cfg = new Configuration(); + cfg.SetProperty(Environment.ConnectionProvider, + "NHibernate.Connection.DriverConnectionProvider"); + cfg.SetProperty(Environment.Dialect, + "NHibernate.Dialect." + dialect); + cfg.SetProperty(Environment.ConnectionDriver, + "NHibernate.Driver." + parts[1]); + 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); + + factory = cfg.BuildSessionFactory(); + session = factory.OpenSession(); + + // 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(); + } + + /*********************************************************************** + * + * Public Interface Functions + * + **********************************************************************/ + + public void StoreRegionSettings(RegionSettings rs) + { + } + + public RegionSettings LoadRegionSettings(LLUUID regionUUID) + { + return null; + } + + /// + /// Adds an object into region storage + /// + /// the object + /// the region UUID + public void StoreObject(SceneObjectGroup obj, LLUUID regionUUID) + { + + } + + /// + /// Removes an object from region storage + /// + /// the object + /// the region UUID + public void RemoveObject(LLUUID obj, LLUUID regionUUID) + { + m_log.InfoFormat("[REGION DB]: Removing obj: {0} from region: {1}", obj.UUID, regionUUID); + + } + + /// + /// Load persisted objects from region storage. + /// + /// The region UUID + /// List of loaded groups + public List LoadObjects(LLUUID regionUUID) + { + List prims = new List(); + return prims; + } + + /// + /// Store a terrain revision in region storage + /// + /// terrain heightfield + /// region UUID + public void StoreTerrain(double[,] ter, LLUUID regionID) + { + + } + + /// + /// Load the latest terrain revision from region storage + /// + /// the region UUID + /// Heightfield data + public double[,] LoadTerrain(LLUUID regionID) + { + double[,] terret = new double[256,256]; + terret.Initialize(); + + + return terret; + } + + /// + /// + /// + /// + public void RemoveLandObject(LLUUID globalID) + { + + } + + /// + /// + /// + /// + public void StoreLandObject(ILandObject parcel) + { + + } + + /// + /// + /// + /// + /// + public List LoadLandObjects(LLUUID regionUUID) + { + List landDataForRegion = new List(); + + return landDataForRegion; + } + + + /// + /// See + /// + public void Shutdown() + { + + } + + /// + /// Load a region banlist + /// + /// the region UUID + /// The banlist + public List LoadRegionBanList(LLUUID regionUUID) + { + List regionbanlist = new List(); + + return regionbanlist; + } + + /// + /// Add en entry into region banlist + /// + /// + public void AddToRegionBanlist(RegionBanListItem item) + { + + } + + /// + /// remove an entry from the region banlist + /// + /// + public void RemoveFromRegionBanlist(RegionBanListItem item) + { + + } + + /// + /// + /// + /// + /// + private static Array serializeTerrain(double[,] val) + { + MemoryStream str = new MemoryStream(65536*sizeof (double)); + BinaryWriter bw = new BinaryWriter(str); + + // TODO: COMPATIBILITY - Add byte-order conversions + for (int x = 0; x < 256; x++) + for (int y = 0; y < 256; y++) + bw.Write(val[x, y]); + + return str.ToArray(); + } + + /// + /// see IRegionDatastore + /// + /// + /// + public void StorePrimInventory(LLUUID primID, ICollection items) + { + + } + } +} -- cgit v1.1