Fix and finish the extra parameters storage system for MySQL

integration
Melanie 2012-08-15 18:21:28 +02:00
parent dc82ad0f7a
commit c7f2debd38
1 changed files with 57 additions and 1 deletions

View File

@ -1969,15 +1969,71 @@ namespace OpenSim.Data.MySQL
public void SaveExtra(UUID regionID, string name, string val) public void SaveExtra(UUID regionID, string name, string val)
{ {
lock (m_dbLock)
{
using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
{
dbcon.Open();
using (MySqlCommand cmd = dbcon.CreateCommand())
{
cmd.CommandText = "replace into regionextra values (?RegionID, ?Name, ?value)";
cmd.Parameters.AddWithValue("?RegionID", regionID.ToString());
cmd.Parameters.AddWithValue("?Name", name);
cmd.Parameters.AddWithValue("?value", val);
cmd.ExecuteNonQuery();
}
}
}
} }
public void RemoveExtra(UUID regionID, string name) public void RemoveExtra(UUID regionID, string name)
{ {
lock (m_dbLock)
{
using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
{
dbcon.Open();
using (MySqlCommand cmd = dbcon.CreateCommand())
{
cmd.CommandText = "delete from regionextra where RegionID=?RegionID and Name=?Name";
cmd.Parameters.AddWithValue("?RegionID", regionID.ToString());
cmd.Parameters.AddWithValue("?Name", name);
cmd.ExecuteNonQuery();
}
}
}
} }
public Dictionary<string, string> GetExtra(UUID regionID) public Dictionary<string, string> GetExtra(UUID regionID)
{ {
return null; Dictionary<string, string> ret = new Dictionary<string, string>();
lock (m_dbLock)
{
using (MySqlConnection dbcon = new MySqlConnection(m_connectionString))
{
dbcon.Open();
using (MySqlCommand cmd = dbcon.CreateCommand())
{
cmd.CommandText = "select * from regionextra where RegionID=?RegionID";
cmd.Parameters.AddWithValue("?RegionID", regionID.ToString());
using (IDataReader r = cmd.ExecuteReader())
{
while (r.Read())
{
ret[r["Name"].ToString()] = r["value"].ToString();
}
}
}
}
}
return ret;
} }
} }
} }