add create_time and access_time to asset db for mysql, as well

as the code to update these at the appropriate time.  This isn't
surfaced in AssetBase yet.

Change the replace into to an insert into for asset create.  Assets
are not supposed to be updatable, and the replace into is more
expensive.

From: Sean Dague <sdague@gmail.com>
0.6.0-stable
Sean Dague 2008-11-06 21:21:46 +00:00
parent c6dad833f5
commit 629b0d9f28
2 changed files with 52 additions and 2 deletions

View File

@ -45,6 +45,7 @@ namespace OpenSim.Data.MySQL
private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
private MySQLManager _dbConnection; private MySQLManager _dbConnection;
private long TicksToEpoch;
#region IPlugin Members #region IPlugin Members
@ -61,6 +62,8 @@ namespace OpenSim.Data.MySQL
/// <param name="connect">connect string</param> /// <param name="connect">connect string</param>
override public void Initialise(string connect) override public void Initialise(string connect)
{ {
TicksToEpoch = new System.DateTime(1970,1,1).Ticks;
// TODO: This will let you pass in the connect string in // TODO: This will let you pass in the connect string in
// the config, though someone will need to write that. // the config, though someone will need to write that.
if (connect == String.Empty) if (connect == String.Empty)
@ -146,6 +149,8 @@ namespace OpenSim.Data.MySQL
dbReader.Close(); dbReader.Close();
cmd.Dispose(); cmd.Dispose();
} }
if (asset != null)
UpdateAccessTime(asset);
} }
catch (Exception e) catch (Exception e)
{ {
@ -178,8 +183,8 @@ namespace OpenSim.Data.MySQL
MySqlCommand cmd = MySqlCommand cmd =
new MySqlCommand( new MySqlCommand(
"REPLACE INTO assets(id, name, description, assetType, local, temporary, data)" + "insert INTO assets(id, name, description, assetType, local, temporary, create_time, access_time, data)" +
"VALUES(?id, ?name, ?description, ?assetType, ?local, ?temporary, ?data)", "VALUES(?id, ?name, ?description, ?assetType, ?local, ?temporary, ?create_time, ?access_time, ?data)",
_dbConnection.Connection); _dbConnection.Connection);
// need to ensure we dispose // need to ensure we dispose
@ -187,12 +192,16 @@ namespace OpenSim.Data.MySQL
{ {
using (cmd) using (cmd)
{ {
// create unix epoch time
int now = (int)((System.DateTime.Now.Ticks - TicksToEpoch) / 10000000);
cmd.Parameters.AddWithValue("?id", asset.FullID.ToString()); cmd.Parameters.AddWithValue("?id", asset.FullID.ToString());
cmd.Parameters.AddWithValue("?name", asset.Name); cmd.Parameters.AddWithValue("?name", asset.Name);
cmd.Parameters.AddWithValue("?description", asset.Description); cmd.Parameters.AddWithValue("?description", asset.Description);
cmd.Parameters.AddWithValue("?assetType", asset.Type); cmd.Parameters.AddWithValue("?assetType", asset.Type);
cmd.Parameters.AddWithValue("?local", asset.Local); cmd.Parameters.AddWithValue("?local", asset.Local);
cmd.Parameters.AddWithValue("?temporary", asset.Temporary); cmd.Parameters.AddWithValue("?temporary", asset.Temporary);
cmd.Parameters.AddWithValue("?create_time", now);
cmd.Parameters.AddWithValue("?access_time", now);
cmd.Parameters.AddWithValue("?data", asset.Data); cmd.Parameters.AddWithValue("?data", asset.Data);
cmd.ExecuteNonQuery(); cmd.ExecuteNonQuery();
cmd.Dispose(); cmd.Dispose();
@ -209,6 +218,41 @@ namespace OpenSim.Data.MySQL
} }
} }
private void UpdateAccessTime(AssetBase asset)
{
lock (_dbConnection)
{
_dbConnection.CheckConnection();
MySqlCommand cmd =
new MySqlCommand("update assets set access_time=?access_time where id=?id",
_dbConnection.Connection);
// need to ensure we dispose
try
{
using (cmd)
{
// create unix epoch time
int now = (int)((System.DateTime.Now.Ticks - TicksToEpoch) / 10000000);
cmd.Parameters.AddWithValue("?id", asset.FullID.ToString());
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);
_dbConnection.Reconnect();
}
}
}
/// <summary> /// <summary>
/// Update a asset in database, see <see cref="CreateAsset"/> /// Update a asset in database, see <see cref="CreateAsset"/>
/// </summary> /// </summary>

View File

@ -0,0 +1,6 @@
BEGIN;
ALTER TABLE assets add create_time integer default 0;
ALTER TABLE assets add access_time integer default 0;
COMMIT;