diff options
author | Sean Dague | 2008-04-02 15:24:31 +0000 |
---|---|---|
committer | Sean Dague | 2008-04-02 15:24:31 +0000 |
commit | c52c68f314c67c76c7181a6d0828f476290fbd66 (patch) | |
tree | 66ab347502892902a096fa985f31b25738eb1381 /OpenSim/Data/MSSQL/MSSQLInventoryData.cs | |
parent | reorganizing namespaces to put all the Data stuff into it's own namespace (diff) | |
download | opensim-SC_OLD-c52c68f314c67c76c7181a6d0828f476290fbd66.zip opensim-SC_OLD-c52c68f314c67c76c7181a6d0828f476290fbd66.tar.gz opensim-SC_OLD-c52c68f314c67c76c7181a6d0828f476290fbd66.tar.bz2 opensim-SC_OLD-c52c68f314c67c76c7181a6d0828f476290fbd66.tar.xz |
whole lot more moving
Diffstat (limited to 'OpenSim/Data/MSSQL/MSSQLInventoryData.cs')
-rw-r--r-- | OpenSim/Data/MSSQL/MSSQLInventoryData.cs | 728 |
1 files changed, 728 insertions, 0 deletions
diff --git a/OpenSim/Data/MSSQL/MSSQLInventoryData.cs b/OpenSim/Data/MSSQL/MSSQLInventoryData.cs new file mode 100644 index 0000000..1e99e51 --- /dev/null +++ b/OpenSim/Data/MSSQL/MSSQLInventoryData.cs | |||
@@ -0,0 +1,728 @@ | |||
1 | /* | ||
2 | * Copyright (c) Contributors, http://opensimulator.org/ | ||
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
4 | * | ||
5 | * Redistribution and use in source and binary forms, with or without | ||
6 | * modification, are permitted provided that the following conditions are met: | ||
7 | * * Redistributions of source code must retain the above copyright | ||
8 | * notice, this list of conditions and the following disclaimer. | ||
9 | * * Redistributions in binary form must reproduce the above copyright | ||
10 | * notice, this list of conditions and the following disclaimer in the | ||
11 | * documentation and/or other materials provided with the distribution. | ||
12 | * * Neither the name of the OpenSim Project nor the | ||
13 | * names of its contributors may be used to endorse or promote products | ||
14 | * derived from this software without specific prior written permission. | ||
15 | * | ||
16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | ||
17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | ||
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | ||
19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | ||
20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | ||
21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | ||
22 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | ||
23 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
24 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | ||
25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
26 | */ | ||
27 | |||
28 | using System; | ||
29 | using System.Collections.Generic; | ||
30 | using System.Data; | ||
31 | using System.Data.SqlClient; | ||
32 | using libsecondlife; | ||
33 | using OpenSim.Framework.Console; | ||
34 | |||
35 | namespace OpenSim.Framework.Data.MSSQL | ||
36 | { | ||
37 | /// <summary> | ||
38 | /// A MySQL interface for the inventory server | ||
39 | /// </summary> | ||
40 | public class MSSQLInventoryData : IInventoryData | ||
41 | { | ||
42 | private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); | ||
43 | |||
44 | /// <summary> | ||
45 | /// The database manager | ||
46 | /// </summary> | ||
47 | private MSSQLManager database; | ||
48 | |||
49 | /// <summary> | ||
50 | /// Loads and initialises this database plugin | ||
51 | /// </summary> | ||
52 | public void Initialise() | ||
53 | { | ||
54 | IniFile GridDataMySqlFile = new IniFile("mssql_connection.ini"); | ||
55 | string settingDataSource = GridDataMySqlFile.ParseFileReadValue("data_source"); | ||
56 | string settingInitialCatalog = GridDataMySqlFile.ParseFileReadValue("initial_catalog"); | ||
57 | string settingPersistSecurityInfo = GridDataMySqlFile.ParseFileReadValue("persist_security_info"); | ||
58 | string settingUserId = GridDataMySqlFile.ParseFileReadValue("user_id"); | ||
59 | string settingPassword = GridDataMySqlFile.ParseFileReadValue("password"); | ||
60 | |||
61 | database = | ||
62 | new MSSQLManager(settingDataSource, settingInitialCatalog, settingPersistSecurityInfo, settingUserId, | ||
63 | settingPassword); | ||
64 | TestTables(); | ||
65 | } | ||
66 | |||
67 | #region Test and initialization code | ||
68 | |||
69 | private void UpgradeFoldersTable(string tableName) | ||
70 | { | ||
71 | // null as the version, indicates that the table didn't exist | ||
72 | if (tableName == null) | ||
73 | { | ||
74 | database.ExecuteResourceSql("CreateFoldersTable.sql"); | ||
75 | //database.ExecuteResourceSql("UpgradeFoldersTableToVersion2.sql"); | ||
76 | return; | ||
77 | } | ||
78 | } | ||
79 | |||
80 | private void UpgradeItemsTable(string tableName) | ||
81 | { | ||
82 | // null as the version, indicates that the table didn't exist | ||
83 | if (tableName == null) | ||
84 | { | ||
85 | database.ExecuteResourceSql("CreateItemsTable.sql"); | ||
86 | //database.ExecuteResourceSql("UpgradeItemsTableToVersion2.sql"); | ||
87 | return; | ||
88 | } | ||
89 | } | ||
90 | |||
91 | private void TestTables() | ||
92 | { | ||
93 | Dictionary<string, string> tableList = new Dictionary<string, string>(); | ||
94 | |||
95 | tableList["inventoryfolders"] = null; | ||
96 | tableList["inventoryitems"] = null; | ||
97 | |||
98 | database.GetTableVersion(tableList); | ||
99 | |||
100 | UpgradeFoldersTable(tableList["inventoryfolders"]); | ||
101 | UpgradeItemsTable(tableList["inventoryitems"]); | ||
102 | } | ||
103 | |||
104 | #endregion | ||
105 | |||
106 | /// <summary> | ||
107 | /// The name of this DB provider | ||
108 | /// </summary> | ||
109 | /// <returns>Name of DB provider</returns> | ||
110 | public string getName() | ||
111 | { | ||
112 | return "MSSQL Inventory Data Interface"; | ||
113 | } | ||
114 | |||
115 | /// <summary> | ||
116 | /// Closes this DB provider | ||
117 | /// </summary> | ||
118 | public void Close() | ||
119 | { | ||
120 | // Do nothing. | ||
121 | } | ||
122 | |||
123 | /// <summary> | ||
124 | /// Returns the version of this DB provider | ||
125 | /// </summary> | ||
126 | /// <returns>A string containing the DB provider</returns> | ||
127 | public string getVersion() | ||
128 | { | ||
129 | return database.getVersion(); | ||
130 | } | ||
131 | |||
132 | /// <summary> | ||
133 | /// Returns a list of items in a specified folder | ||
134 | /// </summary> | ||
135 | /// <param name="folderID">The folder to search</param> | ||
136 | /// <returns>A list containing inventory items</returns> | ||
137 | public List<InventoryItemBase> getInventoryInFolder(LLUUID folderID) | ||
138 | { | ||
139 | try | ||
140 | { | ||
141 | lock (database) | ||
142 | { | ||
143 | List<InventoryItemBase> items = new List<InventoryItemBase>(); | ||
144 | |||
145 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
146 | param["parentFolderID"] = folderID.ToString(); | ||
147 | |||
148 | IDbCommand result = | ||
149 | database.Query("SELECT * FROM inventoryitems WHERE parentFolderID = @parentFolderID", param); | ||
150 | IDataReader reader = result.ExecuteReader(); | ||
151 | |||
152 | while (reader.Read()) | ||
153 | items.Add(readInventoryItem(reader)); | ||
154 | |||
155 | reader.Close(); | ||
156 | result.Dispose(); | ||
157 | |||
158 | return items; | ||
159 | } | ||
160 | } | ||
161 | catch (Exception e) | ||
162 | { | ||
163 | database.Reconnect(); | ||
164 | m_log.Error(e.ToString()); | ||
165 | return null; | ||
166 | } | ||
167 | } | ||
168 | |||
169 | /// <summary> | ||
170 | /// Returns a list of the root folders within a users inventory | ||
171 | /// </summary> | ||
172 | /// <param name="user">The user whos inventory is to be searched</param> | ||
173 | /// <returns>A list of folder objects</returns> | ||
174 | public List<InventoryFolderBase> getUserRootFolders(LLUUID user) | ||
175 | { | ||
176 | try | ||
177 | { | ||
178 | lock (database) | ||
179 | { | ||
180 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
181 | param["uuid"] = user.ToString(); | ||
182 | param["zero"] = LLUUID.Zero.ToString(); | ||
183 | |||
184 | IDbCommand result = | ||
185 | database.Query( | ||
186 | "SELECT * FROM inventoryfolders WHERE parentFolderID = @zero AND agentID = @uuid", param); | ||
187 | IDataReader reader = result.ExecuteReader(); | ||
188 | |||
189 | List<InventoryFolderBase> items = new List<InventoryFolderBase>(); | ||
190 | while (reader.Read()) | ||
191 | items.Add(readInventoryFolder(reader)); | ||
192 | |||
193 | |||
194 | reader.Close(); | ||
195 | result.Dispose(); | ||
196 | |||
197 | return items; | ||
198 | } | ||
199 | } | ||
200 | catch (Exception e) | ||
201 | { | ||
202 | database.Reconnect(); | ||
203 | m_log.Error(e.ToString()); | ||
204 | return null; | ||
205 | } | ||
206 | } | ||
207 | |||
208 | // see InventoryItemBase.getUserRootFolder | ||
209 | public InventoryFolderBase getUserRootFolder(LLUUID user) | ||
210 | { | ||
211 | try | ||
212 | { | ||
213 | lock (database) | ||
214 | { | ||
215 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
216 | param["uuid"] = user.ToString(); | ||
217 | param["zero"] = LLUUID.Zero.ToString(); | ||
218 | |||
219 | IDbCommand result = | ||
220 | database.Query( | ||
221 | "SELECT * FROM inventoryfolders WHERE parentFolderID = @zero AND agentID = @uuid", param); | ||
222 | IDataReader reader = result.ExecuteReader(); | ||
223 | |||
224 | List<InventoryFolderBase> items = new List<InventoryFolderBase>(); | ||
225 | while (reader.Read()) | ||
226 | items.Add(readInventoryFolder(reader)); | ||
227 | |||
228 | InventoryFolderBase rootFolder = null; | ||
229 | |||
230 | // There should only ever be one root folder for a user. However, if there's more | ||
231 | // than one we'll simply use the first one rather than failing. It would be even | ||
232 | // nicer to print some message to this effect, but this feels like it's too low a | ||
233 | // to put such a message out, and it's too minor right now to spare the time to | ||
234 | // suitably refactor. | ||
235 | if (items.Count > 0) | ||
236 | { | ||
237 | rootFolder = items[0]; | ||
238 | } | ||
239 | |||
240 | reader.Close(); | ||
241 | result.Dispose(); | ||
242 | |||
243 | return rootFolder; | ||
244 | } | ||
245 | } | ||
246 | catch (Exception e) | ||
247 | { | ||
248 | database.Reconnect(); | ||
249 | m_log.Error(e.ToString()); | ||
250 | return null; | ||
251 | } | ||
252 | } | ||
253 | |||
254 | /// <summary> | ||
255 | /// Returns a list of folders in a users inventory contained within the specified folder | ||
256 | /// </summary> | ||
257 | /// <param name="parentID">The folder to search</param> | ||
258 | /// <returns>A list of inventory folders</returns> | ||
259 | public List<InventoryFolderBase> getInventoryFolders(LLUUID parentID) | ||
260 | { | ||
261 | try | ||
262 | { | ||
263 | lock (database) | ||
264 | { | ||
265 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
266 | param["parentFolderID"] = parentID.ToString(); | ||
267 | |||
268 | |||
269 | IDbCommand result = | ||
270 | database.Query("SELECT * FROM inventoryfolders WHERE parentFolderID = @parentFolderID", param); | ||
271 | IDataReader reader = result.ExecuteReader(); | ||
272 | |||
273 | List<InventoryFolderBase> items = new List<InventoryFolderBase>(); | ||
274 | |||
275 | while (reader.Read()) | ||
276 | items.Add(readInventoryFolder(reader)); | ||
277 | |||
278 | reader.Close(); | ||
279 | result.Dispose(); | ||
280 | |||
281 | return items; | ||
282 | } | ||
283 | } | ||
284 | catch (Exception e) | ||
285 | { | ||
286 | database.Reconnect(); | ||
287 | m_log.Error(e.ToString()); | ||
288 | return null; | ||
289 | } | ||
290 | } | ||
291 | |||
292 | /// <summary> | ||
293 | /// Reads a one item from an SQL result | ||
294 | /// </summary> | ||
295 | /// <param name="reader">The SQL Result</param> | ||
296 | /// <returns>the item read</returns> | ||
297 | private InventoryItemBase readInventoryItem(IDataReader reader) | ||
298 | { | ||
299 | try | ||
300 | { | ||
301 | InventoryItemBase item = new InventoryItemBase(); | ||
302 | |||
303 | item.inventoryID = new LLUUID((string) reader["inventoryID"]); | ||
304 | item.assetID = new LLUUID((string) reader["assetID"]); | ||
305 | item.assetType = (int) reader["assetType"]; | ||
306 | item.parentFolderID = new LLUUID((string) reader["parentFolderID"]); | ||
307 | item.avatarID = new LLUUID((string) reader["avatarID"]); | ||
308 | item.inventoryName = (string) reader["inventoryName"]; | ||
309 | item.inventoryDescription = (string) reader["inventoryDescription"]; | ||
310 | item.inventoryNextPermissions = Convert.ToUInt32(reader["inventoryNextPermissions"]); | ||
311 | item.inventoryCurrentPermissions = Convert.ToUInt32(reader["inventoryCurrentPermissions"]); | ||
312 | item.invType = (int) reader["invType"]; | ||
313 | item.creatorsID = new LLUUID((string) reader["creatorID"]); | ||
314 | item.inventoryBasePermissions = Convert.ToUInt32(reader["inventoryBasePermissions"]); | ||
315 | item.inventoryEveryOnePermissions = Convert.ToUInt32(reader["inventoryEveryOnePermissions"]); | ||
316 | return item; | ||
317 | } | ||
318 | catch (SqlException e) | ||
319 | { | ||
320 | m_log.Error(e.ToString()); | ||
321 | } | ||
322 | |||
323 | return null; | ||
324 | } | ||
325 | |||
326 | /// <summary> | ||
327 | /// Returns a specified inventory item | ||
328 | /// </summary> | ||
329 | /// <param name="item">The item to return</param> | ||
330 | /// <returns>An inventory item</returns> | ||
331 | public InventoryItemBase getInventoryItem(LLUUID itemID) | ||
332 | { | ||
333 | try | ||
334 | { | ||
335 | lock (database) | ||
336 | { | ||
337 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
338 | param["inventoryID"] = itemID.ToString(); | ||
339 | |||
340 | IDbCommand result = | ||
341 | database.Query("SELECT * FROM inventoryitems WHERE inventoryID = @inventoryID", param); | ||
342 | IDataReader reader = result.ExecuteReader(); | ||
343 | |||
344 | InventoryItemBase item = null; | ||
345 | if (reader.Read()) | ||
346 | item = readInventoryItem(reader); | ||
347 | |||
348 | reader.Close(); | ||
349 | result.Dispose(); | ||
350 | |||
351 | return item; | ||
352 | } | ||
353 | } | ||
354 | catch (Exception e) | ||
355 | { | ||
356 | database.Reconnect(); | ||
357 | m_log.Error(e.ToString()); | ||
358 | } | ||
359 | return null; | ||
360 | } | ||
361 | |||
362 | /// <summary> | ||
363 | /// Reads a list of inventory folders returned by a query. | ||
364 | /// </summary> | ||
365 | /// <param name="reader">A MySQL Data Reader</param> | ||
366 | /// <returns>A List containing inventory folders</returns> | ||
367 | protected InventoryFolderBase readInventoryFolder(IDataReader reader) | ||
368 | { | ||
369 | try | ||
370 | { | ||
371 | InventoryFolderBase folder = new InventoryFolderBase(); | ||
372 | folder.agentID = new LLUUID((string) reader["agentID"]); | ||
373 | folder.parentID = new LLUUID((string) reader["parentFolderID"]); | ||
374 | folder.folderID = new LLUUID((string) reader["folderID"]); | ||
375 | folder.name = (string) reader["folderName"]; | ||
376 | folder.type = (short) reader["type"]; | ||
377 | folder.version = (ushort) ((int) reader["version"]); | ||
378 | return folder; | ||
379 | } | ||
380 | catch (Exception e) | ||
381 | { | ||
382 | m_log.Error(e.ToString()); | ||
383 | } | ||
384 | |||
385 | return null; | ||
386 | } | ||
387 | |||
388 | /// <summary> | ||
389 | /// Returns a specified inventory folder | ||
390 | /// </summary> | ||
391 | /// <param name="folder">The folder to return</param> | ||
392 | /// <returns>A folder class</returns> | ||
393 | public InventoryFolderBase getInventoryFolder(LLUUID folderID) | ||
394 | { | ||
395 | try | ||
396 | { | ||
397 | lock (database) | ||
398 | { | ||
399 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
400 | param["uuid"] = folderID.ToString(); | ||
401 | |||
402 | IDbCommand result = database.Query("SELECT * FROM inventoryfolders WHERE folderID = @uuid", param); | ||
403 | IDataReader reader = result.ExecuteReader(); | ||
404 | |||
405 | reader.Read(); | ||
406 | InventoryFolderBase folder = readInventoryFolder(reader); | ||
407 | reader.Close(); | ||
408 | result.Dispose(); | ||
409 | |||
410 | return folder; | ||
411 | } | ||
412 | } | ||
413 | catch (Exception e) | ||
414 | { | ||
415 | database.Reconnect(); | ||
416 | m_log.Error(e.ToString()); | ||
417 | return null; | ||
418 | } | ||
419 | } | ||
420 | |||
421 | /// <summary> | ||
422 | /// Adds a specified item to the database | ||
423 | /// </summary> | ||
424 | /// <param name="item">The inventory item</param> | ||
425 | public void addInventoryItem(InventoryItemBase item) | ||
426 | { | ||
427 | if (getInventoryItem(item.inventoryID) != null) | ||
428 | { | ||
429 | updateInventoryItem(item); | ||
430 | return; | ||
431 | } | ||
432 | |||
433 | string sql = "INSERT INTO inventoryitems"; | ||
434 | sql += | ||
435 | "([inventoryID], [assetID], [assetType], [parentFolderID], [avatarID], [inventoryName], [inventoryDescription], [inventoryNextPermissions], [inventoryCurrentPermissions], [invType], [creatorID], [inventoryBasePermissions], [inventoryEveryOnePermissions]) VALUES "; | ||
436 | sql += | ||
437 | "(@inventoryID, @assetID, @assetType, @parentFolderID, @avatarID, @inventoryName, @inventoryDescription, @inventoryNextPermissions, @inventoryCurrentPermissions, @invType, @creatorID, @inventoryBasePermissions, @inventoryEveryOnePermissions);"; | ||
438 | |||
439 | try | ||
440 | { | ||
441 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
442 | param["inventoryID"] = item.inventoryID.ToString(); | ||
443 | param["assetID"] = item.assetID.ToString(); | ||
444 | param["assetType"] = item.assetType.ToString(); | ||
445 | param["parentFolderID"] = item.parentFolderID.ToString(); | ||
446 | param["avatarID"] = item.avatarID.ToString(); | ||
447 | param["inventoryName"] = item.inventoryName; | ||
448 | param["inventoryDescription"] = item.inventoryDescription; | ||
449 | param["inventoryNextPermissions"] = item.inventoryNextPermissions.ToString(); | ||
450 | param["inventoryCurrentPermissions"] = item.inventoryCurrentPermissions.ToString(); | ||
451 | param["invType"] = Convert.ToString(item.invType); | ||
452 | param["creatorID"] = item.creatorsID.ToString(); | ||
453 | param["inventoryBasePermissions"] = Convert.ToString(item.inventoryBasePermissions); | ||
454 | param["inventoryEveryOnePermissions"] = Convert.ToString(item.inventoryEveryOnePermissions); | ||
455 | |||
456 | IDbCommand result = database.Query(sql, param); | ||
457 | result.ExecuteNonQuery(); | ||
458 | result.Dispose(); | ||
459 | } | ||
460 | catch (SqlException e) | ||
461 | { | ||
462 | m_log.Error(e.ToString()); | ||
463 | } | ||
464 | } | ||
465 | |||
466 | /// <summary> | ||
467 | /// Updates the specified inventory item | ||
468 | /// </summary> | ||
469 | /// <param name="item">Inventory item to update</param> | ||
470 | public void updateInventoryItem(InventoryItemBase item) | ||
471 | { | ||
472 | SqlCommand command = new SqlCommand("UPDATE inventoryitems set inventoryID = @inventoryID, " + | ||
473 | "assetID = @assetID, " + | ||
474 | "assetType = @assetType" + | ||
475 | "parentFolderID = @parentFolderID" + | ||
476 | "avatarID = @avatarID" + | ||
477 | "inventoryName = @inventoryName" + | ||
478 | "inventoryDescription = @inventoryDescription" + | ||
479 | "inventoryNextPermissions = @inventoryNextPermissions" + | ||
480 | "inventoryCurrentPermissions = @inventoryCurrentPermissions" + | ||
481 | "invType = @invType" + | ||
482 | "creatorID = @creatorID" + | ||
483 | "inventoryBasePermissions = @inventoryBasePermissions" + | ||
484 | "inventoryEveryOnePermissions = @inventoryEveryOnePermissions) where " + | ||
485 | "inventoryID = @keyInventoryID;", database.getConnection()); | ||
486 | SqlParameter param1 = new SqlParameter("@inventoryID", item.inventoryID.ToString()); | ||
487 | SqlParameter param2 = new SqlParameter("@assetID", item.assetID); | ||
488 | SqlParameter param3 = new SqlParameter("@assetType", item.assetType); | ||
489 | SqlParameter param4 = new SqlParameter("@parentFolderID", item.parentFolderID); | ||
490 | SqlParameter param5 = new SqlParameter("@avatarID", item.avatarID); | ||
491 | SqlParameter param6 = new SqlParameter("@inventoryName", item.inventoryName); | ||
492 | SqlParameter param7 = new SqlParameter("@inventoryDescription", item.inventoryDescription); | ||
493 | SqlParameter param8 = new SqlParameter("@inventoryNextPermissions", item.inventoryNextPermissions); | ||
494 | SqlParameter param9 = new SqlParameter("@inventoryCurrentPermissions", item.inventoryCurrentPermissions); | ||
495 | SqlParameter param10 = new SqlParameter("@invType", item.invType); | ||
496 | SqlParameter param11 = new SqlParameter("@creatorID", item.creatorsID); | ||
497 | SqlParameter param12 = new SqlParameter("@inventoryBasePermissions", item.inventoryBasePermissions); | ||
498 | SqlParameter param13 = new SqlParameter("@inventoryEveryOnePermissions", item.inventoryEveryOnePermissions); | ||
499 | SqlParameter param14 = new SqlParameter("@keyInventoryID", item.inventoryID.ToString()); | ||
500 | command.Parameters.Add(param1); | ||
501 | command.Parameters.Add(param2); | ||
502 | command.Parameters.Add(param3); | ||
503 | command.Parameters.Add(param4); | ||
504 | command.Parameters.Add(param5); | ||
505 | command.Parameters.Add(param6); | ||
506 | command.Parameters.Add(param7); | ||
507 | command.Parameters.Add(param8); | ||
508 | command.Parameters.Add(param9); | ||
509 | command.Parameters.Add(param10); | ||
510 | command.Parameters.Add(param11); | ||
511 | command.Parameters.Add(param12); | ||
512 | command.Parameters.Add(param13); | ||
513 | command.Parameters.Add(param14); | ||
514 | |||
515 | try | ||
516 | { | ||
517 | command.ExecuteNonQuery(); | ||
518 | } | ||
519 | catch (Exception e) | ||
520 | { | ||
521 | m_log.Error(e.ToString()); | ||
522 | } | ||
523 | } | ||
524 | |||
525 | /// <summary> | ||
526 | /// | ||
527 | /// </summary> | ||
528 | /// <param name="item"></param> | ||
529 | public void deleteInventoryItem(LLUUID itemID) | ||
530 | { | ||
531 | try | ||
532 | { | ||
533 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
534 | param["uuid"] = itemID.ToString(); | ||
535 | |||
536 | IDbCommand cmd = database.Query("DELETE FROM inventoryitems WHERE inventoryID=@uuid", param); | ||
537 | cmd.ExecuteNonQuery(); | ||
538 | cmd.Dispose(); | ||
539 | } | ||
540 | catch (SqlException e) | ||
541 | { | ||
542 | database.Reconnect(); | ||
543 | m_log.Error(e.ToString()); | ||
544 | } | ||
545 | } | ||
546 | |||
547 | /// <summary> | ||
548 | /// Creates a new inventory folder | ||
549 | /// </summary> | ||
550 | /// <param name="folder">Folder to create</param> | ||
551 | public void addInventoryFolder(InventoryFolderBase folder) | ||
552 | { | ||
553 | string sql = | ||
554 | "INSERT INTO inventoryfolders ([folderID], [agentID], [parentFolderID], [folderName], [type], [version]) VALUES "; | ||
555 | sql += "(@folderID, @agentID, @parentFolderID, @folderName, @type, @version);"; | ||
556 | |||
557 | |||
558 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
559 | param["folderID"] = folder.folderID.ToString(); | ||
560 | param["agentID"] = folder.agentID.ToString(); | ||
561 | param["parentFolderID"] = folder.parentID.ToString(); | ||
562 | param["folderName"] = folder.name; | ||
563 | param["type"] = Convert.ToString(folder.type); | ||
564 | param["version"] = Convert.ToString(folder.version); | ||
565 | |||
566 | try | ||
567 | { | ||
568 | IDbCommand result = database.Query(sql, param); | ||
569 | result.ExecuteNonQuery(); | ||
570 | result.Dispose(); | ||
571 | } | ||
572 | catch (Exception e) | ||
573 | { | ||
574 | m_log.Error(e.ToString()); | ||
575 | } | ||
576 | } | ||
577 | |||
578 | /// <summary> | ||
579 | /// Updates an inventory folder | ||
580 | /// </summary> | ||
581 | /// <param name="folder">Folder to update</param> | ||
582 | public void updateInventoryFolder(InventoryFolderBase folder) | ||
583 | { | ||
584 | SqlCommand command = new SqlCommand("UPDATE inventoryfolders set folderID = @folderID, " + | ||
585 | "agentID = @agentID, " + | ||
586 | "parentFolderID = @parentFolderID," + | ||
587 | "folderName = @folderName," + | ||
588 | "type = @type," + | ||
589 | "version = @version where " + | ||
590 | "folderID = @keyFolderID;", database.getConnection()); | ||
591 | SqlParameter param1 = new SqlParameter("@folderID", folder.folderID.ToString()); | ||
592 | SqlParameter param2 = new SqlParameter("@agentID", folder.agentID.ToString()); | ||
593 | SqlParameter param3 = new SqlParameter("@parentFolderID", folder.parentID.ToString()); | ||
594 | SqlParameter param4 = new SqlParameter("@folderName", folder.name); | ||
595 | SqlParameter param5 = new SqlParameter("@type", folder.type); | ||
596 | SqlParameter param6 = new SqlParameter("@version", folder.version); | ||
597 | SqlParameter param7 = new SqlParameter("@keyFolderID", folder.folderID.ToString()); | ||
598 | command.Parameters.Add(param1); | ||
599 | command.Parameters.Add(param2); | ||
600 | command.Parameters.Add(param3); | ||
601 | command.Parameters.Add(param4); | ||
602 | command.Parameters.Add(param5); | ||
603 | command.Parameters.Add(param6); | ||
604 | command.Parameters.Add(param7); | ||
605 | |||
606 | try | ||
607 | { | ||
608 | command.ExecuteNonQuery(); | ||
609 | } | ||
610 | catch (Exception e) | ||
611 | { | ||
612 | m_log.Error(e.ToString()); | ||
613 | } | ||
614 | } | ||
615 | |||
616 | /// <summary> | ||
617 | /// Updates an inventory folder | ||
618 | /// </summary> | ||
619 | /// <param name="folder">Folder to update</param> | ||
620 | public void moveInventoryFolder(InventoryFolderBase folder) | ||
621 | { | ||
622 | SqlCommand command = new SqlCommand("UPDATE inventoryfolders set folderID = @folderID, " + | ||
623 | "parentFolderID = @parentFolderID," + | ||
624 | "folderID = @keyFolderID;", database.getConnection()); | ||
625 | SqlParameter param1 = new SqlParameter("@folderID", folder.folderID.ToString()); | ||
626 | SqlParameter param2 = new SqlParameter("@parentFolderID", folder.parentID.ToString()); | ||
627 | SqlParameter param3 = new SqlParameter("@keyFolderID", folder.folderID.ToString()); | ||
628 | command.Parameters.Add(param1); | ||
629 | command.Parameters.Add(param2); | ||
630 | command.Parameters.Add(param3); | ||
631 | |||
632 | try | ||
633 | { | ||
634 | command.ExecuteNonQuery(); | ||
635 | } | ||
636 | catch (Exception e) | ||
637 | { | ||
638 | m_log.Error(e.ToString()); | ||
639 | } | ||
640 | } | ||
641 | |||
642 | /// <summary> | ||
643 | /// Append a list of all the child folders of a parent folder | ||
644 | /// </summary> | ||
645 | /// <param name="folders">list where folders will be appended</param> | ||
646 | /// <param name="parentID">ID of parent</param> | ||
647 | protected void getInventoryFolders(ref List<InventoryFolderBase> folders, LLUUID parentID) | ||
648 | { | ||
649 | List<InventoryFolderBase> subfolderList = getInventoryFolders(parentID); | ||
650 | |||
651 | foreach (InventoryFolderBase f in subfolderList) | ||
652 | folders.Add(f); | ||
653 | } | ||
654 | |||
655 | // See IInventoryData | ||
656 | public List<InventoryFolderBase> getFolderHierarchy(LLUUID parentID) | ||
657 | { | ||
658 | List<InventoryFolderBase> folders = new List<InventoryFolderBase>(); | ||
659 | getInventoryFolders(ref folders, parentID); | ||
660 | |||
661 | for (int i = 0; i < folders.Count; i++) | ||
662 | getInventoryFolders(ref folders, folders[i].folderID); | ||
663 | |||
664 | return folders; | ||
665 | } | ||
666 | |||
667 | protected void deleteOneFolder(LLUUID folderID) | ||
668 | { | ||
669 | try | ||
670 | { | ||
671 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
672 | param["folderID"] = folderID.ToString(); | ||
673 | |||
674 | IDbCommand cmd = database.Query("DELETE FROM inventoryfolders WHERE folderID=@folderID", param); | ||
675 | cmd.ExecuteNonQuery(); | ||
676 | cmd.Dispose(); | ||
677 | } | ||
678 | catch (SqlException e) | ||
679 | { | ||
680 | database.Reconnect(); | ||
681 | m_log.Error(e.ToString()); | ||
682 | } | ||
683 | } | ||
684 | |||
685 | protected void deleteItemsInFolder(LLUUID folderID) | ||
686 | { | ||
687 | try | ||
688 | { | ||
689 | Dictionary<string, string> param = new Dictionary<string, string>(); | ||
690 | param["parentFolderID"] = folderID.ToString(); | ||
691 | |||
692 | |||
693 | IDbCommand cmd = | ||
694 | database.Query("DELETE FROM inventoryitems WHERE parentFolderID=@parentFolderID", param); | ||
695 | cmd.ExecuteNonQuery(); | ||
696 | cmd.Dispose(); | ||
697 | } | ||
698 | catch (SqlException e) | ||
699 | { | ||
700 | database.Reconnect(); | ||
701 | m_log.Error(e.ToString()); | ||
702 | } | ||
703 | } | ||
704 | |||
705 | /// <summary> | ||
706 | /// Delete an inventory folder | ||
707 | /// </summary> | ||
708 | /// <param name="folderId">Id of folder to delete</param> | ||
709 | public void deleteInventoryFolder(LLUUID folderID) | ||
710 | { | ||
711 | lock (database) | ||
712 | { | ||
713 | List<InventoryFolderBase> subFolders = getFolderHierarchy(folderID); | ||
714 | |||
715 | //Delete all sub-folders | ||
716 | foreach (InventoryFolderBase f in subFolders) | ||
717 | { | ||
718 | deleteOneFolder(f.folderID); | ||
719 | deleteItemsInFolder(f.folderID); | ||
720 | } | ||
721 | |||
722 | //Delete the actual row | ||
723 | deleteOneFolder(folderID); | ||
724 | deleteItemsInFolder(folderID); | ||
725 | } | ||
726 | } | ||
727 | } | ||
728 | } | ||