diff options
author | Melanie | 2010-02-15 00:20:48 +0000 |
---|---|---|
committer | Melanie | 2010-02-15 00:20:48 +0000 |
commit | c033223c63274ebe41075b24d108ca952fbd242c (patch) | |
tree | 8c969a9643c469feb37133b175be18eb52fdff49 /OpenSim/Data | |
parent | Extraneous debug messages removed (diff) | |
parent | Plug a small hole (diff) | |
download | opensim-SC_OLD-c033223c63274ebe41075b24d108ca952fbd242c.zip opensim-SC_OLD-c033223c63274ebe41075b24d108ca952fbd242c.tar.gz opensim-SC_OLD-c033223c63274ebe41075b24d108ca952fbd242c.tar.bz2 opensim-SC_OLD-c033223c63274ebe41075b24d108ca952fbd242c.tar.xz |
Merge branch 'master' into presence-refactor
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Data/MySQL/MySQLUserData.cs | 5 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteRegionData.cs | 113 |
2 files changed, 101 insertions, 17 deletions
diff --git a/OpenSim/Data/MySQL/MySQLUserData.cs b/OpenSim/Data/MySQL/MySQLUserData.cs index 2cf88b8..0a9d2e3 100644 --- a/OpenSim/Data/MySQL/MySQLUserData.cs +++ b/OpenSim/Data/MySQL/MySQLUserData.cs | |||
@@ -622,11 +622,6 @@ namespace OpenSim.Data.MySQL | |||
622 | return false; | 622 | return false; |
623 | } | 623 | } |
624 | 624 | ||
625 | /// <summary> | ||
626 | /// Appearance | ||
627 | /// TODO: stubs for now to get us to a compiling state gently | ||
628 | /// override | ||
629 | /// </summary> | ||
630 | public override AvatarAppearance GetUserAppearance(UUID user) | 625 | public override AvatarAppearance GetUserAppearance(UUID user) |
631 | { | 626 | { |
632 | try | 627 | try |
diff --git a/OpenSim/Data/SQLite/SQLiteRegionData.cs b/OpenSim/Data/SQLite/SQLiteRegionData.cs index b68de1a..5a4ee2a 100644 --- a/OpenSim/Data/SQLite/SQLiteRegionData.cs +++ b/OpenSim/Data/SQLite/SQLiteRegionData.cs | |||
@@ -617,18 +617,42 @@ namespace OpenSim.Data.SQLite | |||
617 | { | 617 | { |
618 | lock (ds) | 618 | lock (ds) |
619 | { | 619 | { |
620 | using (SqliteCommand cmd = new SqliteCommand("delete from land where UUID=:UUID", m_conn)) | 620 | // Can't use blanket SQL statements when using SqlAdapters unless you re-read the data into the adapter |
621 | // after you're done. | ||
622 | // replaced below code with the SqliteAdapter version. | ||
623 | //using (SqliteCommand cmd = new SqliteCommand("delete from land where UUID=:UUID", m_conn)) | ||
624 | //{ | ||
625 | // cmd.Parameters.Add(new SqliteParameter(":UUID", globalID.ToString())); | ||
626 | // cmd.ExecuteNonQuery(); | ||
627 | //} | ||
628 | |||
629 | //using (SqliteCommand cmd = new SqliteCommand("delete from landaccesslist where LandUUID=:UUID", m_conn)) | ||
630 | //{ | ||
631 | // cmd.Parameters.Add(new SqliteParameter(":UUID", globalID.ToString())); | ||
632 | // cmd.ExecuteNonQuery(); | ||
633 | //} | ||
634 | |||
635 | DataTable land = ds.Tables["land"]; | ||
636 | DataTable landaccesslist = ds.Tables["landaccesslist"]; | ||
637 | DataRow landRow = land.Rows.Find(globalID.ToString()); | ||
638 | if (landRow != null) | ||
621 | { | 639 | { |
622 | cmd.Parameters.Add(new SqliteParameter(":UUID", globalID.ToString())); | 640 | land.Rows.Remove(landRow); |
623 | cmd.ExecuteNonQuery(); | ||
624 | } | 641 | } |
625 | 642 | List<DataRow> rowsToDelete = new List<DataRow>(); | |
626 | using (SqliteCommand cmd = new SqliteCommand("delete from landaccesslist where LandUUID=:UUID", m_conn)) | 643 | foreach (DataRow rowToCheck in landaccesslist.Rows) |
627 | { | 644 | { |
628 | cmd.Parameters.Add(new SqliteParameter(":UUID", globalID.ToString())); | 645 | if (rowToCheck["LandUUID"].ToString() == globalID.ToString()) |
629 | cmd.ExecuteNonQuery(); | 646 | rowsToDelete.Add(rowToCheck); |
647 | } | ||
648 | for (int iter = 0; iter < rowsToDelete.Count; iter++) | ||
649 | { | ||
650 | landaccesslist.Rows.Remove(rowsToDelete[iter]); | ||
630 | } | 651 | } |
652 | |||
653 | |||
631 | } | 654 | } |
655 | Commit(); | ||
632 | } | 656 | } |
633 | 657 | ||
634 | /// <summary> | 658 | /// <summary> |
@@ -655,12 +679,27 @@ namespace OpenSim.Data.SQLite | |||
655 | } | 679 | } |
656 | 680 | ||
657 | // I know this caused someone issues before, but OpenSim is unusable if we leave this stuff around | 681 | // I know this caused someone issues before, but OpenSim is unusable if we leave this stuff around |
658 | using (SqliteCommand cmd = new SqliteCommand("delete from landaccesslist where LandUUID=:LandUUID", m_conn)) | 682 | //using (SqliteCommand cmd = new SqliteCommand("delete from landaccesslist where LandUUID=:LandUUID", m_conn)) |
683 | //{ | ||
684 | // cmd.Parameters.Add(new SqliteParameter(":LandUUID", parcel.LandData.GlobalID.ToString())); | ||
685 | // cmd.ExecuteNonQuery(); | ||
686 | |||
687 | // } | ||
688 | |||
689 | // This is the slower.. but more appropriate thing to do | ||
690 | |||
691 | // We can't modify the table with direct queries before calling Commit() and re-filling them. | ||
692 | List<DataRow> rowsToDelete = new List<DataRow>(); | ||
693 | foreach (DataRow rowToCheck in landaccesslist.Rows) | ||
659 | { | 694 | { |
660 | cmd.Parameters.Add(new SqliteParameter(":LandUUID", parcel.LandData.GlobalID.ToString())); | 695 | if (rowToCheck["LandUUID"].ToString() == parcel.LandData.GlobalID.ToString()) |
661 | cmd.ExecuteNonQuery(); | 696 | rowsToDelete.Add(rowToCheck); |
662 | } | 697 | } |
663 | 698 | for (int iter = 0; iter < rowsToDelete.Count; iter++) | |
699 | { | ||
700 | landaccesslist.Rows.Remove(rowsToDelete[iter]); | ||
701 | } | ||
702 | rowsToDelete.Clear(); | ||
664 | foreach (ParcelManager.ParcelAccessEntry entry in parcel.LandData.ParcelAccessList) | 703 | foreach (ParcelManager.ParcelAccessEntry entry in parcel.LandData.ParcelAccessList) |
665 | { | 704 | { |
666 | DataRow newAccessRow = landaccesslist.NewRow(); | 705 | DataRow newAccessRow = landaccesslist.NewRow(); |
@@ -1711,7 +1750,7 @@ namespace OpenSim.Data.SQLite | |||
1711 | row["terrain_raise_limit"] = settings.TerrainRaiseLimit; | 1750 | row["terrain_raise_limit"] = settings.TerrainRaiseLimit; |
1712 | row["terrain_lower_limit"] = settings.TerrainLowerLimit; | 1751 | row["terrain_lower_limit"] = settings.TerrainLowerLimit; |
1713 | row["use_estate_sun"] = settings.UseEstateSun; | 1752 | row["use_estate_sun"] = settings.UseEstateSun; |
1714 | row["sandbox"] = settings.Sandbox; | 1753 | row["Sandbox"] = settings.Sandbox; // database uses upper case S for sandbox |
1715 | row["sunvectorx"] = settings.SunVector.X; | 1754 | row["sunvectorx"] = settings.SunVector.X; |
1716 | row["sunvectory"] = settings.SunVector.Y; | 1755 | row["sunvectory"] = settings.SunVector.Y; |
1717 | row["sunvectorz"] = settings.SunVector.Z; | 1756 | row["sunvectorz"] = settings.SunVector.Z; |
@@ -1813,6 +1852,7 @@ namespace OpenSim.Data.SQLite | |||
1813 | /// <param name="regionUUID"></param> | 1852 | /// <param name="regionUUID"></param> |
1814 | private void addPrim(SceneObjectPart prim, UUID sceneGroupID, UUID regionUUID) | 1853 | private void addPrim(SceneObjectPart prim, UUID sceneGroupID, UUID regionUUID) |
1815 | { | 1854 | { |
1855 | |||
1816 | DataTable prims = ds.Tables["prims"]; | 1856 | DataTable prims = ds.Tables["prims"]; |
1817 | DataTable shapes = ds.Tables["primshapes"]; | 1857 | DataTable shapes = ds.Tables["primshapes"]; |
1818 | 1858 | ||
@@ -1962,6 +2002,40 @@ namespace OpenSim.Data.SQLite | |||
1962 | } | 2002 | } |
1963 | 2003 | ||
1964 | /// <summary> | 2004 | /// <summary> |
2005 | /// create an update command | ||
2006 | /// </summary> | ||
2007 | /// <param name="table">table name</param> | ||
2008 | /// <param name="pk"></param> | ||
2009 | /// <param name="dt"></param> | ||
2010 | /// <returns>the created command</returns> | ||
2011 | private static SqliteCommand createUpdateCommand(string table, string pk1, string pk2, DataTable dt) | ||
2012 | { | ||
2013 | string sql = "update " + table + " set "; | ||
2014 | string subsql = String.Empty; | ||
2015 | foreach (DataColumn col in dt.Columns) | ||
2016 | { | ||
2017 | if (subsql.Length > 0) | ||
2018 | { | ||
2019 | // a map function would rock so much here | ||
2020 | subsql += ", "; | ||
2021 | } | ||
2022 | subsql += col.ColumnName + "= :" + col.ColumnName; | ||
2023 | } | ||
2024 | sql += subsql; | ||
2025 | sql += " where " + pk1 + " and " + pk2; | ||
2026 | SqliteCommand cmd = new SqliteCommand(sql); | ||
2027 | |||
2028 | // this provides the binding for all our parameters, so | ||
2029 | // much less code than it used to be | ||
2030 | |||
2031 | foreach (DataColumn col in dt.Columns) | ||
2032 | { | ||
2033 | cmd.Parameters.Add(createSqliteParameter(col.ColumnName, col.DataType)); | ||
2034 | } | ||
2035 | return cmd; | ||
2036 | } | ||
2037 | |||
2038 | /// <summary> | ||
1965 | /// | 2039 | /// |
1966 | /// </summary> | 2040 | /// </summary> |
1967 | /// <param name="dt">Data Table</param> | 2041 | /// <param name="dt">Data Table</param> |
@@ -2079,6 +2153,11 @@ namespace OpenSim.Data.SQLite | |||
2079 | 2153 | ||
2080 | da.UpdateCommand = createUpdateCommand("land", "UUID=:UUID", ds.Tables["land"]); | 2154 | da.UpdateCommand = createUpdateCommand("land", "UUID=:UUID", ds.Tables["land"]); |
2081 | da.UpdateCommand.Connection = conn; | 2155 | da.UpdateCommand.Connection = conn; |
2156 | |||
2157 | SqliteCommand delete = new SqliteCommand("delete from land where UUID=:UUID"); | ||
2158 | delete.Parameters.Add(createSqliteParameter("UUID", typeof(String))); | ||
2159 | da.DeleteCommand = delete; | ||
2160 | da.DeleteCommand.Connection = conn; | ||
2082 | } | 2161 | } |
2083 | 2162 | ||
2084 | /// <summary> | 2163 | /// <summary> |
@@ -2090,6 +2169,16 @@ namespace OpenSim.Data.SQLite | |||
2090 | { | 2169 | { |
2091 | da.InsertCommand = createInsertCommand("landaccesslist", ds.Tables["landaccesslist"]); | 2170 | da.InsertCommand = createInsertCommand("landaccesslist", ds.Tables["landaccesslist"]); |
2092 | da.InsertCommand.Connection = conn; | 2171 | da.InsertCommand.Connection = conn; |
2172 | |||
2173 | da.UpdateCommand = createUpdateCommand("landaccesslist", "LandUUID=:landUUID", "AccessUUID=:AccessUUID", ds.Tables["landaccesslist"]); | ||
2174 | da.UpdateCommand.Connection = conn; | ||
2175 | |||
2176 | SqliteCommand delete = new SqliteCommand("delete from landaccesslist where LandUUID= :LandUUID and AccessUUID= :AccessUUID"); | ||
2177 | delete.Parameters.Add(createSqliteParameter("LandUUID", typeof(String))); | ||
2178 | delete.Parameters.Add(createSqliteParameter("AccessUUID", typeof(String))); | ||
2179 | da.DeleteCommand = delete; | ||
2180 | da.DeleteCommand.Connection = conn; | ||
2181 | |||
2093 | } | 2182 | } |
2094 | 2183 | ||
2095 | private void setupRegionSettingsCommands(SqliteDataAdapter da, SqliteConnection conn) | 2184 | private void setupRegionSettingsCommands(SqliteDataAdapter da, SqliteConnection conn) |