123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267 |
- /*
- * Copyright (c) Contributors, http://www.openmetaverse.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 Db4objects.Db4o;
- using libsecondlife;
- using OpenSim.Framework.Console;
- using OpenSim.Framework.Interfaces;
- using OpenSim.Framework.Types;
- namespace OpenSim.Region.Storage.LocalStorageDb4o
- {
- /// <summary>
- ///
- /// </summary>
- public class Db4LocalStorage : ILocalStorage
- {
- private IObjectContainer db;
- private string datastore;
- public Db4LocalStorage()
- {
- }
- public void Initialise(string dfile)
- {
- MainLog.Instance.Warn("Db4LocalStorage Opening " + dfile);
- datastore = dfile;
- try
- {
- db = Db4oFactory.OpenFile(datastore);
- MainLog.Instance.Verbose("Db4LocalStorage creation");
- }
- catch (Exception e)
- {
- db.Close();
- MainLog.Instance.Warn("Db4LocalStorage :Constructor - Exception occured");
- MainLog.Instance.Warn(e.ToString());
- }
- }
- public void StorePrim(PrimData prim)
- {
- IObjectSet result = db.Query(new UUIDPrimQuery(prim.FullID));
- if (result.Count > 0)
- {
- //prim already in storage
- //so update it
- PrimData found = (PrimData)result.Next();
- found.PathBegin = prim.PathBegin;
- found.PathCurve = prim.PathCurve;
- found.PathEnd = prim.PathEnd;
- found.PathRadiusOffset = prim.PathRadiusOffset;
- found.PathRevolutions = prim.PathRevolutions;
- found.PathScaleX = prim.PathScaleX;
- found.PathScaleY = prim.PathScaleY;
- found.PathShearX = prim.PathShearX;
- found.PathShearY = prim.PathShearY;
- found.PathSkew = prim.PathSkew;
- found.PathTaperX = prim.PathTaperX;
- found.PathTaperY = prim.PathTaperY;
- found.PathTwist = prim.PathTwist;
- found.PathTwistBegin = prim.PathTwistBegin;
- found.PCode = prim.PCode;
- found.ProfileBegin = prim.ProfileBegin;
- found.ProfileCurve = prim.ProfileCurve;
- found.ProfileEnd = prim.ProfileEnd;
- found.ProfileHollow = prim.ProfileHollow;
- found.Position = prim.Position;
- found.Rotation = prim.Rotation;
- found.TextureEntry = prim.TextureEntry;
- db.Set(found);
- db.Commit();
- }
- else
- {
- //not in storage
- db.Set(prim);
- db.Commit();
- }
- }
- public void RemovePrim(LLUUID primID)
- {
- IObjectSet result = db.Query(new UUIDPrimQuery(primID));
- if (result.Count > 0)
- {
- PrimData found = (PrimData)result.Next();
- db.Delete(found);
- }
- }
- public void LoadPrimitives(ILocalStorageReceiver receiver)
- {
- IObjectSet result = db.Get(typeof(PrimData));
- MainLog.Instance.Verbose("Db4LocalStorage.cs: LoadPrimitives() - number of prims in storages is " + result.Count);
- foreach (PrimData prim in result)
- {
- receiver.PrimFromStorage(prim);
- }
- }
- public float[] LoadWorld()
- {
- MainLog.Instance.Verbose("LoadWorld() - Loading world....");
- float[] heightmap = null;
- MainLog.Instance.Verbose("LoadWorld() - Looking for a heightmap in local DB");
- IObjectSet world_result = db.Get(typeof(MapStorage));
- if (world_result.Count > 0)
- {
- MainLog.Instance.Verbose("LoadWorld() - Found a heightmap in local database, loading");
- MapStorage map = (MapStorage)world_result.Next();
- //blank.LandMap = map.Map;
- heightmap = map.Map;
- }
- return heightmap;
- }
- public void SaveMap(float[] heightmap)
- {
- IObjectSet world_result = db.Get(typeof(MapStorage));
- if (world_result.Count > 0)
- {
- MainLog.Instance.Verbose("SaveWorld() - updating saved copy of heightmap in local database");
- MapStorage map = (MapStorage)world_result.Next();
- db.Delete(map);
- }
- MapStorage map1 = new MapStorage();
- map1.Map = heightmap; //OpenSim_Main.local_world.LandMap;
- db.Set(map1);
- db.Commit();
- }
- public void SaveParcel(ParcelData parcel)
- {
- IObjectSet result = db.Query(new UUIDParcelQuery(parcel.globalID));
- if (result.Count > 0)
- {
- //Old Parcel
- ParcelData updateParcel = (ParcelData)result.Next();
- updateParcel.AABBMax = parcel.AABBMax;
- updateParcel.AABBMin = parcel.AABBMin;
- updateParcel.area = parcel.area;
- updateParcel.auctionID = parcel.auctionID;
- updateParcel.authBuyerID = parcel.authBuyerID;
- updateParcel.category = parcel.category;
- updateParcel.claimDate = parcel.claimDate;
- updateParcel.claimPrice = parcel.claimPrice;
- updateParcel.groupID = parcel.groupID;
- updateParcel.groupPrims = parcel.groupPrims;
- updateParcel.isGroupOwned = parcel.isGroupOwned;
- updateParcel.landingType = parcel.landingType;
- updateParcel.mediaAutoScale = parcel.mediaAutoScale;
- updateParcel.mediaID = parcel.mediaID;
- updateParcel.mediaURL = parcel.mediaURL;
- updateParcel.musicURL = parcel.musicURL;
- updateParcel.localID = parcel.localID;
- updateParcel.ownerID = parcel.ownerID;
- updateParcel.passHours = parcel.passHours;
- updateParcel.passPrice = parcel.passPrice;
- updateParcel.parcelBitmapByteArray = (byte[])parcel.parcelBitmapByteArray.Clone();
- updateParcel.parcelDesc = parcel.parcelDesc;
- updateParcel.parcelFlags = parcel.parcelFlags;
- updateParcel.parcelName = parcel.parcelName;
- updateParcel.parcelStatus = parcel.parcelStatus;
- updateParcel.salePrice = parcel.salePrice;
- updateParcel.snapshotID = parcel.snapshotID;
- updateParcel.userLocation = parcel.userLocation;
- updateParcel.userLookAt = parcel.userLookAt;
- db.Set(updateParcel);
- }
- else
- {
- db.Set(parcel);
- }
- db.Commit();
- }
- public void SaveParcels(ParcelData[] parcel_data)
- {
- MainLog.Instance.Notice("Parcel Backup: Saving Parcels...");
- int i;
- for (i = 0; i < parcel_data.GetLength(0); i++)
- {
- SaveParcel(parcel_data[i]);
- }
- MainLog.Instance.Notice("Parcel Backup: Parcel Save Complete");
- }
- public void RemoveParcel(ParcelData parcel)
- {
- IObjectSet result = db.Query(new UUIDParcelQuery(parcel.globalID));
- if (result.Count > 0)
- {
- db.Delete(result[0]);
- }
- db.Commit();
- }
- public void RemoveAllParcels()
- {
- MainLog.Instance.Notice("Parcel Backup: Removing all parcels...");
- IObjectSet result = db.Get(typeof(ParcelData));
- if (result.Count > 0)
- {
- foreach (ParcelData parcelData in result)
- {
- RemoveParcel(parcelData);
- }
- }
- }
- public void LoadParcels(ILocalStorageParcelReceiver recv)
- {
- MainLog.Instance.Notice("Parcel Backup: Loading Parcels...");
- IObjectSet result = db.Get(typeof(ParcelData));
- if (result.Count > 0)
- {
- MainLog.Instance.Notice("Parcel Backup: Parcels exist in database.");
- foreach (ParcelData parcelData in result)
- {
- recv.ParcelFromStorage(parcelData);
- }
- }
- else
- {
- MainLog.Instance.Notice("Parcel Backup: No parcels exist. Creating basic parcel.");
- recv.NoParcelDataFromStorage();
- }
- MainLog.Instance.Notice("Parcel Backup: Parcels Restored");
- }
- public void ShutDown()
- {
- db.Commit();
- db.Close();
- }
- }
- }
|