MSSQLInventoryData.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747
  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. using System;
  28. using System.Collections.Generic;
  29. using System.Data;
  30. using System.Data.SqlClient;
  31. using System.Reflection;
  32. using libsecondlife;
  33. using log4net;
  34. using OpenSim.Framework;
  35. namespace OpenSim.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 ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
  43. /// <summary>
  44. /// The database manager
  45. /// </summary>
  46. private MSSQLManager database;
  47. public void Initialise(string connect)
  48. {
  49. // TODO: actually use the provided connect string
  50. IniFile GridDataMySqlFile = new IniFile("mssql_connection.ini");
  51. string settingDataSource = GridDataMySqlFile.ParseFileReadValue("data_source");
  52. string settingInitialCatalog = GridDataMySqlFile.ParseFileReadValue("initial_catalog");
  53. string settingPersistSecurityInfo = GridDataMySqlFile.ParseFileReadValue("persist_security_info");
  54. string settingUserId = GridDataMySqlFile.ParseFileReadValue("user_id");
  55. string settingPassword = GridDataMySqlFile.ParseFileReadValue("password");
  56. database =
  57. new MSSQLManager(settingDataSource, settingInitialCatalog, settingPersistSecurityInfo, settingUserId,
  58. settingPassword);
  59. TestTables();
  60. }
  61. #region Test and initialization code
  62. private void UpgradeFoldersTable(string tableName)
  63. {
  64. // null as the version, indicates that the table didn't exist
  65. if (tableName == null)
  66. {
  67. database.ExecuteResourceSql("CreateFoldersTable.sql");
  68. //database.ExecuteResourceSql("UpgradeFoldersTableToVersion2.sql");
  69. return;
  70. }
  71. }
  72. private void UpgradeItemsTable(string tableName)
  73. {
  74. // null as the version, indicates that the table didn't exist
  75. if (tableName == null)
  76. {
  77. database.ExecuteResourceSql("CreateItemsTable.sql");
  78. //database.ExecuteResourceSql("UpgradeItemsTableToVersion2.sql");
  79. return;
  80. }
  81. }
  82. private void TestTables()
  83. {
  84. Dictionary<string, string> tableList = new Dictionary<string, string>();
  85. tableList["inventoryfolders"] = null;
  86. tableList["inventoryitems"] = null;
  87. database.GetTableVersion(tableList);
  88. UpgradeFoldersTable(tableList["inventoryfolders"]);
  89. UpgradeItemsTable(tableList["inventoryitems"]);
  90. }
  91. #endregion
  92. /// <summary>
  93. /// The name of this DB provider
  94. /// </summary>
  95. /// <returns>Name of DB provider</returns>
  96. public string getName()
  97. {
  98. return "MSSQL Inventory Data Interface";
  99. }
  100. /// <summary>
  101. /// Closes this DB provider
  102. /// </summary>
  103. public void Close()
  104. {
  105. // Do nothing.
  106. }
  107. /// <summary>
  108. /// Returns the version of this DB provider
  109. /// </summary>
  110. /// <returns>A string containing the DB provider</returns>
  111. public string getVersion()
  112. {
  113. return database.getVersion();
  114. }
  115. /// <summary>
  116. /// Returns a list of items in a specified folder
  117. /// </summary>
  118. /// <param name="folderID">The folder to search</param>
  119. /// <returns>A list containing inventory items</returns>
  120. public List<InventoryItemBase> getInventoryInFolder(LLUUID folderID)
  121. {
  122. try
  123. {
  124. lock (database)
  125. {
  126. List<InventoryItemBase> items = new List<InventoryItemBase>();
  127. Dictionary<string, string> param = new Dictionary<string, string>();
  128. param["parentFolderID"] = folderID.ToString();
  129. IDbCommand result =
  130. database.Query("SELECT * FROM inventoryitems WHERE parentFolderID = @parentFolderID", param);
  131. IDataReader reader = result.ExecuteReader();
  132. while (reader.Read())
  133. items.Add(readInventoryItem(reader));
  134. reader.Close();
  135. result.Dispose();
  136. return items;
  137. }
  138. }
  139. catch (Exception e)
  140. {
  141. database.Reconnect();
  142. m_log.Error(e.ToString());
  143. return null;
  144. }
  145. }
  146. /// <summary>
  147. /// Returns a list of the root folders within a users inventory
  148. /// </summary>
  149. /// <param name="user">The user whos inventory is to be searched</param>
  150. /// <returns>A list of folder objects</returns>
  151. public List<InventoryFolderBase> getUserRootFolders(LLUUID user)
  152. {
  153. try
  154. {
  155. lock (database)
  156. {
  157. Dictionary<string, string> param = new Dictionary<string, string>();
  158. param["uuid"] = user.ToString();
  159. param["zero"] = LLUUID.Zero.ToString();
  160. IDbCommand result =
  161. database.Query(
  162. "SELECT * FROM inventoryfolders WHERE parentFolderID = @zero AND agentID = @uuid", param);
  163. IDataReader reader = result.ExecuteReader();
  164. List<InventoryFolderBase> items = new List<InventoryFolderBase>();
  165. while (reader.Read())
  166. items.Add(readInventoryFolder(reader));
  167. reader.Close();
  168. result.Dispose();
  169. return items;
  170. }
  171. }
  172. catch (Exception e)
  173. {
  174. database.Reconnect();
  175. m_log.Error(e.ToString());
  176. return null;
  177. }
  178. }
  179. // see InventoryItemBase.getUserRootFolder
  180. public InventoryFolderBase getUserRootFolder(LLUUID user)
  181. {
  182. try
  183. {
  184. lock (database)
  185. {
  186. Dictionary<string, string> param = new Dictionary<string, string>();
  187. param["uuid"] = user.ToString();
  188. param["zero"] = LLUUID.Zero.ToString();
  189. IDbCommand result =
  190. database.Query(
  191. "SELECT * FROM inventoryfolders WHERE parentFolderID = @zero AND agentID = @uuid", param);
  192. IDataReader reader = result.ExecuteReader();
  193. List<InventoryFolderBase> items = new List<InventoryFolderBase>();
  194. while (reader.Read())
  195. items.Add(readInventoryFolder(reader));
  196. InventoryFolderBase rootFolder = null;
  197. // There should only ever be one root folder for a user. However, if there's more
  198. // than one we'll simply use the first one rather than failing. It would be even
  199. // nicer to print some message to this effect, but this feels like it's too low a
  200. // to put such a message out, and it's too minor right now to spare the time to
  201. // suitably refactor.
  202. if (items.Count > 0)
  203. {
  204. rootFolder = items[0];
  205. }
  206. reader.Close();
  207. result.Dispose();
  208. return rootFolder;
  209. }
  210. }
  211. catch (Exception e)
  212. {
  213. database.Reconnect();
  214. m_log.Error(e.ToString());
  215. return null;
  216. }
  217. }
  218. /// <summary>
  219. /// Returns a list of folders in a users inventory contained within the specified folder
  220. /// </summary>
  221. /// <param name="parentID">The folder to search</param>
  222. /// <returns>A list of inventory folders</returns>
  223. public List<InventoryFolderBase> getInventoryFolders(LLUUID parentID)
  224. {
  225. try
  226. {
  227. lock (database)
  228. {
  229. Dictionary<string, string> param = new Dictionary<string, string>();
  230. param["parentFolderID"] = parentID.ToString();
  231. IDbCommand result =
  232. database.Query("SELECT * FROM inventoryfolders WHERE parentFolderID = @parentFolderID", param);
  233. IDataReader reader = result.ExecuteReader();
  234. List<InventoryFolderBase> items = new List<InventoryFolderBase>();
  235. while (reader.Read())
  236. items.Add(readInventoryFolder(reader));
  237. reader.Close();
  238. result.Dispose();
  239. return items;
  240. }
  241. }
  242. catch (Exception e)
  243. {
  244. database.Reconnect();
  245. m_log.Error(e.ToString());
  246. return null;
  247. }
  248. }
  249. /// <summary>
  250. /// Reads a one item from an SQL result
  251. /// </summary>
  252. /// <param name="reader">The SQL Result</param>
  253. /// <returns>the item read</returns>
  254. private static InventoryItemBase readInventoryItem(IDataReader reader)
  255. {
  256. try
  257. {
  258. InventoryItemBase item = new InventoryItemBase();
  259. item.ID = new LLUUID((string) reader["inventoryID"]);
  260. item.AssetID = new LLUUID((string) reader["assetID"]);
  261. item.AssetType = (int) reader["assetType"];
  262. item.Folder = new LLUUID((string) reader["parentFolderID"]);
  263. item.Owner = new LLUUID((string) reader["avatarID"]);
  264. item.Name = (string) reader["inventoryName"];
  265. item.Description = (string) reader["inventoryDescription"];
  266. item.NextPermissions = Convert.ToUInt32(reader["inventoryNextPermissions"]);
  267. item.CurrentPermissions = Convert.ToUInt32(reader["inventoryCurrentPermissions"]);
  268. item.InvType = (int) reader["invType"];
  269. item.Creator = new LLUUID((string) reader["creatorID"]);
  270. item.BasePermissions = Convert.ToUInt32(reader["inventoryBasePermissions"]);
  271. item.EveryOnePermissions = Convert.ToUInt32(reader["inventoryEveryOnePermissions"]);
  272. item.SalePrice = (int) reader["salePrice"];
  273. item.SaleType = Convert.ToByte(reader["saleType"]);
  274. item.CreationDate = (int) reader["creationDate"];
  275. item.GroupID = new LLUUID(reader["groupID"].ToString());
  276. item.GroupOwned = Convert.ToBoolean(reader["groupOwned"]);
  277. item.Flags = (uint) reader["flags"];
  278. return item;
  279. }
  280. catch (SqlException e)
  281. {
  282. m_log.Error(e.ToString());
  283. }
  284. return null;
  285. }
  286. /// <summary>
  287. /// Returns a specified inventory item
  288. /// </summary>
  289. /// <param name="item">The item to return</param>
  290. /// <returns>An inventory item</returns>
  291. public InventoryItemBase getInventoryItem(LLUUID itemID)
  292. {
  293. try
  294. {
  295. lock (database)
  296. {
  297. Dictionary<string, string> param = new Dictionary<string, string>();
  298. param["inventoryID"] = itemID.ToString();
  299. IDbCommand result =
  300. database.Query("SELECT * FROM inventoryitems WHERE inventoryID = @inventoryID", param);
  301. IDataReader reader = result.ExecuteReader();
  302. InventoryItemBase item = null;
  303. if (reader.Read())
  304. item = readInventoryItem(reader);
  305. reader.Close();
  306. result.Dispose();
  307. return item;
  308. }
  309. }
  310. catch (Exception e)
  311. {
  312. database.Reconnect();
  313. m_log.Error(e.ToString());
  314. }
  315. return null;
  316. }
  317. /// <summary>
  318. /// Reads a list of inventory folders returned by a query.
  319. /// </summary>
  320. /// <param name="reader">A MySQL Data Reader</param>
  321. /// <returns>A List containing inventory folders</returns>
  322. protected static InventoryFolderBase readInventoryFolder(IDataReader reader)
  323. {
  324. try
  325. {
  326. InventoryFolderBase folder = new InventoryFolderBase();
  327. folder.Owner = new LLUUID((string) reader["agentID"]);
  328. folder.ParentID = new LLUUID((string) reader["parentFolderID"]);
  329. folder.ID = new LLUUID((string) reader["folderID"]);
  330. folder.Name = (string) reader["folderName"];
  331. folder.Type = (short) reader["type"];
  332. folder.Version = (ushort) ((int) reader["version"]);
  333. return folder;
  334. }
  335. catch (Exception e)
  336. {
  337. m_log.Error(e.ToString());
  338. }
  339. return null;
  340. }
  341. /// <summary>
  342. /// Returns a specified inventory folder
  343. /// </summary>
  344. /// <param name="folder">The folder to return</param>
  345. /// <returns>A folder class</returns>
  346. public InventoryFolderBase getInventoryFolder(LLUUID folderID)
  347. {
  348. try
  349. {
  350. lock (database)
  351. {
  352. Dictionary<string, string> param = new Dictionary<string, string>();
  353. param["uuid"] = folderID.ToString();
  354. IDbCommand result = database.Query("SELECT * FROM inventoryfolders WHERE folderID = @uuid", param);
  355. IDataReader reader = result.ExecuteReader();
  356. reader.Read();
  357. InventoryFolderBase folder = readInventoryFolder(reader);
  358. reader.Close();
  359. result.Dispose();
  360. return folder;
  361. }
  362. }
  363. catch (Exception e)
  364. {
  365. database.Reconnect();
  366. m_log.Error(e.ToString());
  367. return null;
  368. }
  369. }
  370. /// <summary>
  371. /// Adds a specified item to the database
  372. /// </summary>
  373. /// <param name="item">The inventory item</param>
  374. public void addInventoryItem(InventoryItemBase item)
  375. {
  376. if (getInventoryItem(item.ID) != null)
  377. {
  378. updateInventoryItem(item);
  379. return;
  380. }
  381. string sql = "INSERT INTO inventoryitems";
  382. sql +=
  383. "([inventoryID], [assetID], [assetType], [parentFolderID], [avatarID], [inventoryName]"
  384. + ", [inventoryDescription], [inventoryNextPermissions], [inventoryCurrentPermissions]"
  385. + ", [invType], [creatorID], [inventoryBasePermissions], [inventoryEveryOnePermissions]"
  386. + ", [salePrice], [saleType], [creationDate], [groupID], [groupOwned], [flags]) VALUES ";
  387. sql +=
  388. "(@inventoryID, @assetID, @assetType, @parentFolderID, @avatarID, @inventoryName, @inventoryDescription"
  389. + ", @inventoryNextPermissions, @inventoryCurrentPermissions, @invType, @creatorID"
  390. + ", @inventoryBasePermissions, @inventoryEveryOnePermissions, @salePrice, @saleType"
  391. + ", @creationDate, @groupID, @groupOwned, @flags);";
  392. try
  393. {
  394. Dictionary<string, string> param = new Dictionary<string, string>();
  395. param["inventoryID"] = item.ID.ToString();
  396. param["assetID"] = item.AssetID.ToString();
  397. param["assetType"] = item.AssetType.ToString();
  398. param["parentFolderID"] = item.Folder.ToString();
  399. param["avatarID"] = item.Owner.ToString();
  400. param["inventoryName"] = item.Name;
  401. param["inventoryDescription"] = item.Description;
  402. param["inventoryNextPermissions"] = item.NextPermissions.ToString();
  403. param["inventoryCurrentPermissions"] = item.CurrentPermissions.ToString();
  404. param["invType"] = Convert.ToString(item.InvType);
  405. param["creatorID"] = item.Creator.ToString();
  406. param["inventoryBasePermissions"] = Convert.ToString(item.BasePermissions);
  407. param["inventoryEveryOnePermissions"] = Convert.ToString(item.EveryOnePermissions);
  408. param["salePrice"] = Convert.ToString(item.SalePrice);
  409. param["saleType"] = Convert.ToString(item.SaleType);
  410. param["creationDate"] = Convert.ToString(item.CreationDate);
  411. param["groupID"] = item.GroupID.ToString();
  412. param["groupOwned"] = Convert.ToString(item.GroupOwned);
  413. param["flags"] = Convert.ToString(item.Flags);
  414. IDbCommand result = database.Query(sql, param);
  415. result.ExecuteNonQuery();
  416. result.Dispose();
  417. }
  418. catch (SqlException e)
  419. {
  420. m_log.Error(e.ToString());
  421. }
  422. }
  423. /// <summary>
  424. /// Updates the specified inventory item
  425. /// </summary>
  426. /// <param name="item">Inventory item to update</param>
  427. public void updateInventoryItem(InventoryItemBase item)
  428. {
  429. SqlCommand command = new SqlCommand("UPDATE inventoryitems set inventoryID = @inventoryID, " +
  430. "assetID = @assetID, " +
  431. "assetType = @assetType" +
  432. "parentFolderID = @parentFolderID" +
  433. "avatarID = @avatarID" +
  434. "inventoryName = @inventoryName" +
  435. "inventoryDescription = @inventoryDescription" +
  436. "inventoryNextPermissions = @inventoryNextPermissions" +
  437. "inventoryCurrentPermissions = @inventoryCurrentPermissions" +
  438. "invType = @invType" +
  439. "creatorID = @creatorID" +
  440. "inventoryBasePermissions = @inventoryBasePermissions" +
  441. "inventoryEveryOnePermissions = @inventoryEveryOnePermissions) where " +
  442. "inventoryID = @keyInventoryID;", database.getConnection());
  443. SqlParameter param1 = new SqlParameter("@inventoryID", item.ID.ToString());
  444. SqlParameter param2 = new SqlParameter("@assetID", item.AssetID);
  445. SqlParameter param3 = new SqlParameter("@assetType", item.AssetType);
  446. SqlParameter param4 = new SqlParameter("@parentFolderID", item.Folder);
  447. SqlParameter param5 = new SqlParameter("@avatarID", item.Owner);
  448. SqlParameter param6 = new SqlParameter("@inventoryName", item.Name);
  449. SqlParameter param7 = new SqlParameter("@inventoryDescription", item.Description);
  450. SqlParameter param8 = new SqlParameter("@inventoryNextPermissions", item.NextPermissions);
  451. SqlParameter param9 = new SqlParameter("@inventoryCurrentPermissions", item.CurrentPermissions);
  452. SqlParameter param10 = new SqlParameter("@invType", item.InvType);
  453. SqlParameter param11 = new SqlParameter("@creatorID", item.Creator);
  454. SqlParameter param12 = new SqlParameter("@inventoryBasePermissions", item.BasePermissions);
  455. SqlParameter param13 = new SqlParameter("@inventoryEveryOnePermissions", item.EveryOnePermissions);
  456. SqlParameter param14 = new SqlParameter("@keyInventoryID", item.ID.ToString());
  457. command.Parameters.Add(param1);
  458. command.Parameters.Add(param2);
  459. command.Parameters.Add(param3);
  460. command.Parameters.Add(param4);
  461. command.Parameters.Add(param5);
  462. command.Parameters.Add(param6);
  463. command.Parameters.Add(param7);
  464. command.Parameters.Add(param8);
  465. command.Parameters.Add(param9);
  466. command.Parameters.Add(param10);
  467. command.Parameters.Add(param11);
  468. command.Parameters.Add(param12);
  469. command.Parameters.Add(param13);
  470. command.Parameters.Add(param14);
  471. try
  472. {
  473. command.ExecuteNonQuery();
  474. }
  475. catch (Exception e)
  476. {
  477. m_log.Error(e.ToString());
  478. }
  479. }
  480. /// <summary>
  481. ///
  482. /// </summary>
  483. /// <param name="item"></param>
  484. public void deleteInventoryItem(LLUUID itemID)
  485. {
  486. try
  487. {
  488. Dictionary<string, string> param = new Dictionary<string, string>();
  489. param["uuid"] = itemID.ToString();
  490. IDbCommand cmd = database.Query("DELETE FROM inventoryitems WHERE inventoryID=@uuid", param);
  491. cmd.ExecuteNonQuery();
  492. cmd.Dispose();
  493. }
  494. catch (SqlException e)
  495. {
  496. database.Reconnect();
  497. m_log.Error(e.ToString());
  498. }
  499. }
  500. /// <summary>
  501. /// Creates a new inventory folder
  502. /// </summary>
  503. /// <param name="folder">Folder to create</param>
  504. public void addInventoryFolder(InventoryFolderBase folder)
  505. {
  506. string sql =
  507. "INSERT INTO inventoryfolders ([folderID], [agentID], [parentFolderID], [folderName], [type], [version]) VALUES ";
  508. sql += "(@folderID, @agentID, @parentFolderID, @folderName, @type, @version);";
  509. Dictionary<string, string> param = new Dictionary<string, string>();
  510. param["folderID"] = folder.ID.ToString();
  511. param["agentID"] = folder.Owner.ToString();
  512. param["parentFolderID"] = folder.ParentID.ToString();
  513. param["folderName"] = folder.Name;
  514. param["type"] = Convert.ToString(folder.Type);
  515. param["version"] = Convert.ToString(folder.Version);
  516. try
  517. {
  518. IDbCommand result = database.Query(sql, param);
  519. result.ExecuteNonQuery();
  520. result.Dispose();
  521. }
  522. catch (Exception e)
  523. {
  524. m_log.Error(e.ToString());
  525. }
  526. }
  527. /// <summary>
  528. /// Updates an inventory folder
  529. /// </summary>
  530. /// <param name="folder">Folder to update</param>
  531. public void updateInventoryFolder(InventoryFolderBase folder)
  532. {
  533. SqlCommand command = new SqlCommand("UPDATE inventoryfolders set folderID = @folderID, " +
  534. "agentID = @agentID, " +
  535. "parentFolderID = @parentFolderID," +
  536. "folderName = @folderName," +
  537. "type = @type," +
  538. "version = @version where " +
  539. "folderID = @keyFolderID;", database.getConnection());
  540. SqlParameter param1 = new SqlParameter("@folderID", folder.ID.ToString());
  541. SqlParameter param2 = new SqlParameter("@agentID", folder.Owner.ToString());
  542. SqlParameter param3 = new SqlParameter("@parentFolderID", folder.ParentID.ToString());
  543. SqlParameter param4 = new SqlParameter("@folderName", folder.Name);
  544. SqlParameter param5 = new SqlParameter("@type", folder.Type);
  545. SqlParameter param6 = new SqlParameter("@version", folder.Version);
  546. SqlParameter param7 = new SqlParameter("@keyFolderID", folder.ID.ToString());
  547. command.Parameters.Add(param1);
  548. command.Parameters.Add(param2);
  549. command.Parameters.Add(param3);
  550. command.Parameters.Add(param4);
  551. command.Parameters.Add(param5);
  552. command.Parameters.Add(param6);
  553. command.Parameters.Add(param7);
  554. try
  555. {
  556. command.ExecuteNonQuery();
  557. }
  558. catch (Exception e)
  559. {
  560. m_log.Error(e.ToString());
  561. }
  562. }
  563. /// <summary>
  564. /// Updates an inventory folder
  565. /// </summary>
  566. /// <param name="folder">Folder to update</param>
  567. public void moveInventoryFolder(InventoryFolderBase folder)
  568. {
  569. SqlCommand command = new SqlCommand("UPDATE inventoryfolders set folderID = @folderID, " +
  570. "parentFolderID = @parentFolderID," +
  571. "folderID = @keyFolderID;", database.getConnection());
  572. SqlParameter param1 = new SqlParameter("@folderID", folder.ID.ToString());
  573. SqlParameter param2 = new SqlParameter("@parentFolderID", folder.ParentID.ToString());
  574. SqlParameter param3 = new SqlParameter("@keyFolderID", folder.ID.ToString());
  575. command.Parameters.Add(param1);
  576. command.Parameters.Add(param2);
  577. command.Parameters.Add(param3);
  578. try
  579. {
  580. command.ExecuteNonQuery();
  581. }
  582. catch (Exception e)
  583. {
  584. m_log.Error(e.ToString());
  585. }
  586. }
  587. /// <summary>
  588. /// Append a list of all the child folders of a parent folder
  589. /// </summary>
  590. /// <param name="folders">list where folders will be appended</param>
  591. /// <param name="parentID">ID of parent</param>
  592. protected void getInventoryFolders(ref List<InventoryFolderBase> folders, LLUUID parentID)
  593. {
  594. List<InventoryFolderBase> subfolderList = getInventoryFolders(parentID);
  595. foreach (InventoryFolderBase f in subfolderList)
  596. folders.Add(f);
  597. }
  598. // See IInventoryData
  599. public List<InventoryFolderBase> getFolderHierarchy(LLUUID parentID)
  600. {
  601. List<InventoryFolderBase> folders = new List<InventoryFolderBase>();
  602. getInventoryFolders(ref folders, parentID);
  603. for (int i = 0; i < folders.Count; i++)
  604. getInventoryFolders(ref folders, folders[i].ID);
  605. return folders;
  606. }
  607. protected void deleteOneFolder(LLUUID folderID)
  608. {
  609. try
  610. {
  611. Dictionary<string, string> param = new Dictionary<string, string>();
  612. param["folderID"] = folderID.ToString();
  613. IDbCommand cmd = database.Query("DELETE FROM inventoryfolders WHERE folderID=@folderID", param);
  614. cmd.ExecuteNonQuery();
  615. cmd.Dispose();
  616. }
  617. catch (SqlException e)
  618. {
  619. database.Reconnect();
  620. m_log.Error(e.ToString());
  621. }
  622. }
  623. protected void deleteItemsInFolder(LLUUID folderID)
  624. {
  625. try
  626. {
  627. Dictionary<string, string> param = new Dictionary<string, string>();
  628. param["parentFolderID"] = folderID.ToString();
  629. IDbCommand cmd =
  630. database.Query("DELETE FROM inventoryitems WHERE parentFolderID=@parentFolderID", param);
  631. cmd.ExecuteNonQuery();
  632. cmd.Dispose();
  633. }
  634. catch (SqlException e)
  635. {
  636. database.Reconnect();
  637. m_log.Error(e.ToString());
  638. }
  639. }
  640. /// <summary>
  641. /// Delete an inventory folder
  642. /// </summary>
  643. /// <param name="folderId">Id of folder to delete</param>
  644. public void deleteInventoryFolder(LLUUID folderID)
  645. {
  646. lock (database)
  647. {
  648. List<InventoryFolderBase> subFolders = getFolderHierarchy(folderID);
  649. //Delete all sub-folders
  650. foreach (InventoryFolderBase f in subFolders)
  651. {
  652. deleteOneFolder(f.ID);
  653. deleteItemsInFolder(f.ID);
  654. }
  655. //Delete the actual row
  656. deleteOneFolder(folderID);
  657. deleteItemsInFolder(folderID);
  658. }
  659. }
  660. }
  661. }