/* * 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 OpenSimulator 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.Data; using System.Reflection; using System.Collections.Generic; using log4net; using MySql.Data.MySqlClient; using OpenMetaverse; using OpenSim.Framework; namespace OpenSim.Data.MySQL { /// <summary> /// A MySQL Interface for the Asset Server /// </summary> public class MySQLXInventoryData : IXInventoryData { private MySQLGenericTableHandler<XInventoryFolder> m_Folders; private MySqlItemHandler m_Items; public MySQLXInventoryData(string conn, string realm) { m_Folders = new MySQLGenericTableHandler<XInventoryFolder>( conn, "inventoryfolders", "InventoryStore"); m_Items = new MySqlItemHandler( conn, "inventoryitems", String.Empty); } public XInventoryFolder[] GetFolders(string[] fields, string[] vals) { return m_Folders.Get(fields, vals); } public XInventoryItem[] GetItems(string[] fields, string[] vals) { return m_Items.Get(fields, vals); } public bool StoreFolder(XInventoryFolder folder) { if (folder.folderName.Length > 64) folder.folderName = folder.folderName.Substring(0, 64); return m_Folders.Store(folder); } public bool StoreItem(XInventoryItem item) { if (item.inventoryName.Length > 64) item.inventoryName = item.inventoryName.Substring(0, 64); if (item.inventoryDescription.Length > 128) item.inventoryDescription = item.inventoryDescription.Substring(0, 128); return m_Items.Store(item); } public bool DeleteFolders(string field, string val) { return m_Folders.Delete(field, val); } public bool DeleteFolders(string[] fields, string[] vals) { return m_Folders.Delete(fields, vals); } public bool DeleteItems(string field, string val) { return m_Items.Delete(field, val); } public bool DeleteItems(string[] fields, string[] vals) { return m_Items.Delete(fields, vals); } public bool MoveItem(string id, string newParent) { return m_Items.MoveItem(id, newParent); } public XInventoryItem[] GetActiveGestures(UUID principalID) { return m_Items.GetActiveGestures(principalID); } public int GetAssetPermissions(UUID principalID, UUID assetID) { return m_Items.GetAssetPermissions(principalID, assetID); } } public class MySqlItemHandler : MySQLGenericTableHandler<XInventoryItem> { public MySqlItemHandler(string c, string t, string m) : base(c, t, m) { } public bool MoveItem(string id, string newParent) { using (MySqlCommand cmd = new MySqlCommand()) { cmd.CommandText = String.Format("update {0} set parentFolderID = ?ParentFolderID where inventoryID = ?InventoryID", m_Realm); cmd.Parameters.AddWithValue("?ParentFolderID", newParent); cmd.Parameters.AddWithValue("?InventoryID", id); return ExecuteNonQuery(cmd) == 0 ? false : true; } } public XInventoryItem[] GetActiveGestures(UUID principalID) { using (MySqlCommand cmd = new MySqlCommand()) { cmd.CommandText = String.Format("select * from inventoryitems where avatarId = ?uuid and assetType = ?type and flags & 1", m_Realm); cmd.Parameters.AddWithValue("?uuid", principalID.ToString()); cmd.Parameters.AddWithValue("?type", (int)AssetType.Gesture); return DoQuery(cmd); } } public int GetAssetPermissions(UUID principalID, UUID assetID) { using (MySqlConnection dbcon = new MySqlConnection(m_connectionString)) { dbcon.Open(); using (MySqlCommand cmd = new MySqlCommand()) { cmd.Connection = dbcon; cmd.CommandText = String.Format("select bit_or(inventoryCurrentPermissions) as inventoryCurrentPermissions from inventoryitems where avatarID = ?PrincipalID and assetID = ?AssetID group by assetID", m_Realm); cmd.Parameters.AddWithValue("?PrincipalID", principalID.ToString()); cmd.Parameters.AddWithValue("?AssetID", assetID.ToString()); using (IDataReader reader = cmd.ExecuteReader()) { int perms = 0; if (reader.Read()) { perms = Convert.ToInt32(reader["inventoryCurrentPermissions"]); } return perms; } } } } public override bool Store(XInventoryItem item) { if (!base.Store(item)) return false; using (MySqlConnection dbcon = new MySqlConnection(m_connectionString)) { dbcon.Open(); using (MySqlCommand cmd = new MySqlCommand()) { cmd.Connection = dbcon; cmd.CommandText = String.Format("update inventoryfolders set version=version+1 where folderID = ?folderID"); cmd.Parameters.AddWithValue("?folderID", item.parentFolderID.ToString()); try { cmd.ExecuteNonQuery(); } catch (Exception) { return false; } cmd.Dispose(); } dbcon.Close(); } return true; } } }