123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362 |
- 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
- {
-
-
-
- public class MySQLAssetData : AssetDataBase
- {
- private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
- private string m_connectionString;
- private object m_dbLock = new object();
- #region IPlugin Members
- public override string Version { get { return "1.0.0.0"; } }
-
-
-
-
-
-
-
-
-
-
-
- public override void Initialise(string connect)
- {
- m_connectionString = connect;
-
- Assembly assem = GetType().Assembly;
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- Migration m = new Migration(dbcon, assem, "AssetStore");
- m.Update();
- }
- }
- public override void Initialise()
- {
- throw new NotImplementedException();
- }
- public override void Dispose() { }
-
-
-
- override public string Name
- {
- get { return "MySQL Asset storage engine"; }
- }
- #endregion
- #region IAssetDataPlugin Members
-
-
-
-
-
-
- override public AssetBase GetAsset(UUID assetID)
- {
- AssetBase asset = null;
- lock (m_dbLock)
- {
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- using (MySqlCommand cmd = new MySqlCommand(
- "SELECT name, description, assetType, local, temporary, asset_flags, data FROM assets WHERE id=?id",
- dbcon))
- {
- cmd.Parameters.AddWithValue("?id", assetID.ToString());
- try
- {
- using (MySqlDataReader dbReader = cmd.ExecuteReader(CommandBehavior.SingleRow))
- {
- if (dbReader.Read())
- {
- asset = new AssetBase(assetID, (string)dbReader["name"], (sbyte)dbReader["assetType"], UUID.Zero.ToString());
- asset.Data = (byte[])dbReader["data"];
- asset.Description = (string)dbReader["description"];
- string local = dbReader["local"].ToString();
- if (local.Equals("1") || local.Equals("true", StringComparison.InvariantCultureIgnoreCase))
- asset.Local = true;
- else
- asset.Local = false;
- asset.Temporary = Convert.ToBoolean(dbReader["temporary"]);
- asset.Flags = (AssetFlags)Convert.ToInt32(dbReader["asset_flags"]);
- }
- }
- }
- catch (Exception e)
- {
- m_log.Error("[ASSETS DB]: MySql failure fetching asset " + assetID + ": " + e.Message);
- }
- }
- }
- }
- return asset;
- }
-
-
-
-
-
- override public void StoreAsset(AssetBase asset)
- {
- lock (m_dbLock)
- {
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- MySqlCommand cmd =
- new MySqlCommand(
- "replace INTO assets(id, name, description, assetType, local, temporary, create_time, access_time, asset_flags, data)" +
- "VALUES(?id, ?name, ?description, ?assetType, ?local, ?temporary, ?create_time, ?access_time, ?asset_flags, ?data)",
- dbcon);
- string assetName = asset.Name;
- if (asset.Name.Length > 64)
- {
- assetName = asset.Name.Substring(0, 64);
- m_log.Warn("[ASSET DB]: Name field truncated from " + asset.Name.Length + " to " + assetName.Length + " characters on add");
- }
- string assetDescription = asset.Description;
- if (asset.Description.Length > 64)
- {
- assetDescription = asset.Description.Substring(0, 64);
- m_log.Warn("[ASSET DB]: Description field truncated from " + asset.Description.Length + " to " + assetDescription.Length + " characters on add");
- }
-
- try
- {
- using (cmd)
- {
-
- int now = (int)Utils.DateTimeToUnixTime(DateTime.UtcNow);
- cmd.Parameters.AddWithValue("?id", asset.ID);
- cmd.Parameters.AddWithValue("?name", assetName);
- cmd.Parameters.AddWithValue("?description", assetDescription);
- cmd.Parameters.AddWithValue("?assetType", asset.Type);
- cmd.Parameters.AddWithValue("?local", asset.Local);
- cmd.Parameters.AddWithValue("?temporary", asset.Temporary);
- cmd.Parameters.AddWithValue("?create_time", now);
- cmd.Parameters.AddWithValue("?access_time", now);
- cmd.Parameters.AddWithValue("?asset_flags", (int)asset.Flags);
- cmd.Parameters.AddWithValue("?data", asset.Data);
- cmd.ExecuteNonQuery();
- cmd.Dispose();
- }
- }
- catch (Exception e)
- {
- m_log.ErrorFormat("[ASSET DB]: MySQL failure creating asset {0} with name \"{1}\". Error: {2}",
- asset.FullID, asset.Name, e.Message);
- }
- }
- }
- }
- private void UpdateAccessTime(AssetBase asset)
- {
-
- return;
- lock (m_dbLock)
- {
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- MySqlCommand cmd =
- new MySqlCommand("update assets set access_time=?access_time where id=?id",
- dbcon);
-
- try
- {
- using (cmd)
- {
-
- int now = (int)Utils.DateTimeToUnixTime(DateTime.UtcNow);
- cmd.Parameters.AddWithValue("?id", asset.ID);
- cmd.Parameters.AddWithValue("?access_time", now);
- cmd.ExecuteNonQuery();
- cmd.Dispose();
- }
- }
- catch (Exception e)
- {
- m_log.ErrorFormat(
- "[ASSETS DB]: " +
- "MySql failure updating access_time for asset {0} with name {1}" + Environment.NewLine + e.ToString()
- + Environment.NewLine + "Attempting reconnection", asset.FullID, asset.Name);
- }
- }
- }
- }
-
-
-
-
-
- override public bool ExistsAsset(UUID uuid)
- {
- bool assetExists = false;
- lock (m_dbLock)
- {
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- using (MySqlCommand cmd = new MySqlCommand("SELECT id FROM assets WHERE id=?id", dbcon))
- {
- cmd.Parameters.AddWithValue("?id", uuid.ToString());
- try
- {
- using (MySqlDataReader dbReader = cmd.ExecuteReader(CommandBehavior.SingleRow))
- {
- if (dbReader.Read())
- assetExists = true;
- }
- }
- catch (Exception e)
- {
- m_log.ErrorFormat(
- "[ASSETS DB]: MySql failure fetching asset {0}" + Environment.NewLine + e.ToString(), uuid);
- }
- }
- }
- }
- return assetExists;
- }
-
-
-
-
-
-
-
-
- public override List<AssetMetadata> FetchAssetMetadataSet(int start, int count)
- {
- List<AssetMetadata> retList = new List<AssetMetadata>(count);
- lock (m_dbLock)
- {
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- MySqlCommand cmd = new MySqlCommand("SELECT name,description,assetType,temporary,id,asset_flags FROM assets LIMIT ?start, ?count", dbcon);
- cmd.Parameters.AddWithValue("?start", start);
- cmd.Parameters.AddWithValue("?count", count);
- try
- {
- using (MySqlDataReader dbReader = cmd.ExecuteReader())
- {
- while (dbReader.Read())
- {
- AssetMetadata metadata = new AssetMetadata();
- metadata.Name = (string)dbReader["name"];
- metadata.Description = (string)dbReader["description"];
- metadata.Type = (sbyte)dbReader["assetType"];
- metadata.Temporary = Convert.ToBoolean(dbReader["temporary"]);
- metadata.Flags = (AssetFlags)Convert.ToInt32(dbReader["asset_flags"]);
- metadata.FullID = new UUID((string)dbReader["id"]);
-
- metadata.SHA1 = new byte[] { };
- retList.Add(metadata);
- }
- }
- }
- catch (Exception e)
- {
- m_log.Error("[ASSETS DB]: MySql failure fetching asset set" + Environment.NewLine + e.ToString());
- }
- }
- }
- return retList;
- }
- public override bool Delete(string id)
- {
- lock (m_dbLock)
- {
- using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
- {
- dbcon.Open();
- MySqlCommand cmd = new MySqlCommand("delete from assets where id=?id", dbcon);
- cmd.Parameters.AddWithValue("?id", id);
- cmd.ExecuteNonQuery();
- cmd.Dispose();
- }
- }
- return true;
- }
- #endregion
- }
- }
|