diff options
author | Justin Clark-Casey (justincc) | 2010-06-08 15:50:21 +0100 |
---|---|---|
committer | Justin Clark-Casey (justincc) | 2010-06-08 15:50:21 +0100 |
commit | a160b44e0766329a6c336adcb804cede39e00fc7 (patch) | |
tree | edf6d5070a0bb9dcba424cf883fe20a7c96af751 /OpenSim/Data/SQLite | |
parent | If a transfer request is received for a task inventory item asset, then route... (diff) | |
parent | minor: remove some commented out code and return ScenePresence.UpdatePriority... (diff) | |
download | opensim-SC-a160b44e0766329a6c336adcb804cede39e00fc7.zip opensim-SC-a160b44e0766329a6c336adcb804cede39e00fc7.tar.gz opensim-SC-a160b44e0766329a6c336adcb804cede39e00fc7.tar.bz2 opensim-SC-a160b44e0766329a6c336adcb804cede39e00fc7.tar.xz |
Merge branch '0.6.9-post-fixes' into share-with-group
Diffstat (limited to 'OpenSim/Data/SQLite')
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteAssetData.cs | 4 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteEstateData.cs | 44 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteFramework.cs | 20 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteGenericTableHandler.cs | 23 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteInventoryStore.cs | 15 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteManager.cs | 8 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteRegionData.cs | 311 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteUserData.cs | 33 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteUtils.cs | 2 | ||||
-rw-r--r-- | OpenSim/Data/SQLite/SQLiteXInventoryData.cs | 6 |
10 files changed, 286 insertions, 180 deletions
diff --git a/OpenSim/Data/SQLite/SQLiteAssetData.cs b/OpenSim/Data/SQLite/SQLiteAssetData.cs index c52f60b..373c903 100644 --- a/OpenSim/Data/SQLite/SQLiteAssetData.cs +++ b/OpenSim/Data/SQLite/SQLiteAssetData.cs | |||
@@ -30,7 +30,7 @@ using System.Data; | |||
30 | using System.Reflection; | 30 | using System.Reflection; |
31 | using System.Collections.Generic; | 31 | using System.Collections.Generic; |
32 | using log4net; | 32 | using log4net; |
33 | using Mono.Data.SqliteClient; | 33 | using Mono.Data.Sqlite; |
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | using OpenSim.Framework; | 35 | using OpenSim.Framework; |
36 | 36 | ||
@@ -339,4 +339,4 @@ namespace OpenSim.Data.SQLite | |||
339 | 339 | ||
340 | #endregion | 340 | #endregion |
341 | } | 341 | } |
342 | } \ No newline at end of file | 342 | } |
diff --git a/OpenSim/Data/SQLite/SQLiteEstateData.cs b/OpenSim/Data/SQLite/SQLiteEstateData.cs index 1be99ee..643e55d 100644 --- a/OpenSim/Data/SQLite/SQLiteEstateData.cs +++ b/OpenSim/Data/SQLite/SQLiteEstateData.cs | |||
@@ -30,7 +30,7 @@ using System.Collections.Generic; | |||
30 | using System.Data; | 30 | using System.Data; |
31 | using System.Reflection; | 31 | using System.Reflection; |
32 | using log4net; | 32 | using log4net; |
33 | using Mono.Data.SqliteClient; | 33 | using Mono.Data.Sqlite; |
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | using OpenSim.Framework; | 35 | using OpenSim.Framework; |
36 | using OpenSim.Region.Framework.Interfaces; | 36 | using OpenSim.Region.Framework.Interfaces; |
@@ -62,8 +62,8 @@ namespace OpenSim.Data.SQLite | |||
62 | Migration m = new Migration(m_connection, assem, "EstateStore"); | 62 | Migration m = new Migration(m_connection, assem, "EstateStore"); |
63 | m.Update(); | 63 | m.Update(); |
64 | 64 | ||
65 | m_connection.Close(); | 65 | //m_connection.Close(); |
66 | m_connection.Open(); | 66 | // m_connection.Open(); |
67 | 67 | ||
68 | Type t = typeof(EstateSettings); | 68 | Type t = typeof(EstateSettings); |
69 | m_Fields = t.GetFields(BindingFlags.NonPublic | | 69 | m_Fields = t.GetFields(BindingFlags.NonPublic | |
@@ -90,7 +90,7 @@ namespace OpenSim.Data.SQLite | |||
90 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); | 90 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); |
91 | 91 | ||
92 | cmd.CommandText = sql; | 92 | cmd.CommandText = sql; |
93 | cmd.Parameters.Add(":RegionID", regionID.ToString()); | 93 | cmd.Parameters.AddWithValue(":RegionID", regionID.ToString()); |
94 | 94 | ||
95 | IDataReader r = cmd.ExecuteReader(); | 95 | IDataReader r = cmd.ExecuteReader(); |
96 | 96 | ||
@@ -140,13 +140,13 @@ namespace OpenSim.Data.SQLite | |||
140 | if (m_FieldMap[name].GetValue(es) is bool) | 140 | if (m_FieldMap[name].GetValue(es) is bool) |
141 | { | 141 | { |
142 | if ((bool)m_FieldMap[name].GetValue(es)) | 142 | if ((bool)m_FieldMap[name].GetValue(es)) |
143 | cmd.Parameters.Add(":"+name, "1"); | 143 | cmd.Parameters.AddWithValue(":"+name, "1"); |
144 | else | 144 | else |
145 | cmd.Parameters.Add(":"+name, "0"); | 145 | cmd.Parameters.AddWithValue(":"+name, "0"); |
146 | } | 146 | } |
147 | else | 147 | else |
148 | { | 148 | { |
149 | cmd.Parameters.Add(":"+name, m_FieldMap[name].GetValue(es).ToString()); | 149 | cmd.Parameters.AddWithValue(":"+name, m_FieldMap[name].GetValue(es).ToString()); |
150 | } | 150 | } |
151 | } | 151 | } |
152 | 152 | ||
@@ -164,8 +164,8 @@ namespace OpenSim.Data.SQLite | |||
164 | r.Close(); | 164 | r.Close(); |
165 | 165 | ||
166 | cmd.CommandText = "insert into estate_map values (:RegionID, :EstateID)"; | 166 | cmd.CommandText = "insert into estate_map values (:RegionID, :EstateID)"; |
167 | cmd.Parameters.Add(":RegionID", regionID.ToString()); | 167 | cmd.Parameters.AddWithValue(":RegionID", regionID.ToString()); |
168 | cmd.Parameters.Add(":EstateID", es.EstateID.ToString()); | 168 | cmd.Parameters.AddWithValue(":EstateID", es.EstateID.ToString()); |
169 | 169 | ||
170 | // This will throw on dupe key | 170 | // This will throw on dupe key |
171 | try | 171 | try |
@@ -180,7 +180,7 @@ namespace OpenSim.Data.SQLite | |||
180 | // | 180 | // |
181 | cmd.Parameters.Clear(); | 181 | cmd.Parameters.Clear(); |
182 | cmd.CommandText = "insert into estateban select "+es.EstateID.ToString()+", bannedUUID, bannedIp, bannedIpHostMask, '' from regionban where regionban.regionUUID = :UUID"; | 182 | cmd.CommandText = "insert into estateban select "+es.EstateID.ToString()+", bannedUUID, bannedIp, bannedIpHostMask, '' from regionban where regionban.regionUUID = :UUID"; |
183 | cmd.Parameters.Add(":UUID", regionID.ToString()); | 183 | cmd.Parameters.AddWithValue(":UUID", regionID.ToString()); |
184 | 184 | ||
185 | try | 185 | try |
186 | { | 186 | { |
@@ -222,13 +222,13 @@ namespace OpenSim.Data.SQLite | |||
222 | if (m_FieldMap[name].GetValue(es) is bool) | 222 | if (m_FieldMap[name].GetValue(es) is bool) |
223 | { | 223 | { |
224 | if ((bool)m_FieldMap[name].GetValue(es)) | 224 | if ((bool)m_FieldMap[name].GetValue(es)) |
225 | cmd.Parameters.Add(":"+name, "1"); | 225 | cmd.Parameters.AddWithValue(":"+name, "1"); |
226 | else | 226 | else |
227 | cmd.Parameters.Add(":"+name, "0"); | 227 | cmd.Parameters.AddWithValue(":"+name, "0"); |
228 | } | 228 | } |
229 | else | 229 | else |
230 | { | 230 | { |
231 | cmd.Parameters.Add(":"+name, m_FieldMap[name].GetValue(es).ToString()); | 231 | cmd.Parameters.AddWithValue(":"+name, m_FieldMap[name].GetValue(es).ToString()); |
232 | } | 232 | } |
233 | } | 233 | } |
234 | 234 | ||
@@ -247,7 +247,7 @@ namespace OpenSim.Data.SQLite | |||
247 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); | 247 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); |
248 | 248 | ||
249 | cmd.CommandText = "select bannedUUID from estateban where EstateID = :EstateID"; | 249 | cmd.CommandText = "select bannedUUID from estateban where EstateID = :EstateID"; |
250 | cmd.Parameters.Add(":EstateID", es.EstateID); | 250 | cmd.Parameters.AddWithValue(":EstateID", es.EstateID); |
251 | 251 | ||
252 | IDataReader r = cmd.ExecuteReader(); | 252 | IDataReader r = cmd.ExecuteReader(); |
253 | 253 | ||
@@ -271,7 +271,7 @@ namespace OpenSim.Data.SQLite | |||
271 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); | 271 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); |
272 | 272 | ||
273 | cmd.CommandText = "delete from estateban where EstateID = :EstateID"; | 273 | cmd.CommandText = "delete from estateban where EstateID = :EstateID"; |
274 | cmd.Parameters.Add(":EstateID", es.EstateID.ToString()); | 274 | cmd.Parameters.AddWithValue(":EstateID", es.EstateID.ToString()); |
275 | 275 | ||
276 | cmd.ExecuteNonQuery(); | 276 | cmd.ExecuteNonQuery(); |
277 | 277 | ||
@@ -281,8 +281,8 @@ namespace OpenSim.Data.SQLite | |||
281 | 281 | ||
282 | foreach (EstateBan b in es.EstateBans) | 282 | foreach (EstateBan b in es.EstateBans) |
283 | { | 283 | { |
284 | cmd.Parameters.Add(":EstateID", es.EstateID.ToString()); | 284 | cmd.Parameters.AddWithValue(":EstateID", es.EstateID.ToString()); |
285 | cmd.Parameters.Add(":bannedUUID", b.BannedUserID.ToString()); | 285 | cmd.Parameters.AddWithValue(":bannedUUID", b.BannedUserID.ToString()); |
286 | 286 | ||
287 | cmd.ExecuteNonQuery(); | 287 | cmd.ExecuteNonQuery(); |
288 | cmd.Parameters.Clear(); | 288 | cmd.Parameters.Clear(); |
@@ -294,7 +294,7 @@ namespace OpenSim.Data.SQLite | |||
294 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); | 294 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); |
295 | 295 | ||
296 | cmd.CommandText = "delete from "+table+" where EstateID = :EstateID"; | 296 | cmd.CommandText = "delete from "+table+" where EstateID = :EstateID"; |
297 | cmd.Parameters.Add(":EstateID", EstateID.ToString()); | 297 | cmd.Parameters.AddWithValue(":EstateID", EstateID.ToString()); |
298 | 298 | ||
299 | cmd.ExecuteNonQuery(); | 299 | cmd.ExecuteNonQuery(); |
300 | 300 | ||
@@ -304,8 +304,8 @@ namespace OpenSim.Data.SQLite | |||
304 | 304 | ||
305 | foreach (UUID uuid in data) | 305 | foreach (UUID uuid in data) |
306 | { | 306 | { |
307 | cmd.Parameters.Add(":EstateID", EstateID.ToString()); | 307 | cmd.Parameters.AddWithValue(":EstateID", EstateID.ToString()); |
308 | cmd.Parameters.Add(":uuid", uuid.ToString()); | 308 | cmd.Parameters.AddWithValue(":uuid", uuid.ToString()); |
309 | 309 | ||
310 | cmd.ExecuteNonQuery(); | 310 | cmd.ExecuteNonQuery(); |
311 | cmd.Parameters.Clear(); | 311 | cmd.Parameters.Clear(); |
@@ -319,7 +319,7 @@ namespace OpenSim.Data.SQLite | |||
319 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); | 319 | SqliteCommand cmd = (SqliteCommand)m_connection.CreateCommand(); |
320 | 320 | ||
321 | cmd.CommandText = "select uuid from "+table+" where EstateID = :EstateID"; | 321 | cmd.CommandText = "select uuid from "+table+" where EstateID = :EstateID"; |
322 | cmd.Parameters.Add(":EstateID", EstateID); | 322 | cmd.Parameters.AddWithValue(":EstateID", EstateID); |
323 | 323 | ||
324 | IDataReader r = cmd.ExecuteReader(); | 324 | IDataReader r = cmd.ExecuteReader(); |
325 | 325 | ||
@@ -337,4 +337,4 @@ namespace OpenSim.Data.SQLite | |||
337 | return uuids.ToArray(); | 337 | return uuids.ToArray(); |
338 | } | 338 | } |
339 | } | 339 | } |
340 | } | 340 | } \ No newline at end of file |
diff --git a/OpenSim/Data/SQLite/SQLiteFramework.cs b/OpenSim/Data/SQLite/SQLiteFramework.cs index 12b2750..9567727 100644 --- a/OpenSim/Data/SQLite/SQLiteFramework.cs +++ b/OpenSim/Data/SQLite/SQLiteFramework.cs | |||
@@ -31,7 +31,7 @@ using System.Collections.Generic; | |||
31 | using System.Data; | 31 | using System.Data; |
32 | using OpenMetaverse; | 32 | using OpenMetaverse; |
33 | using OpenSim.Framework; | 33 | using OpenSim.Framework; |
34 | using Mono.Data.SqliteClient; | 34 | using Mono.Data.Sqlite; |
35 | 35 | ||
36 | namespace OpenSim.Data.SQLite | 36 | namespace OpenSim.Data.SQLite |
37 | { | 37 | { |
@@ -65,12 +65,18 @@ namespace OpenSim.Data.SQLite | |||
65 | 65 | ||
66 | protected IDataReader ExecuteReader(SqliteCommand cmd) | 66 | protected IDataReader ExecuteReader(SqliteCommand cmd) |
67 | { | 67 | { |
68 | SqliteConnection newConnection = | 68 | lock (m_Connection) |
69 | (SqliteConnection)((ICloneable)m_Connection).Clone(); | 69 | { |
70 | newConnection.Open(); | 70 | //SqliteConnection newConnection = |
71 | // (SqliteConnection)((ICloneable)connection).Clone(); | ||
72 | //newConnection.Open(); | ||
71 | 73 | ||
72 | cmd.Connection = newConnection; | 74 | //cmd.Connection = newConnection; |
73 | return cmd.ExecuteReader(); | 75 | cmd.Connection = m_Connection; |
76 | //Console.WriteLine("XXX " + cmd.CommandText); | ||
77 | |||
78 | return cmd.ExecuteReader(); | ||
79 | } | ||
74 | } | 80 | } |
75 | 81 | ||
76 | protected void CloseReaderCommand(SqliteCommand cmd) | 82 | protected void CloseReaderCommand(SqliteCommand cmd) |
@@ -80,4 +86,4 @@ namespace OpenSim.Data.SQLite | |||
80 | cmd.Dispose(); | 86 | cmd.Dispose(); |
81 | } | 87 | } |
82 | } | 88 | } |
83 | } | 89 | } \ No newline at end of file |
diff --git a/OpenSim/Data/SQLite/SQLiteGenericTableHandler.cs b/OpenSim/Data/SQLite/SQLiteGenericTableHandler.cs index 8e91693..86eaca1 100644 --- a/OpenSim/Data/SQLite/SQLiteGenericTableHandler.cs +++ b/OpenSim/Data/SQLite/SQLiteGenericTableHandler.cs | |||
@@ -30,7 +30,7 @@ using System.Collections.Generic; | |||
30 | using System.Data; | 30 | using System.Data; |
31 | using System.Reflection; | 31 | using System.Reflection; |
32 | using log4net; | 32 | using log4net; |
33 | using Mono.Data.SqliteClient; | 33 | using Mono.Data.Sqlite; |
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | using OpenSim.Framework; | 35 | using OpenSim.Framework; |
36 | using OpenSim.Region.Framework.Interfaces; | 36 | using OpenSim.Region.Framework.Interfaces; |
@@ -54,10 +54,23 @@ namespace OpenSim.Data.SQLite | |||
54 | m_Realm = realm; | 54 | m_Realm = realm; |
55 | if (storeName != String.Empty) | 55 | if (storeName != String.Empty) |
56 | { | 56 | { |
57 | Assembly assem = GetType().Assembly; | 57 | m_Connection = new SqliteConnection(connectionString); |
58 | //Console.WriteLine(string.Format("OPENING CONNECTION FOR {0} USING {1}", storeName, connectionString)); | ||
59 | m_Connection.Open(); | ||
58 | 60 | ||
59 | Migration m = new Migration(m_Connection, assem, storeName); | 61 | if (storeName != String.Empty) |
60 | m.Update(); | 62 | { |
63 | Assembly assem = GetType().Assembly; | ||
64 | //SqliteConnection newConnection = | ||
65 | // (SqliteConnection)((ICloneable)m_Connection).Clone(); | ||
66 | //newConnection.Open(); | ||
67 | |||
68 | //Migration m = new Migration(newConnection, assem, storeName); | ||
69 | Migration m = new Migration(m_Connection, assem, storeName); | ||
70 | m.Update(); | ||
71 | //newConnection.Close(); | ||
72 | //newConnection.Dispose(); | ||
73 | } | ||
61 | } | 74 | } |
62 | 75 | ||
63 | Type t = typeof(T); | 76 | Type t = typeof(T); |
@@ -180,7 +193,7 @@ namespace OpenSim.Data.SQLite | |||
180 | result.Add(row); | 193 | result.Add(row); |
181 | } | 194 | } |
182 | 195 | ||
183 | CloseReaderCommand(cmd); | 196 | //CloseCommand(cmd); |
184 | 197 | ||
185 | return result.ToArray(); | 198 | return result.ToArray(); |
186 | } | 199 | } |
diff --git a/OpenSim/Data/SQLite/SQLiteInventoryStore.cs b/OpenSim/Data/SQLite/SQLiteInventoryStore.cs index 64591fd..9ce21b1 100644 --- a/OpenSim/Data/SQLite/SQLiteInventoryStore.cs +++ b/OpenSim/Data/SQLite/SQLiteInventoryStore.cs | |||
@@ -30,7 +30,7 @@ using System.Collections.Generic; | |||
30 | using System.Data; | 30 | using System.Data; |
31 | using System.Reflection; | 31 | using System.Reflection; |
32 | using log4net; | 32 | using log4net; |
33 | using Mono.Data.SqliteClient; | 33 | using Mono.Data.Sqlite; |
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | using OpenSim.Framework; | 35 | using OpenSim.Framework; |
36 | 36 | ||
@@ -88,15 +88,17 @@ namespace OpenSim.Data.SQLite | |||
88 | invFoldersDa = new SqliteDataAdapter(foldersSelectCmd); | 88 | invFoldersDa = new SqliteDataAdapter(foldersSelectCmd); |
89 | 89 | ||
90 | ds = new DataSet(); | 90 | ds = new DataSet(); |
91 | 91 | ||
92 | ds.Tables.Add(createInventoryFoldersTable()); | 92 | ds.Tables.Add(createInventoryFoldersTable()); |
93 | invFoldersDa.Fill(ds.Tables["inventoryfolders"]); | 93 | invFoldersDa.Fill(ds.Tables["inventoryfolders"]); |
94 | setupFoldersCommands(invFoldersDa, conn); | 94 | setupFoldersCommands(invFoldersDa, conn); |
95 | CreateDataSetMapping(invFoldersDa, "inventoryfolders"); | ||
95 | m_log.Info("[INVENTORY DB]: Populated Inventory Folders Definitions"); | 96 | m_log.Info("[INVENTORY DB]: Populated Inventory Folders Definitions"); |
96 | 97 | ||
97 | ds.Tables.Add(createInventoryItemsTable()); | 98 | ds.Tables.Add(createInventoryItemsTable()); |
98 | invItemsDa.Fill(ds.Tables["inventoryitems"]); | 99 | invItemsDa.Fill(ds.Tables["inventoryitems"]); |
99 | setupItemsCommands(invItemsDa, conn); | 100 | setupItemsCommands(invItemsDa, conn); |
101 | CreateDataSetMapping(invItemsDa, "inventoryitems"); | ||
100 | m_log.Info("[INVENTORY DB]: Populated Inventory Items Definitions"); | 102 | m_log.Info("[INVENTORY DB]: Populated Inventory Items Definitions"); |
101 | 103 | ||
102 | ds.AcceptChanges(); | 104 | ds.AcceptChanges(); |
@@ -721,6 +723,15 @@ namespace OpenSim.Data.SQLite | |||
721 | * | 723 | * |
722 | **********************************************************************/ | 724 | **********************************************************************/ |
723 | 725 | ||
726 | protected void CreateDataSetMapping(IDataAdapter da, string tableName) | ||
727 | { | ||
728 | ITableMapping dbMapping = da.TableMappings.Add(tableName, tableName); | ||
729 | foreach (DataColumn col in ds.Tables[tableName].Columns) | ||
730 | { | ||
731 | dbMapping.ColumnMappings.Add(col.ColumnName, col.ColumnName); | ||
732 | } | ||
733 | } | ||
734 | |||
724 | /// <summary> | 735 | /// <summary> |
725 | /// Create the "inventoryitems" table | 736 | /// Create the "inventoryitems" table |
726 | /// </summary> | 737 | /// </summary> |
diff --git a/OpenSim/Data/SQLite/SQLiteManager.cs b/OpenSim/Data/SQLite/SQLiteManager.cs index b6d4a1c..7dcd323 100644 --- a/OpenSim/Data/SQLite/SQLiteManager.cs +++ b/OpenSim/Data/SQLite/SQLiteManager.cs | |||
@@ -28,9 +28,9 @@ | |||
28 | using System; | 28 | using System; |
29 | using System.Collections.Generic; | 29 | using System.Collections.Generic; |
30 | using System.Data; | 30 | using System.Data; |
31 | using System.Data.SQLite; | ||
32 | using System.Reflection; | 31 | using System.Reflection; |
33 | using log4net; | 32 | using log4net; |
33 | using Mono.Data.Sqlite; | ||
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | 35 | ||
36 | namespace OpenSim.Data.SQLite | 36 | namespace OpenSim.Data.SQLite |
@@ -66,7 +66,7 @@ namespace OpenSim.Data.SQLite | |||
66 | connectionString = "URI=file:GridServerSqlite.db;"; | 66 | connectionString = "URI=file:GridServerSqlite.db;"; |
67 | } | 67 | } |
68 | 68 | ||
69 | dbcon = new SQLiteConnection(connectionString); | 69 | dbcon = new SqliteConnection(connectionString); |
70 | 70 | ||
71 | dbcon.Open(); | 71 | dbcon.Open(); |
72 | } | 72 | } |
@@ -93,11 +93,11 @@ namespace OpenSim.Data.SQLite | |||
93 | /// <returns>A SQLite DB Command</returns> | 93 | /// <returns>A SQLite DB Command</returns> |
94 | public IDbCommand Query(string sql, Dictionary<string, string> parameters) | 94 | public IDbCommand Query(string sql, Dictionary<string, string> parameters) |
95 | { | 95 | { |
96 | SQLiteCommand dbcommand = (SQLiteCommand) dbcon.CreateCommand(); | 96 | SqliteCommand dbcommand = (SqliteCommand) dbcon.CreateCommand(); |
97 | dbcommand.CommandText = sql; | 97 | dbcommand.CommandText = sql; |
98 | foreach (KeyValuePair<string, string> param in parameters) | 98 | foreach (KeyValuePair<string, string> param in parameters) |
99 | { | 99 | { |
100 | SQLiteParameter paramx = new SQLiteParameter(param.Key, param.Value); | 100 | SqliteParameter paramx = new SqliteParameter(param.Key, param.Value); |
101 | dbcommand.Parameters.Add(paramx); | 101 | dbcommand.Parameters.Add(paramx); |
102 | } | 102 | } |
103 | 103 | ||
diff --git a/OpenSim/Data/SQLite/SQLiteRegionData.cs b/OpenSim/Data/SQLite/SQLiteRegionData.cs index 5a4ee2a..4313db8 100644 --- a/OpenSim/Data/SQLite/SQLiteRegionData.cs +++ b/OpenSim/Data/SQLite/SQLiteRegionData.cs | |||
@@ -32,7 +32,7 @@ using System.Drawing; | |||
32 | using System.IO; | 32 | using System.IO; |
33 | using System.Reflection; | 33 | using System.Reflection; |
34 | using log4net; | 34 | using log4net; |
35 | using Mono.Data.SqliteClient; | 35 | using Mono.Data.Sqlite; |
36 | using OpenMetaverse; | 36 | using OpenMetaverse; |
37 | using OpenSim.Framework; | 37 | using OpenSim.Framework; |
38 | using OpenSim.Region.Framework.Interfaces; | 38 | using OpenSim.Region.Framework.Interfaces; |
@@ -87,119 +87,151 @@ namespace OpenSim.Data.SQLite | |||
87 | /// <param name="connectionString">the connection string</param> | 87 | /// <param name="connectionString">the connection string</param> |
88 | public void Initialise(string connectionString) | 88 | public void Initialise(string connectionString) |
89 | { | 89 | { |
90 | m_connectionString = connectionString; | 90 | try |
91 | { | ||
92 | m_connectionString = connectionString; | ||
91 | 93 | ||
92 | ds = new DataSet(); | 94 | ds = new DataSet("Region"); |
93 | 95 | ||
94 | m_log.Info("[REGION DB]: Sqlite - connecting: " + connectionString); | 96 | m_log.Info("[SQLITE REGION DB]: Sqlite - connecting: " + connectionString); |
95 | m_conn = new SqliteConnection(m_connectionString); | 97 | m_conn = new SqliteConnection(m_connectionString); |
96 | m_conn.Open(); | 98 | m_conn.Open(); |
97 | 99 | ||
100 | SqliteCommand primSelectCmd = new SqliteCommand(primSelect, m_conn); | ||
101 | primDa = new SqliteDataAdapter(primSelectCmd); | ||
98 | 102 | ||
103 | SqliteCommand shapeSelectCmd = new SqliteCommand(shapeSelect, m_conn); | ||
104 | shapeDa = new SqliteDataAdapter(shapeSelectCmd); | ||
105 | // SqliteCommandBuilder shapeCb = new SqliteCommandBuilder(shapeDa); | ||
99 | 106 | ||
100 | SqliteCommand primSelectCmd = new SqliteCommand(primSelect, m_conn); | 107 | SqliteCommand itemsSelectCmd = new SqliteCommand(itemsSelect, m_conn); |
101 | primDa = new SqliteDataAdapter(primSelectCmd); | 108 | itemsDa = new SqliteDataAdapter(itemsSelectCmd); |
102 | // SqliteCommandBuilder primCb = new SqliteCommandBuilder(primDa); | ||
103 | 109 | ||
104 | SqliteCommand shapeSelectCmd = new SqliteCommand(shapeSelect, m_conn); | 110 | SqliteCommand terrainSelectCmd = new SqliteCommand(terrainSelect, m_conn); |
105 | shapeDa = new SqliteDataAdapter(shapeSelectCmd); | 111 | terrainDa = new SqliteDataAdapter(terrainSelectCmd); |
106 | // SqliteCommandBuilder shapeCb = new SqliteCommandBuilder(shapeDa); | ||
107 | 112 | ||
108 | SqliteCommand itemsSelectCmd = new SqliteCommand(itemsSelect, m_conn); | 113 | SqliteCommand landSelectCmd = new SqliteCommand(landSelect, m_conn); |
109 | itemsDa = new SqliteDataAdapter(itemsSelectCmd); | 114 | landDa = new SqliteDataAdapter(landSelectCmd); |
110 | 115 | ||
111 | SqliteCommand terrainSelectCmd = new SqliteCommand(terrainSelect, m_conn); | 116 | SqliteCommand landAccessListSelectCmd = new SqliteCommand(landAccessListSelect, m_conn); |
112 | terrainDa = new SqliteDataAdapter(terrainSelectCmd); | 117 | landAccessListDa = new SqliteDataAdapter(landAccessListSelectCmd); |
113 | 118 | ||
114 | SqliteCommand landSelectCmd = new SqliteCommand(landSelect, m_conn); | 119 | SqliteCommand regionSettingsSelectCmd = new SqliteCommand(regionSettingsSelect, m_conn); |
115 | landDa = new SqliteDataAdapter(landSelectCmd); | 120 | regionSettingsDa = new SqliteDataAdapter(regionSettingsSelectCmd); |
121 | // This actually does the roll forward assembly stuff | ||
122 | Assembly assem = GetType().Assembly; | ||
123 | Migration m = new Migration(m_conn, assem, "RegionStore"); | ||
124 | m.Update(); | ||
116 | 125 | ||
117 | SqliteCommand landAccessListSelectCmd = new SqliteCommand(landAccessListSelect, m_conn); | 126 | lock (ds) |
118 | landAccessListDa = new SqliteDataAdapter(landAccessListSelectCmd); | 127 | { |
128 | ds.Tables.Add(createPrimTable()); | ||
129 | setupPrimCommands(primDa, m_conn); | ||
119 | 130 | ||
120 | SqliteCommand regionSettingsSelectCmd = new SqliteCommand(regionSettingsSelect, m_conn); | 131 | ds.Tables.Add(createShapeTable()); |
121 | regionSettingsDa = new SqliteDataAdapter(regionSettingsSelectCmd); | 132 | setupShapeCommands(shapeDa, m_conn); |
122 | // This actually does the roll forward assembly stuff | ||
123 | Assembly assem = GetType().Assembly; | ||
124 | Migration m = new Migration(m_conn, assem, "RegionStore"); | ||
125 | m.Update(); | ||
126 | 133 | ||
127 | lock (ds) | 134 | ds.Tables.Add(createItemsTable()); |
128 | { | 135 | setupItemsCommands(itemsDa, m_conn); |
129 | ds.Tables.Add(createPrimTable()); | ||
130 | setupPrimCommands(primDa, m_conn); | ||
131 | primDa.Fill(ds.Tables["prims"]); | ||
132 | 136 | ||
133 | ds.Tables.Add(createShapeTable()); | 137 | ds.Tables.Add(createTerrainTable()); |
134 | setupShapeCommands(shapeDa, m_conn); | 138 | setupTerrainCommands(terrainDa, m_conn); |
135 | 139 | ||
136 | ds.Tables.Add(createItemsTable()); | 140 | ds.Tables.Add(createLandTable()); |
137 | setupItemsCommands(itemsDa, m_conn); | 141 | setupLandCommands(landDa, m_conn); |
138 | itemsDa.Fill(ds.Tables["primitems"]); | ||
139 | 142 | ||
140 | ds.Tables.Add(createTerrainTable()); | 143 | ds.Tables.Add(createLandAccessListTable()); |
141 | setupTerrainCommands(terrainDa, m_conn); | 144 | setupLandAccessCommands(landAccessListDa, m_conn); |
142 | 145 | ||
143 | ds.Tables.Add(createLandTable()); | 146 | ds.Tables.Add(createRegionSettingsTable()); |
144 | setupLandCommands(landDa, m_conn); | 147 | setupRegionSettingsCommands(regionSettingsDa, m_conn); |
145 | 148 | ||
146 | ds.Tables.Add(createLandAccessListTable()); | 149 | // WORKAROUND: This is a work around for sqlite on |
147 | setupLandAccessCommands(landAccessListDa, m_conn); | 150 | // windows, which gets really unhappy with blob columns |
151 | // that have no sample data in them. At some point we | ||
152 | // need to actually find a proper way to handle this. | ||
153 | try | ||
154 | { | ||
155 | primDa.Fill(ds.Tables["prims"]); | ||
156 | } | ||
157 | catch (Exception) | ||
158 | { | ||
159 | m_log.Info("[SQLITE REGION DB]: Caught fill error on prims table"); | ||
160 | } | ||
148 | 161 | ||
149 | ds.Tables.Add(createRegionSettingsTable()); | 162 | try |
150 | 163 | { | |
151 | setupRegionSettingsCommands(regionSettingsDa, m_conn); | 164 | shapeDa.Fill(ds.Tables["primshapes"]); |
165 | } | ||
166 | catch (Exception) | ||
167 | { | ||
168 | m_log.Info("[SQLITE REGION DB]: Caught fill error on primshapes table"); | ||
169 | } | ||
152 | 170 | ||
153 | // WORKAROUND: This is a work around for sqlite on | 171 | try |
154 | // windows, which gets really unhappy with blob columns | 172 | { |
155 | // that have no sample data in them. At some point we | 173 | itemsDa.Fill(ds.Tables["primitems"]); |
156 | // need to actually find a proper way to handle this. | 174 | } |
157 | try | 175 | catch (Exception) |
158 | { | 176 | { |
159 | shapeDa.Fill(ds.Tables["primshapes"]); | 177 | m_log.Info("[SQLITE REGION DB]: Caught fill error on primitems table"); |
160 | } | 178 | } |
161 | catch (Exception) | 179 | |
162 | { | 180 | try |
163 | m_log.Info("[REGION DB]: Caught fill error on primshapes table"); | 181 | { |
164 | } | 182 | terrainDa.Fill(ds.Tables["terrain"]); |
183 | } | ||
184 | catch (Exception) | ||
185 | { | ||
186 | m_log.Info("[SQLITE REGION DB]: Caught fill error on terrain table"); | ||
187 | } | ||
165 | 188 | ||
166 | try | 189 | try |
167 | { | 190 | { |
168 | terrainDa.Fill(ds.Tables["terrain"]); | 191 | landDa.Fill(ds.Tables["land"]); |
169 | } | 192 | } |
170 | catch (Exception) | 193 | catch (Exception) |
171 | { | 194 | { |
172 | m_log.Info("[REGION DB]: Caught fill error on terrain table"); | 195 | m_log.Info("[SQLITE REGION DB]: Caught fill error on land table"); |
173 | } | 196 | } |
174 | 197 | ||
175 | try | 198 | try |
176 | { | 199 | { |
177 | landDa.Fill(ds.Tables["land"]); | 200 | landAccessListDa.Fill(ds.Tables["landaccesslist"]); |
178 | } | 201 | } |
179 | catch (Exception) | 202 | catch (Exception) |
180 | { | 203 | { |
181 | m_log.Info("[REGION DB]: Caught fill error on land table"); | 204 | m_log.Info("[SQLITE REGION DB]: Caught fill error on landaccesslist table"); |
182 | } | 205 | } |
183 | 206 | ||
184 | try | 207 | try |
185 | { | 208 | { |
186 | landAccessListDa.Fill(ds.Tables["landaccesslist"]); | 209 | regionSettingsDa.Fill(ds.Tables["regionsettings"]); |
187 | } | 210 | } |
188 | catch (Exception) | 211 | catch (Exception) |
189 | { | 212 | { |
190 | m_log.Info("[REGION DB]: Caught fill error on landaccesslist table"); | 213 | m_log.Info("[SQLITE REGION DB]: Caught fill error on regionsettings table"); |
191 | } | 214 | } |
192 | 215 | ||
193 | try | 216 | // We have to create a data set mapping for every table, otherwise the IDataAdaptor.Update() will not populate rows with values! |
194 | { | 217 | // Not sure exactly why this is - this kind of thing was not necessary before - justincc 20100409 |
195 | regionSettingsDa.Fill(ds.Tables["regionsettings"]); | 218 | // Possibly because we manually set up our own DataTables before connecting to the database |
196 | } | 219 | CreateDataSetMapping(primDa, "prims"); |
197 | catch (Exception) | 220 | CreateDataSetMapping(shapeDa, "primshapes"); |
198 | { | 221 | CreateDataSetMapping(itemsDa, "primitems"); |
199 | m_log.Info("[REGION DB]: Caught fill error on regionsettings table"); | 222 | CreateDataSetMapping(terrainDa, "terrain"); |
223 | CreateDataSetMapping(landDa, "land"); | ||
224 | CreateDataSetMapping(landAccessListDa, "landaccesslist"); | ||
225 | CreateDataSetMapping(regionSettingsDa, "regionsettings"); | ||
200 | } | 226 | } |
201 | return; | ||
202 | } | 227 | } |
228 | catch (Exception e) | ||
229 | { | ||
230 | m_log.Error(e); | ||
231 | Environment.Exit(23); | ||
232 | } | ||
233 | |||
234 | return; | ||
203 | } | 235 | } |
204 | 236 | ||
205 | public void Dispose() | 237 | public void Dispose() |
@@ -402,7 +434,7 @@ namespace OpenSim.Data.SQLite | |||
402 | lock (ds) | 434 | lock (ds) |
403 | { | 435 | { |
404 | DataRow[] primsForRegion = prims.Select(byRegion); | 436 | DataRow[] primsForRegion = prims.Select(byRegion); |
405 | m_log.Info("[REGION DB]: Loaded " + primsForRegion.Length + " prims for region: " + regionUUID); | 437 | // m_log.Info("[SQLITE REGION DB]: Loaded " + primsForRegion.Length + " prims for region: " + regionUUID); |
406 | 438 | ||
407 | // First, create all groups | 439 | // First, create all groups |
408 | foreach (DataRow primRow in primsForRegion) | 440 | foreach (DataRow primRow in primsForRegion) |
@@ -424,8 +456,8 @@ namespace OpenSim.Data.SQLite | |||
424 | } | 456 | } |
425 | else | 457 | else |
426 | { | 458 | { |
427 | m_log.Info( | 459 | m_log.Warn( |
428 | "[REGION DB]: No shape found for prim in storage, so setting default box shape"); | 460 | "[SQLITE REGION DB]: No shape found for prim in storage, so setting default box shape"); |
429 | prim.Shape = PrimitiveBaseShape.Default; | 461 | prim.Shape = PrimitiveBaseShape.Default; |
430 | } | 462 | } |
431 | 463 | ||
@@ -437,11 +469,11 @@ namespace OpenSim.Data.SQLite | |||
437 | } | 469 | } |
438 | catch (Exception e) | 470 | catch (Exception e) |
439 | { | 471 | { |
440 | m_log.Error("[REGION DB]: Failed create prim object in new group, exception and data follows"); | 472 | m_log.Error("[SQLITE REGION DB]: Failed create prim object in new group, exception and data follows"); |
441 | m_log.Info("[REGION DB]: " + e.ToString()); | 473 | m_log.Error("[SQLITE REGION DB]: ", e); |
442 | foreach (DataColumn col in prims.Columns) | 474 | foreach (DataColumn col in prims.Columns) |
443 | { | 475 | { |
444 | m_log.Info("[REGION DB]: Col: " + col.ColumnName + " => " + primRow[col]); | 476 | m_log.Error("[SQLITE REGION DB]: Col: " + col.ColumnName + " => " + primRow[col]); |
445 | } | 477 | } |
446 | } | 478 | } |
447 | } | 479 | } |
@@ -466,7 +498,7 @@ namespace OpenSim.Data.SQLite | |||
466 | else | 498 | else |
467 | { | 499 | { |
468 | m_log.Warn( | 500 | m_log.Warn( |
469 | "[REGION DB]: No shape found for prim in storage, so setting default box shape"); | 501 | "[SQLITE REGION DB]: No shape found for prim in storage, so setting default box shape"); |
470 | prim.Shape = PrimitiveBaseShape.Default; | 502 | prim.Shape = PrimitiveBaseShape.Default; |
471 | } | 503 | } |
472 | 504 | ||
@@ -476,11 +508,11 @@ namespace OpenSim.Data.SQLite | |||
476 | } | 508 | } |
477 | catch (Exception e) | 509 | catch (Exception e) |
478 | { | 510 | { |
479 | m_log.Error("[REGION DB]: Failed create prim object in group, exception and data follows"); | 511 | m_log.Error("[SQLITE REGION DB]: Failed create prim object in group, exception and data follows"); |
480 | m_log.Info("[REGION DB]: " + e.ToString()); | 512 | m_log.Error("[SQLITE REGION DB]: ", e); |
481 | foreach (DataColumn col in prims.Columns) | 513 | foreach (DataColumn col in prims.Columns) |
482 | { | 514 | { |
483 | m_log.Info("[REGION DB]: Col: " + col.ColumnName + " => " + primRow[col]); | 515 | m_log.Error("[SQLITE REGION DB]: Col: " + col.ColumnName + " => " + primRow[col]); |
484 | } | 516 | } |
485 | } | 517 | } |
486 | } | 518 | } |
@@ -493,20 +525,23 @@ namespace OpenSim.Data.SQLite | |||
493 | /// </summary> | 525 | /// </summary> |
494 | /// <param name="prim">the prim</param> | 526 | /// <param name="prim">the prim</param> |
495 | private void LoadItems(SceneObjectPart prim) | 527 | private void LoadItems(SceneObjectPart prim) |
496 | { | 528 | { |
497 | //m_log.DebugFormat("[DATASTORE]: Loading inventory for {0}, {1}", prim.Name, prim.UUID); | 529 | // m_log.DebugFormat("[SQLITE REGION DB]: Loading inventory for {0} {1}", prim.Name, prim.UUID); |
498 | 530 | ||
499 | DataTable dbItems = ds.Tables["primitems"]; | 531 | DataTable dbItems = ds.Tables["primitems"]; |
500 | String sql = String.Format("primID = '{0}'", prim.UUID.ToString()); | 532 | String sql = String.Format("primID = '{0}'", prim.UUID.ToString()); |
501 | DataRow[] dbItemRows = dbItems.Select(sql); | 533 | DataRow[] dbItemRows = dbItems.Select(sql); |
502 | IList<TaskInventoryItem> inventory = new List<TaskInventoryItem>(); | 534 | IList<TaskInventoryItem> inventory = new List<TaskInventoryItem>(); |
503 | 535 | ||
536 | // m_log.DebugFormat( | ||
537 | // "[SQLITE REGION DB]: Found {0} items for {1} {2}", dbItemRows.Length, prim.Name, prim.UUID); | ||
538 | |||
504 | foreach (DataRow row in dbItemRows) | 539 | foreach (DataRow row in dbItemRows) |
505 | { | 540 | { |
506 | TaskInventoryItem item = buildItem(row); | 541 | TaskInventoryItem item = buildItem(row); |
507 | inventory.Add(item); | 542 | inventory.Add(item); |
508 | 543 | ||
509 | //m_log.DebugFormat("[DATASTORE]: Restored item {0}, {1}", item.Name, item.ItemID); | 544 | // m_log.DebugFormat("[SQLITE REGION DB]: Restored item {0} {1}", item.Name, item.ItemID); |
510 | } | 545 | } |
511 | 546 | ||
512 | prim.Inventory.RestoreInventoryItems(inventory); | 547 | prim.Inventory.RestoreInventoryItems(inventory); |
@@ -542,7 +577,7 @@ namespace OpenSim.Data.SQLite | |||
542 | 577 | ||
543 | // the following is an work around for .NET. The perf | 578 | // the following is an work around for .NET. The perf |
544 | // issues associated with it aren't as bad as you think. | 579 | // issues associated with it aren't as bad as you think. |
545 | m_log.Info("[REGION DB]: Storing terrain revision r" + revision.ToString()); | 580 | m_log.Debug("[SQLITE REGION DB]: Storing terrain revision r" + revision.ToString()); |
546 | String sql = "insert into terrain(RegionUUID, Revision, Heightfield)" + | 581 | String sql = "insert into terrain(RegionUUID, Revision, Heightfield)" + |
547 | " values(:RegionUUID, :Revision, :Heightfield)"; | 582 | " values(:RegionUUID, :Revision, :Heightfield)"; |
548 | 583 | ||
@@ -594,15 +629,15 @@ namespace OpenSim.Data.SQLite | |||
594 | } | 629 | } |
595 | } | 630 | } |
596 | } | 631 | } |
597 | rev = (int) row["Revision"]; | 632 | rev = Convert.ToInt32(row["Revision"]); |
598 | } | 633 | } |
599 | else | 634 | else |
600 | { | 635 | { |
601 | m_log.Info("[REGION DB]: No terrain found for region"); | 636 | m_log.Warn("[SQLITE REGION DB]: No terrain found for region"); |
602 | return null; | 637 | return null; |
603 | } | 638 | } |
604 | 639 | ||
605 | m_log.Info("[REGION DB]: Loaded terrain revision r" + rev.ToString()); | 640 | m_log.Debug("[SQLITE REGION DB]: Loaded terrain revision r" + rev.ToString()); |
606 | } | 641 | } |
607 | } | 642 | } |
608 | return terret; | 643 | return terret; |
@@ -746,6 +781,7 @@ namespace OpenSim.Data.SQLite | |||
746 | /// </summary> | 781 | /// </summary> |
747 | public void Commit() | 782 | public void Commit() |
748 | { | 783 | { |
784 | //m_log.Debug("[SQLITE]: Starting commit"); | ||
749 | lock (ds) | 785 | lock (ds) |
750 | { | 786 | { |
751 | primDa.Update(ds, "prims"); | 787 | primDa.Update(ds, "prims"); |
@@ -760,18 +796,11 @@ namespace OpenSim.Data.SQLite | |||
760 | { | 796 | { |
761 | regionSettingsDa.Update(ds, "regionsettings"); | 797 | regionSettingsDa.Update(ds, "regionsettings"); |
762 | } | 798 | } |
763 | catch (SqliteExecutionException SqlEx) | 799 | catch (SqliteException SqlEx) |
764 | { | 800 | { |
765 | if (SqlEx.Message.Contains("logic error")) | 801 | throw new Exception( |
766 | { | 802 | "There was a SQL error or connection string configuration error when saving the region settings. This could be a bug, it could also happen if ConnectionString is defined in the [DatabaseService] section of StandaloneCommon.ini in the config_include folder. This could also happen if the config_include folder doesn't exist or if the OpenSim.ini [Architecture] section isn't set. If this is your first time running OpenSimulator, please restart the simulator and bug a developer to fix this!", |
767 | throw new Exception( | 803 | SqlEx); |
768 | "There was a SQL error or connection string configuration error when saving the region settings. This could be a bug, it could also happen if ConnectionString is defined in the [DatabaseService] section of StandaloneCommon.ini in the config_include folder. This could also happen if the config_include folder doesn't exist or if the OpenSim.ini [Architecture] section isn't set. If this is your first time running OpenSimulator, please restart the simulator and bug a developer to fix this!", | ||
769 | SqlEx); | ||
770 | } | ||
771 | else | ||
772 | { | ||
773 | throw SqlEx; | ||
774 | } | ||
775 | } | 804 | } |
776 | ds.AcceptChanges(); | 805 | ds.AcceptChanges(); |
777 | } | 806 | } |
@@ -793,6 +822,15 @@ namespace OpenSim.Data.SQLite | |||
793 | * | 822 | * |
794 | **********************************************************************/ | 823 | **********************************************************************/ |
795 | 824 | ||
825 | protected void CreateDataSetMapping(IDataAdapter da, string tableName) | ||
826 | { | ||
827 | ITableMapping dbMapping = da.TableMappings.Add(tableName, tableName); | ||
828 | foreach (DataColumn col in ds.Tables[tableName].Columns) | ||
829 | { | ||
830 | dbMapping.ColumnMappings.Add(col.ColumnName, col.ColumnName); | ||
831 | } | ||
832 | } | ||
833 | |||
796 | /// <summary> | 834 | /// <summary> |
797 | /// | 835 | /// |
798 | /// </summary> | 836 | /// </summary> |
@@ -1381,7 +1419,7 @@ namespace OpenSim.Data.SQLite | |||
1381 | } | 1419 | } |
1382 | catch (InvalidCastException) | 1420 | catch (InvalidCastException) |
1383 | { | 1421 | { |
1384 | m_log.ErrorFormat("[PARCEL]: unable to get parcel telehub settings for {1}", newData.Name); | 1422 | m_log.ErrorFormat("[SQLITE REGION DB]: unable to get parcel telehub settings for {1}", newData.Name); |
1385 | newData.UserLocation = Vector3.Zero; | 1423 | newData.UserLocation = Vector3.Zero; |
1386 | newData.UserLookAt = Vector3.Zero; | 1424 | newData.UserLookAt = Vector3.Zero; |
1387 | } | 1425 | } |
@@ -1888,7 +1926,7 @@ namespace OpenSim.Data.SQLite | |||
1888 | /// <param name="items"></param> | 1926 | /// <param name="items"></param> |
1889 | public void StorePrimInventory(UUID primID, ICollection<TaskInventoryItem> items) | 1927 | public void StorePrimInventory(UUID primID, ICollection<TaskInventoryItem> items) |
1890 | { | 1928 | { |
1891 | m_log.InfoFormat("[REGION DB]: Entered StorePrimInventory with prim ID {0}", primID); | 1929 | // m_log.DebugFormat("[SQLITE REGION DB]: Entered StorePrimInventory with prim ID {0}", primID); |
1892 | 1930 | ||
1893 | DataTable dbItems = ds.Tables["primitems"]; | 1931 | DataTable dbItems = ds.Tables["primitems"]; |
1894 | 1932 | ||
@@ -1955,6 +1993,7 @@ namespace OpenSim.Data.SQLite | |||
1955 | sql += ") values (:"; | 1993 | sql += ") values (:"; |
1956 | sql += String.Join(", :", cols); | 1994 | sql += String.Join(", :", cols); |
1957 | sql += ")"; | 1995 | sql += ")"; |
1996 | //m_log.DebugFormat("[SQLITE]: Created insert command {0}", sql); | ||
1958 | SqliteCommand cmd = new SqliteCommand(sql); | 1997 | SqliteCommand cmd = new SqliteCommand(sql); |
1959 | 1998 | ||
1960 | // this provides the binding for all our parameters, so | 1999 | // this provides the binding for all our parameters, so |
@@ -2250,6 +2289,36 @@ namespace OpenSim.Data.SQLite | |||
2250 | return DbType.String; | 2289 | return DbType.String; |
2251 | } | 2290 | } |
2252 | } | 2291 | } |
2292 | |||
2293 | static void PrintDataSet(DataSet ds) | ||
2294 | { | ||
2295 | // Print out any name and extended properties. | ||
2296 | Console.WriteLine("DataSet is named: {0}", ds.DataSetName); | ||
2297 | foreach (System.Collections.DictionaryEntry de in ds.ExtendedProperties) | ||
2298 | { | ||
2299 | Console.WriteLine("Key = {0}, Value = {1}", de.Key, de.Value); | ||
2300 | } | ||
2301 | Console.WriteLine(); | ||
2302 | foreach (DataTable dt in ds.Tables) | ||
2303 | { | ||
2304 | Console.WriteLine("=> {0} Table:", dt.TableName); | ||
2305 | // Print out the column names. | ||
2306 | for (int curCol = 0; curCol < dt.Columns.Count; curCol++) | ||
2307 | { | ||
2308 | Console.Write(dt.Columns[curCol].ColumnName + "\t"); | ||
2309 | } | ||
2310 | Console.WriteLine("\n----------------------------------"); | ||
2311 | // Print the DataTable. | ||
2312 | for (int curRow = 0; curRow < dt.Rows.Count; curRow++) | ||
2313 | { | ||
2314 | for (int curCol = 0; curCol < dt.Columns.Count; curCol++) | ||
2315 | { | ||
2316 | Console.Write(dt.Rows[curRow][curCol].ToString() + "\t"); | ||
2317 | } | ||
2318 | Console.WriteLine(); | ||
2319 | } | ||
2320 | } | ||
2321 | } | ||
2253 | 2322 | ||
2254 | } | 2323 | } |
2255 | } | 2324 | } |
diff --git a/OpenSim/Data/SQLite/SQLiteUserData.cs b/OpenSim/Data/SQLite/SQLiteUserData.cs index caddcf8..ea755b0 100644 --- a/OpenSim/Data/SQLite/SQLiteUserData.cs +++ b/OpenSim/Data/SQLite/SQLiteUserData.cs | |||
@@ -30,7 +30,7 @@ using System.Collections.Generic; | |||
30 | using System.Data; | 30 | using System.Data; |
31 | using System.Reflection; | 31 | using System.Reflection; |
32 | using log4net; | 32 | using log4net; |
33 | using Mono.Data.SqliteClient; | 33 | using Mono.Data.Sqlite; |
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | using OpenSim.Framework; | 35 | using OpenSim.Framework; |
36 | 36 | ||
@@ -115,15 +115,19 @@ namespace OpenSim.Data.SQLite | |||
115 | 115 | ||
116 | setupUserCommands(da, conn); | 116 | setupUserCommands(da, conn); |
117 | da.Fill(ds.Tables["users"]); | 117 | da.Fill(ds.Tables["users"]); |
118 | CreateDataSetMapping(da, "users"); | ||
118 | 119 | ||
119 | setupAgentCommands(dua, conn); | 120 | setupAgentCommands(dua, conn); |
120 | dua.Fill(ds.Tables["useragents"]); | 121 | dua.Fill(ds.Tables["useragents"]); |
122 | CreateDataSetMapping(dua, "useragents"); | ||
121 | 123 | ||
122 | setupUserFriendsCommands(daf, conn); | 124 | setupUserFriendsCommands(daf, conn); |
123 | daf.Fill(ds.Tables["userfriends"]); | 125 | daf.Fill(ds.Tables["userfriends"]); |
126 | CreateDataSetMapping(daf, "userfriends"); | ||
124 | 127 | ||
125 | setupAvatarAppearanceCommands(daa, conn); | 128 | setupAvatarAppearanceCommands(daa, conn); |
126 | daa.Fill(ds.Tables["avatarappearance"]); | 129 | daa.Fill(ds.Tables["avatarappearance"]); |
130 | CreateDataSetMapping(daa, "avatarappearance"); | ||
127 | } | 131 | } |
128 | 132 | ||
129 | return; | 133 | return; |
@@ -706,15 +710,10 @@ namespace OpenSim.Data.SQLite | |||
706 | aa.SkirtItem = new UUID((String)row["SkirtItem"]); | 710 | aa.SkirtItem = new UUID((String)row["SkirtItem"]); |
707 | aa.SkirtAsset = new UUID((String)row["SkirtAsset"]); | 711 | aa.SkirtAsset = new UUID((String)row["SkirtAsset"]); |
708 | 712 | ||
709 | // Ewe Loon | 713 | byte[] texture = (byte[])row["Texture"]; |
710 | // Used Base64String because for some reason it wont accept using Byte[] (which works in Region date) | ||
711 | |||
712 | String str = (String)row["Texture"]; | ||
713 | byte[] texture = Convert.FromBase64String(str); | ||
714 | aa.Texture = new Primitive.TextureEntry(texture, 0, texture.Length); | 714 | aa.Texture = new Primitive.TextureEntry(texture, 0, texture.Length); |
715 | 715 | ||
716 | str = (String)row["VisualParams"]; | 716 | byte[] VisualParams = (byte[])row["VisualParams"]; |
717 | byte[] VisualParams = Convert.FromBase64String(str); | ||
718 | aa.VisualParams = VisualParams; | 717 | aa.VisualParams = VisualParams; |
719 | 718 | ||
720 | aa.Serial = Convert.ToInt32(row["Serial"]); | 719 | aa.Serial = Convert.ToInt32(row["Serial"]); |
@@ -793,6 +792,15 @@ namespace OpenSim.Data.SQLite | |||
793 | * | 792 | * |
794 | **********************************************************************/ | 793 | **********************************************************************/ |
795 | 794 | ||
795 | protected void CreateDataSetMapping(IDataAdapter da, string tableName) | ||
796 | { | ||
797 | ITableMapping dbMapping = da.TableMappings.Add(tableName, tableName); | ||
798 | foreach (DataColumn col in ds.Tables[tableName].Columns) | ||
799 | { | ||
800 | dbMapping.ColumnMappings.Add(col.ColumnName, col.ColumnName); | ||
801 | } | ||
802 | } | ||
803 | |||
796 | /// <summary> | 804 | /// <summary> |
797 | /// Create the "users" table | 805 | /// Create the "users" table |
798 | /// </summary> | 806 | /// </summary> |
@@ -924,9 +932,8 @@ namespace OpenSim.Data.SQLite | |||
924 | SQLiteUtil.createCol(aa, "SkirtItem", typeof(String)); | 932 | SQLiteUtil.createCol(aa, "SkirtItem", typeof(String)); |
925 | SQLiteUtil.createCol(aa, "SkirtAsset", typeof(String)); | 933 | SQLiteUtil.createCol(aa, "SkirtAsset", typeof(String)); |
926 | 934 | ||
927 | // Used Base64String because for some reason it wont accept using Byte[] (which works in Region date) | 935 | SQLiteUtil.createCol(aa, "Texture", typeof (Byte[])); |
928 | SQLiteUtil.createCol(aa, "Texture", typeof (String)); | 936 | SQLiteUtil.createCol(aa, "VisualParams", typeof (Byte[])); |
929 | SQLiteUtil.createCol(aa, "VisualParams", typeof (String)); | ||
930 | 937 | ||
931 | SQLiteUtil.createCol(aa, "Serial", typeof(Int32)); | 938 | SQLiteUtil.createCol(aa, "Serial", typeof(Int32)); |
932 | SQLiteUtil.createCol(aa, "AvatarHeight", typeof(Double)); | 939 | SQLiteUtil.createCol(aa, "AvatarHeight", typeof(Double)); |
@@ -1090,8 +1097,8 @@ namespace OpenSim.Data.SQLite | |||
1090 | row["SkirtAsset"] = appearance.SkirtAsset.ToString(); | 1097 | row["SkirtAsset"] = appearance.SkirtAsset.ToString(); |
1091 | 1098 | ||
1092 | // Used Base64String because for some reason it wont accept using Byte[] (which works in Region date) | 1099 | // Used Base64String because for some reason it wont accept using Byte[] (which works in Region date) |
1093 | row["Texture"] = Convert.ToBase64String(appearance.Texture.GetBytes()); | 1100 | row["Texture"] = appearance.Texture.GetBytes(); |
1094 | row["VisualParams"] = Convert.ToBase64String(appearance.VisualParams); | 1101 | row["VisualParams"] = appearance.VisualParams; |
1095 | 1102 | ||
1096 | row["Serial"] = appearance.Serial; | 1103 | row["Serial"] = appearance.Serial; |
1097 | row["AvatarHeight"] = appearance.AvatarHeight; | 1104 | row["AvatarHeight"] = appearance.AvatarHeight; |
diff --git a/OpenSim/Data/SQLite/SQLiteUtils.cs b/OpenSim/Data/SQLite/SQLiteUtils.cs index 4a835ce..07c6b69 100644 --- a/OpenSim/Data/SQLite/SQLiteUtils.cs +++ b/OpenSim/Data/SQLite/SQLiteUtils.cs | |||
@@ -27,7 +27,7 @@ | |||
27 | 27 | ||
28 | using System; | 28 | using System; |
29 | using System.Data; | 29 | using System.Data; |
30 | using Mono.Data.SqliteClient; | 30 | using Mono.Data.Sqlite; |
31 | 31 | ||
32 | namespace OpenSim.Data.SQLite | 32 | namespace OpenSim.Data.SQLite |
33 | { | 33 | { |
diff --git a/OpenSim/Data/SQLite/SQLiteXInventoryData.cs b/OpenSim/Data/SQLite/SQLiteXInventoryData.cs index 5c93f88..0d211b6 100644 --- a/OpenSim/Data/SQLite/SQLiteXInventoryData.cs +++ b/OpenSim/Data/SQLite/SQLiteXInventoryData.cs | |||
@@ -29,7 +29,7 @@ using System; | |||
29 | using System.Data; | 29 | using System.Data; |
30 | using System.Reflection; | 30 | using System.Reflection; |
31 | using System.Collections.Generic; | 31 | using System.Collections.Generic; |
32 | using Mono.Data.SqliteClient; | 32 | using Mono.Data.Sqlite; |
33 | using log4net; | 33 | using log4net; |
34 | using OpenMetaverse; | 34 | using OpenMetaverse; |
35 | using OpenSim.Framework; | 35 | using OpenSim.Framework; |
@@ -147,8 +147,8 @@ namespace OpenSim.Data.SQLite | |||
147 | } | 147 | } |
148 | 148 | ||
149 | reader.Close(); | 149 | reader.Close(); |
150 | CloseReaderCommand(cmd); | 150 | |
151 | 151 | //CloseCommand(cmd); | |
152 | return perms; | 152 | return perms; |
153 | } | 153 | } |
154 | } | 154 | } |