MySQLManager.cs 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909
  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.IO;
  32. using System.Reflection;
  33. using libsecondlife;
  34. using MySql.Data.MySqlClient;
  35. using OpenSim.Framework.Console;
  36. namespace OpenSim.Framework.Data.MySQL
  37. {
  38. /// <summary>
  39. /// A MySQL Database manager
  40. /// </summary>
  41. internal class MySQLManager
  42. {
  43. private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
  44. /// <summary>
  45. /// The database connection object
  46. /// </summary>
  47. private MySqlConnection dbcon;
  48. /// <summary>
  49. /// Connection string for ADO.net
  50. /// </summary>
  51. private string connectionString;
  52. /// <summary>
  53. /// Initialises and creates a new MySQL connection and maintains it.
  54. /// </summary>
  55. /// <param name="hostname">The MySQL server being connected to</param>
  56. /// <param name="database">The name of the MySQL database being used</param>
  57. /// <param name="username">The username logging into the database</param>
  58. /// <param name="password">The password for the user logging in</param>
  59. /// <param name="cpooling">Whether to use connection pooling or not, can be one of the following: 'yes', 'true', 'no' or 'false', if unsure use 'false'.</param>
  60. public MySQLManager(string hostname, string database, string username, string password, string cpooling,
  61. string port)
  62. {
  63. try
  64. {
  65. connectionString = "Server=" + hostname + ";Port=" + port + ";Database=" + database + ";User ID=" +
  66. username + ";Password=" + password + ";Pooling=" + cpooling + ";";
  67. dbcon = new MySqlConnection(connectionString);
  68. try
  69. {
  70. dbcon.Open();
  71. }
  72. catch(Exception e)
  73. {
  74. throw new Exception( "Connection error while using connection string ["+connectionString+"]", e );
  75. }
  76. m_log.Info("[MYSQL]: Connection established");
  77. }
  78. catch (Exception e)
  79. {
  80. throw new Exception("Error initialising MySql Database: " + e.ToString());
  81. }
  82. }
  83. /// <summary>
  84. /// Get the connection being used
  85. /// </summary>
  86. public MySqlConnection Connection
  87. {
  88. get { return dbcon; }
  89. }
  90. /// <summary>
  91. /// Shuts down the database connection
  92. /// </summary>
  93. public void Close()
  94. {
  95. dbcon.Close();
  96. dbcon = null;
  97. }
  98. /// <summary>
  99. /// Reconnects to the database
  100. /// </summary>
  101. public void Reconnect()
  102. {
  103. lock (dbcon)
  104. {
  105. try
  106. {
  107. // Close the DB connection
  108. dbcon.Close();
  109. // Try reopen it
  110. dbcon = new MySqlConnection(connectionString);
  111. dbcon.Open();
  112. }
  113. catch (Exception e)
  114. {
  115. m_log.Error("Unable to reconnect to database " + e.ToString());
  116. }
  117. }
  118. }
  119. /// <summary>
  120. /// Returns the version of this DB provider
  121. /// </summary>
  122. /// <returns>A string containing the DB provider</returns>
  123. public string getVersion()
  124. {
  125. Module module = GetType().Module;
  126. string dllName = module.Assembly.ManifestModule.Name;
  127. Version dllVersion = module.Assembly.GetName().Version;
  128. return
  129. string.Format("{0}.{1}.{2}.{3}", dllVersion.Major, dllVersion.Minor, dllVersion.Build,
  130. dllVersion.Revision);
  131. }
  132. /// <summary>
  133. /// Extract a named string resource from the embedded resources
  134. /// </summary>
  135. /// <param name="name">name of embedded resource</param>
  136. /// <returns>string contained within the embedded resource</returns>
  137. private string getResourceString(string name)
  138. {
  139. Assembly assem = GetType().Assembly;
  140. string[] names = assem.GetManifestResourceNames();
  141. foreach (string s in names)
  142. {
  143. if (s.EndsWith(name))
  144. {
  145. using (Stream resource = assem.GetManifestResourceStream(s))
  146. {
  147. using (StreamReader resourceReader = new StreamReader(resource))
  148. {
  149. string resourceString = resourceReader.ReadToEnd();
  150. return resourceString;
  151. }
  152. }
  153. }
  154. }
  155. throw new Exception(string.Format("Resource '{0}' was not found", name));
  156. }
  157. /// <summary>
  158. /// Execute a SQL statement stored in a resource, as a string
  159. /// </summary>
  160. /// <param name="name"></param>
  161. public void ExecuteResourceSql(string name)
  162. {
  163. MySqlCommand cmd = new MySqlCommand(getResourceString(name), dbcon);
  164. cmd.ExecuteNonQuery();
  165. }
  166. /// <summary>
  167. /// Given a list of tables, return the version of the tables, as seen in the database
  168. /// </summary>
  169. /// <param name="tableList"></param>
  170. public void GetTableVersion(Dictionary<string, string> tableList)
  171. {
  172. lock (dbcon)
  173. {
  174. MySqlCommand tablesCmd =
  175. new MySqlCommand(
  176. "SELECT TABLE_NAME, TABLE_COMMENT FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA=?dbname",
  177. dbcon);
  178. tablesCmd.Parameters.AddWithValue("?dbname", dbcon.Database);
  179. using (MySqlDataReader tables = tablesCmd.ExecuteReader())
  180. {
  181. while (tables.Read())
  182. {
  183. try
  184. {
  185. string tableName = (string) tables["TABLE_NAME"];
  186. string comment = (string) tables["TABLE_COMMENT"];
  187. if (tableList.ContainsKey(tableName))
  188. {
  189. tableList[tableName] = comment;
  190. }
  191. }
  192. catch (Exception e)
  193. {
  194. m_log.Error(e.ToString());
  195. }
  196. }
  197. tables.Close();
  198. }
  199. }
  200. }
  201. // TODO: at some time this code should be cleaned up
  202. /// <summary>
  203. /// Runs a query with protection against SQL Injection by using parameterised input.
  204. /// </summary>
  205. /// <param name="sql">The SQL string - replace any variables such as WHERE x = "y" with WHERE x = @y</param>
  206. /// <param name="parameters">The parameters - index so that @y is indexed as 'y'</param>
  207. /// <returns>A MySQL DB Command</returns>
  208. public IDbCommand Query(string sql, Dictionary<string, string> parameters)
  209. {
  210. try
  211. {
  212. MySqlCommand dbcommand = (MySqlCommand) dbcon.CreateCommand();
  213. dbcommand.CommandText = sql;
  214. foreach (KeyValuePair<string, string> param in parameters)
  215. {
  216. dbcommand.Parameters.AddWithValue(param.Key, param.Value);
  217. }
  218. return (IDbCommand) dbcommand;
  219. }
  220. catch
  221. {
  222. lock (dbcon)
  223. {
  224. // Close the DB connection
  225. try
  226. {
  227. dbcon.Close();
  228. }
  229. catch
  230. {
  231. }
  232. // Try to reopen it
  233. try
  234. {
  235. dbcon = new MySqlConnection(connectionString);
  236. dbcon.Open();
  237. }
  238. catch (Exception e)
  239. {
  240. m_log.Error("Unable to reconnect to database " + e.ToString());
  241. }
  242. // Run the query again
  243. try
  244. {
  245. MySqlCommand dbcommand = (MySqlCommand) dbcon.CreateCommand();
  246. dbcommand.CommandText = sql;
  247. foreach (KeyValuePair<string, string> param in parameters)
  248. {
  249. dbcommand.Parameters.AddWithValue(param.Key, param.Value);
  250. }
  251. return (IDbCommand) dbcommand;
  252. }
  253. catch (Exception e)
  254. {
  255. // Return null if it fails.
  256. m_log.Error("Failed during Query generation: " + e.ToString());
  257. return null;
  258. }
  259. }
  260. }
  261. }
  262. /// <summary>
  263. /// Reads a region row from a database reader
  264. /// </summary>
  265. /// <param name="reader">An active database reader</param>
  266. /// <returns>A region profile</returns>
  267. public RegionProfileData readSimRow(IDataReader reader)
  268. {
  269. RegionProfileData retval = new RegionProfileData();
  270. if (reader.Read())
  271. {
  272. // Region Main gotta-have-or-we-return-null parts
  273. if (!UInt64.TryParse(reader["regionHandle"].ToString(), out retval.regionHandle))
  274. return null;
  275. if (!LLUUID.TryParse((string)reader["uuid"], out retval.UUID))
  276. return null;
  277. // non-critical parts
  278. retval.regionName = (string)reader["regionName"];
  279. retval.originUUID = new LLUUID((string) reader["originUUID"]);
  280. // Secrets
  281. retval.regionRecvKey = (string) reader["regionRecvKey"];
  282. retval.regionSecret = (string) reader["regionSecret"];
  283. retval.regionSendKey = (string) reader["regionSendKey"];
  284. // Region Server
  285. retval.regionDataURI = (string) reader["regionDataURI"];
  286. retval.regionOnline = false; // Needs to be pinged before this can be set.
  287. retval.serverIP = (string) reader["serverIP"];
  288. retval.serverPort = (uint) reader["serverPort"];
  289. retval.serverURI = (string) reader["serverURI"];
  290. retval.httpPort = Convert.ToUInt32(reader["serverHttpPort"].ToString());
  291. retval.remotingPort = Convert.ToUInt32(reader["serverRemotingPort"].ToString());
  292. // Location
  293. retval.regionLocX = Convert.ToUInt32(reader["locX"].ToString());
  294. retval.regionLocY = Convert.ToUInt32(reader["locY"].ToString());
  295. retval.regionLocZ = Convert.ToUInt32(reader["locZ"].ToString());
  296. // Neighbours - 0 = No Override
  297. retval.regionEastOverrideHandle = Convert.ToUInt64(reader["eastOverrideHandle"].ToString());
  298. retval.regionWestOverrideHandle = Convert.ToUInt64(reader["westOverrideHandle"].ToString());
  299. retval.regionSouthOverrideHandle = Convert.ToUInt64(reader["southOverrideHandle"].ToString());
  300. retval.regionNorthOverrideHandle = Convert.ToUInt64(reader["northOverrideHandle"].ToString());
  301. // Assets
  302. retval.regionAssetURI = (string) reader["regionAssetURI"];
  303. retval.regionAssetRecvKey = (string) reader["regionAssetRecvKey"];
  304. retval.regionAssetSendKey = (string) reader["regionAssetSendKey"];
  305. // Userserver
  306. retval.regionUserURI = (string) reader["regionUserURI"];
  307. retval.regionUserRecvKey = (string) reader["regionUserRecvKey"];
  308. retval.regionUserSendKey = (string) reader["regionUserSendKey"];
  309. // World Map Addition
  310. LLUUID.TryParse((string)reader["regionMapTexture"], out retval.regionMapTextureID);
  311. LLUUID.TryParse((string)reader["owner_uuid"], out retval.owner_uuid);
  312. }
  313. else
  314. {
  315. return null;
  316. }
  317. return retval;
  318. }
  319. /// <summary>
  320. /// Reads a reservation row from a database reader
  321. /// </summary>
  322. /// <param name="reader">An active database reader</param>
  323. /// <returns>A reservation data object</returns>
  324. public ReservationData readReservationRow(IDataReader reader)
  325. {
  326. ReservationData retval = new ReservationData();
  327. if (reader.Read())
  328. {
  329. retval.gridRecvKey = (string) reader["gridRecvKey"];
  330. retval.gridSendKey = (string) reader["gridSendKey"];
  331. retval.reservationCompany = (string) reader["resCompany"];
  332. retval.reservationMaxX = Convert.ToInt32(reader["resXMax"].ToString());
  333. retval.reservationMaxY = Convert.ToInt32(reader["resYMax"].ToString());
  334. retval.reservationMinX = Convert.ToInt32(reader["resXMin"].ToString());
  335. retval.reservationMinY = Convert.ToInt32(reader["resYMin"].ToString());
  336. retval.reservationName = (string) reader["resName"];
  337. retval.status = Convert.ToInt32(reader["status"].ToString()) == 1;
  338. LLUUID.TryParse((string) reader["userUUID"], out retval.userUUID);
  339. }
  340. else
  341. {
  342. return null;
  343. }
  344. return retval;
  345. }
  346. /// <summary>
  347. /// Reads an agent row from a database reader
  348. /// </summary>
  349. /// <param name="reader">An active database reader</param>
  350. /// <returns>A user session agent</returns>
  351. public UserAgentData readAgentRow(IDataReader reader)
  352. {
  353. UserAgentData retval = new UserAgentData();
  354. if (reader.Read())
  355. {
  356. // Agent IDs
  357. if (!LLUUID.TryParse((string)reader["UUID"], out retval.UUID))
  358. return null;
  359. LLUUID.TryParse((string) reader["sessionID"], out retval.sessionID);
  360. LLUUID.TryParse((string)reader["secureSessionID"], out retval.secureSessionID);
  361. // Agent Who?
  362. retval.agentIP = (string) reader["agentIP"];
  363. retval.agentPort = Convert.ToUInt32(reader["agentPort"].ToString());
  364. retval.agentOnline = Convert.ToBoolean(Convert.ToInt16(reader["agentOnline"].ToString()));
  365. // Login/Logout times (UNIX Epoch)
  366. retval.loginTime = Convert.ToInt32(reader["loginTime"].ToString());
  367. retval.logoutTime = Convert.ToInt32(reader["logoutTime"].ToString());
  368. // Current position
  369. retval.currentRegion = new LLUUID((string)reader["currentRegion"]);
  370. retval.currentHandle = Convert.ToUInt64(reader["currentHandle"].ToString());
  371. LLVector3.TryParse((string) reader["currentPos"], out retval.currentPos);
  372. }
  373. else
  374. {
  375. return null;
  376. }
  377. return retval;
  378. }
  379. /// <summary>
  380. /// Reads a user profile from an active data reader
  381. /// </summary>
  382. /// <param name="reader">An active database reader</param>
  383. /// <returns>A user profile</returns>
  384. public UserProfileData readUserRow(IDataReader reader)
  385. {
  386. UserProfileData retval = new UserProfileData();
  387. if (reader.Read())
  388. {
  389. if (!LLUUID.TryParse((string)reader["UUID"], out retval.UUID))
  390. return null;
  391. retval.username = (string) reader["username"];
  392. retval.surname = (string) reader["lastname"];
  393. retval.passwordHash = (string) reader["passwordHash"];
  394. retval.passwordSalt = (string) reader["passwordSalt"];
  395. retval.homeRegion = Convert.ToUInt64(reader["homeRegion"].ToString());
  396. retval.homeLocation = new LLVector3(
  397. Convert.ToSingle(reader["homeLocationX"].ToString()),
  398. Convert.ToSingle(reader["homeLocationY"].ToString()),
  399. Convert.ToSingle(reader["homeLocationZ"].ToString()));
  400. retval.homeLookAt = new LLVector3(
  401. Convert.ToSingle(reader["homeLookAtX"].ToString()),
  402. Convert.ToSingle(reader["homeLookAtY"].ToString()),
  403. Convert.ToSingle(reader["homeLookAtZ"].ToString()));
  404. retval.created = Convert.ToInt32(reader["created"].ToString());
  405. retval.lastLogin = Convert.ToInt32(reader["lastLogin"].ToString());
  406. retval.userInventoryURI = (string) reader["userInventoryURI"];
  407. retval.userAssetURI = (string) reader["userAssetURI"];
  408. retval.profileCanDoMask = Convert.ToUInt32(reader["profileCanDoMask"].ToString());
  409. retval.profileWantDoMask = Convert.ToUInt32(reader["profileWantDoMask"].ToString());
  410. if (reader.IsDBNull(reader.GetOrdinal("profileAboutText")))
  411. retval.profileAboutText = "";
  412. else
  413. retval.profileAboutText = (string) reader["profileAboutText"];
  414. if (reader.IsDBNull(reader.GetOrdinal("profileFirstText")))
  415. retval.profileFirstText = "";
  416. else
  417. retval.profileFirstText = (string)reader["profileFirstText"];
  418. if (reader.IsDBNull(reader.GetOrdinal("profileImage")))
  419. retval.profileImage = LLUUID.Zero;
  420. else
  421. LLUUID.TryParse((string)reader["profileImage"], out retval.profileImage);
  422. if (reader.IsDBNull(reader.GetOrdinal("profileFirstImage")))
  423. retval.profileFirstImage = LLUUID.Zero;
  424. else
  425. LLUUID.TryParse((string)reader["profileFirstImage"], out retval.profileFirstImage);
  426. if(reader.IsDBNull(reader.GetOrdinal("webLoginKey")))
  427. {
  428. retval.webLoginKey = LLUUID.Zero;
  429. }
  430. else
  431. {
  432. LLUUID.TryParse((string)reader["webLoginKey"], out retval.webLoginKey);
  433. }
  434. }
  435. else
  436. {
  437. return null;
  438. }
  439. return retval;
  440. }
  441. /// <summary>
  442. /// Inserts a new row into the log database
  443. /// </summary>
  444. /// <param name="serverDaemon">The daemon which triggered this event</param>
  445. /// <param name="target">Who were we operating on when this occured (region UUID, user UUID, etc)</param>
  446. /// <param name="methodCall">The method call where the problem occured</param>
  447. /// <param name="arguments">The arguments passed to the method</param>
  448. /// <param name="priority">How critical is this?</param>
  449. /// <param name="logMessage">Extra message info</param>
  450. /// <returns>Saved successfully?</returns>
  451. public bool insertLogRow(string serverDaemon, string target, string methodCall, string arguments, int priority,
  452. string logMessage)
  453. {
  454. string sql = "INSERT INTO logs (`target`, `server`, `method`, `arguments`, `priority`, `message`) VALUES ";
  455. sql += "(?target, ?server, ?method, ?arguments, ?priority, ?message)";
  456. Dictionary<string, string> parameters = new Dictionary<string, string>();
  457. parameters["?server"] = serverDaemon;
  458. parameters["?target"] = target;
  459. parameters["?method"] = methodCall;
  460. parameters["?arguments"] = arguments;
  461. parameters["?priority"] = priority.ToString();
  462. parameters["?message"] = logMessage;
  463. bool returnval = false;
  464. try
  465. {
  466. IDbCommand result = Query(sql, parameters);
  467. if (result.ExecuteNonQuery() == 1)
  468. returnval = true;
  469. result.Dispose();
  470. }
  471. catch (Exception e)
  472. {
  473. m_log.Error(e.ToString());
  474. return false;
  475. }
  476. return returnval;
  477. }
  478. /// <summary>
  479. /// Creates a new user and inserts it into the database
  480. /// </summary>
  481. /// <param name="uuid">User ID</param>
  482. /// <param name="username">First part of the login</param>
  483. /// <param name="lastname">Second part of the login</param>
  484. /// <param name="passwordHash">A salted hash of the users password</param>
  485. /// <param name="passwordSalt">The salt used for the password hash</param>
  486. /// <param name="homeRegion">A regionHandle of the users home region</param>
  487. /// <param name="homeLocX">Home region position vector</param>
  488. /// <param name="homeLocY">Home region position vector</param>
  489. /// <param name="homeLocZ">Home region position vector</param>
  490. /// <param name="homeLookAtX">Home region 'look at' vector</param>
  491. /// <param name="homeLookAtY">Home region 'look at' vector</param>
  492. /// <param name="homeLookAtZ">Home region 'look at' vector</param>
  493. /// <param name="created">Account created (unix timestamp)</param>
  494. /// <param name="lastlogin">Last login (unix timestamp)</param>
  495. /// <param name="inventoryURI">Users inventory URI</param>
  496. /// <param name="assetURI">Users asset URI</param>
  497. /// <param name="canDoMask">I can do mask</param>
  498. /// <param name="wantDoMask">I want to do mask</param>
  499. /// <param name="aboutText">Profile text</param>
  500. /// <param name="firstText">Firstlife text</param>
  501. /// <param name="profileImage">UUID for profile image</param>
  502. /// <param name="firstImage">UUID for firstlife image</param>
  503. /// <returns>Success?</returns>
  504. public bool insertUserRow(LLUUID uuid, string username, string lastname, string passwordHash,
  505. string passwordSalt, UInt64 homeRegion, float homeLocX, float homeLocY, float homeLocZ,
  506. float homeLookAtX, float homeLookAtY, float homeLookAtZ, int created, int lastlogin,
  507. string inventoryURI, string assetURI, uint canDoMask, uint wantDoMask,
  508. string aboutText, string firstText,
  509. LLUUID profileImage, LLUUID firstImage, LLUUID webLoginKey)
  510. {
  511. m_log.Debug("[MySQLManager]: Fetching profile for " + uuid.ToString());
  512. string sql =
  513. "INSERT INTO users (`UUID`, `username`, `lastname`, `passwordHash`, `passwordSalt`, `homeRegion`, ";
  514. sql +=
  515. "`homeLocationX`, `homeLocationY`, `homeLocationZ`, `homeLookAtX`, `homeLookAtY`, `homeLookAtZ`, `created`, ";
  516. sql +=
  517. "`lastLogin`, `userInventoryURI`, `userAssetURI`, `profileCanDoMask`, `profileWantDoMask`, `profileAboutText`, ";
  518. sql += "`profileFirstText`, `profileImage`, `profileFirstImage`, `webLoginKey`) VALUES ";
  519. sql += "(?UUID, ?username, ?lastname, ?passwordHash, ?passwordSalt, ?homeRegion, ";
  520. sql +=
  521. "?homeLocationX, ?homeLocationY, ?homeLocationZ, ?homeLookAtX, ?homeLookAtY, ?homeLookAtZ, ?created, ";
  522. sql +=
  523. "?lastLogin, ?userInventoryURI, ?userAssetURI, ?profileCanDoMask, ?profileWantDoMask, ?profileAboutText, ";
  524. sql += "?profileFirstText, ?profileImage, ?profileFirstImage, ?webLoginKey)";
  525. Dictionary<string, string> parameters = new Dictionary<string, string>();
  526. parameters["?UUID"] = uuid.ToString();
  527. parameters["?username"] = username.ToString();
  528. parameters["?lastname"] = lastname.ToString();
  529. parameters["?passwordHash"] = passwordHash.ToString();
  530. parameters["?passwordSalt"] = passwordSalt.ToString();
  531. parameters["?homeRegion"] = homeRegion.ToString();
  532. parameters["?homeLocationX"] = homeLocX.ToString();
  533. parameters["?homeLocationY"] = homeLocY.ToString();
  534. parameters["?homeLocationZ"] = homeLocZ.ToString();
  535. parameters["?homeLookAtX"] = homeLookAtX.ToString();
  536. parameters["?homeLookAtY"] = homeLookAtY.ToString();
  537. parameters["?homeLookAtZ"] = homeLookAtZ.ToString();
  538. parameters["?created"] = created.ToString();
  539. parameters["?lastLogin"] = lastlogin.ToString();
  540. parameters["?userInventoryURI"] = String.Empty;
  541. parameters["?userAssetURI"] = String.Empty;
  542. parameters["?profileCanDoMask"] = "0";
  543. parameters["?profileWantDoMask"] = "0";
  544. parameters["?profileAboutText"] = aboutText;
  545. parameters["?profileFirstText"] = firstText;
  546. parameters["?profileImage"] = profileImage.ToString();
  547. parameters["?profileFirstImage"] = firstImage.ToString();
  548. parameters["?webLoginKey"] = string.Empty;
  549. bool returnval = false;
  550. try
  551. {
  552. IDbCommand result = Query(sql, parameters);
  553. if (result.ExecuteNonQuery() == 1)
  554. returnval = true;
  555. result.Dispose();
  556. }
  557. catch (Exception e)
  558. {
  559. m_log.Error(e.ToString());
  560. return false;
  561. }
  562. m_log.Debug("[MySQLManager]: Fetch user retval == " + returnval.ToString());
  563. return returnval;
  564. }
  565. /// <summary>
  566. /// Creates a new user and inserts it into the database
  567. /// </summary>
  568. /// <param name="uuid">User ID</param>
  569. /// <param name="username">First part of the login</param>
  570. /// <param name="lastname">Second part of the login</param>
  571. /// <param name="passwordHash">A salted hash of the users password</param>
  572. /// <param name="passwordSalt">The salt used for the password hash</param>
  573. /// <param name="homeRegion">A regionHandle of the users home region</param>
  574. /// <param name="homeLocX">Home region position vector</param>
  575. /// <param name="homeLocY">Home region position vector</param>
  576. /// <param name="homeLocZ">Home region position vector</param>
  577. /// <param name="homeLookAtX">Home region 'look at' vector</param>
  578. /// <param name="homeLookAtY">Home region 'look at' vector</param>
  579. /// <param name="homeLookAtZ">Home region 'look at' vector</param>
  580. /// <param name="created">Account created (unix timestamp)</param>
  581. /// <param name="lastlogin">Last login (unix timestamp)</param>
  582. /// <param name="inventoryURI">Users inventory URI</param>
  583. /// <param name="assetURI">Users asset URI</param>
  584. /// <param name="canDoMask">I can do mask</param>
  585. /// <param name="wantDoMask">I want to do mask</param>
  586. /// <param name="aboutText">Profile text</param>
  587. /// <param name="firstText">Firstlife text</param>
  588. /// <param name="profileImage">UUID for profile image</param>
  589. /// <param name="firstImage">UUID for firstlife image</param>
  590. /// <returns>Success?</returns>
  591. public bool updateUserRow(LLUUID uuid, string username, string lastname, string passwordHash,
  592. string passwordSalt, UInt64 homeRegion, float homeLocX, float homeLocY, float homeLocZ,
  593. float homeLookAtX, float homeLookAtY, float homeLookAtZ, int created, int lastlogin,
  594. string inventoryURI, string assetURI, uint canDoMask, uint wantDoMask,
  595. string aboutText, string firstText,
  596. LLUUID profileImage, LLUUID firstImage, LLUUID webLoginKey)
  597. {
  598. string sql = "UPDATE users SET `username` = ?username , `lastname` = ?lastname ";
  599. sql += ", `passwordHash` = ?passwordHash , `passwordSalt` = ?passwordSalt , ";
  600. sql += "`homeRegion` = ?homeRegion , `homeLocationX` = ?homeLocationX , ";
  601. sql += "`homeLocationY` = ?homeLocationY , `homeLocationZ` = ?homeLocationZ , ";
  602. sql += "`homeLookAtX` = ?homeLookAtX , `homeLookAtY` = ?homeLookAtY , ";
  603. sql += "`homeLookAtZ` = ?homeLookAtZ , `created` = ?created , `lastLogin` = ?lastLogin , ";
  604. sql += "`userInventoryURI` = ?userInventoryURI , `userAssetURI` = ?userAssetURI , ";
  605. sql += "`profileCanDoMask` = ?profileCanDoMask , `profileWantDoMask` = ?profileWantDoMask , ";
  606. sql += "`profileAboutText` = ?profileAboutText , `profileFirstText` = ?profileFirstText, ";
  607. sql += "`profileImage` = ?profileImage , `profileFirstImage` = ?profileFirstImage , ";
  608. sql += "`webLoginKey` = ?webLoginKey WHERE UUID = ?UUID";
  609. Dictionary<string, string> parameters = new Dictionary<string, string>();
  610. parameters["?UUID"] = uuid.ToString();
  611. parameters["?username"] = username.ToString();
  612. parameters["?lastname"] = lastname.ToString();
  613. parameters["?passwordHash"] = passwordHash.ToString();
  614. parameters["?passwordSalt"] = passwordSalt.ToString();
  615. parameters["?homeRegion"] = homeRegion.ToString();
  616. parameters["?homeLocationX"] = homeLocX.ToString();
  617. parameters["?homeLocationY"] = homeLocY.ToString();
  618. parameters["?homeLocationZ"] = homeLocZ.ToString();
  619. parameters["?homeLookAtX"] = homeLookAtX.ToString();
  620. parameters["?homeLookAtY"] = homeLookAtY.ToString();
  621. parameters["?homeLookAtZ"] = homeLookAtZ.ToString();
  622. parameters["?created"] = created.ToString();
  623. parameters["?lastLogin"] = lastlogin.ToString();
  624. parameters["?userInventoryURI"] = inventoryURI;
  625. parameters["?userAssetURI"] = assetURI;
  626. parameters["?profileCanDoMask"] = "0";
  627. parameters["?profileWantDoMask"] = "0";
  628. parameters["?profileAboutText"] = aboutText;
  629. parameters["?profileFirstText"] = firstText;
  630. parameters["?profileImage"] = profileImage.ToString();
  631. parameters["?profileFirstImage"] = firstImage.ToString();
  632. parameters["?webLoginKey"] = webLoginKey.ToString();
  633. bool returnval = false;
  634. try
  635. {
  636. IDbCommand result = Query(sql, parameters);
  637. if (result.ExecuteNonQuery() == 1)
  638. returnval = true;
  639. result.Dispose();
  640. }
  641. catch (Exception e)
  642. {
  643. m_log.Error(e.ToString());
  644. return false;
  645. }
  646. m_log.Debug("[MySQLManager]: update user retval == " + returnval.ToString());
  647. return returnval;
  648. }
  649. /// <summary>
  650. /// Inserts a new region into the database
  651. /// </summary>
  652. /// <param name="profile">The region to insert</param>
  653. /// <returns>Success?</returns>
  654. public bool insertRegion(RegionProfileData regiondata)
  655. {
  656. bool GRID_ONLY_UPDATE_NECESSARY_DATA = false;
  657. string sql = String.Empty;
  658. if (GRID_ONLY_UPDATE_NECESSARY_DATA)
  659. {
  660. sql += "INSERT INTO ";
  661. }
  662. else
  663. {
  664. sql += "REPLACE INTO ";
  665. }
  666. sql += "regions (regionHandle, regionName, uuid, regionRecvKey, regionSecret, regionSendKey, regionDataURI, ";
  667. sql +=
  668. "serverIP, serverPort, serverURI, locX, locY, locZ, eastOverrideHandle, westOverrideHandle, southOverrideHandle, northOverrideHandle, regionAssetURI, regionAssetRecvKey, ";
  669. // part of an initial brutish effort to provide accurate information (as per the xml region spec)
  670. // wrt the ownership of a given region
  671. // the (very bad) assumption is that this value is being read and handled inconsistently or
  672. // not at all. Current strategy is to put the code in place to support the validity of this information
  673. // and to roll forward debugging any issues from that point
  674. //
  675. // this particular section of the mod attempts to implement the commit of a supplied value
  676. // server for the UUID of the region's owner (master avatar). It consists of the addition of the column and value to the relevant sql,
  677. // as well as the related parameterization
  678. sql +=
  679. "regionAssetSendKey, regionUserURI, regionUserRecvKey, regionUserSendKey, regionMapTexture, serverHttpPort, serverRemotingPort, owner_uuid, originUUID) VALUES ";
  680. sql += "(?regionHandle, ?regionName, ?uuid, ?regionRecvKey, ?regionSecret, ?regionSendKey, ?regionDataURI, ";
  681. sql +=
  682. "?serverIP, ?serverPort, ?serverURI, ?locX, ?locY, ?locZ, ?eastOverrideHandle, ?westOverrideHandle, ?southOverrideHandle, ?northOverrideHandle, ?regionAssetURI, ?regionAssetRecvKey, ";
  683. sql +=
  684. "?regionAssetSendKey, ?regionUserURI, ?regionUserRecvKey, ?regionUserSendKey, ?regionMapTexture, ?serverHttpPort, ?serverRemotingPort, ?owner_uuid, ?originUUID)";
  685. if (GRID_ONLY_UPDATE_NECESSARY_DATA)
  686. {
  687. sql += "ON DUPLICATE KEY UPDATE serverIP = ?serverIP, serverPort = ?serverPort, serverURI = ?serverURI, owner_uuid - ?owner_uuid;";
  688. }
  689. else
  690. {
  691. sql += ";";
  692. }
  693. Dictionary<string, string> parameters = new Dictionary<string, string>();
  694. parameters["?regionHandle"] = regiondata.regionHandle.ToString();
  695. parameters["?regionName"] = regiondata.regionName.ToString();
  696. parameters["?uuid"] = regiondata.UUID.ToString();
  697. parameters["?regionRecvKey"] = regiondata.regionRecvKey.ToString();
  698. parameters["?regionSecret"] = regiondata.regionSecret.ToString();
  699. parameters["?regionSendKey"] = regiondata.regionSendKey.ToString();
  700. parameters["?regionDataURI"] = regiondata.regionDataURI.ToString();
  701. parameters["?serverIP"] = regiondata.serverIP.ToString();
  702. parameters["?serverPort"] = regiondata.serverPort.ToString();
  703. parameters["?serverURI"] = regiondata.serverURI.ToString();
  704. parameters["?locX"] = regiondata.regionLocX.ToString();
  705. parameters["?locY"] = regiondata.regionLocY.ToString();
  706. parameters["?locZ"] = regiondata.regionLocZ.ToString();
  707. parameters["?eastOverrideHandle"] = regiondata.regionEastOverrideHandle.ToString();
  708. parameters["?westOverrideHandle"] = regiondata.regionWestOverrideHandle.ToString();
  709. parameters["?northOverrideHandle"] = regiondata.regionNorthOverrideHandle.ToString();
  710. parameters["?southOverrideHandle"] = regiondata.regionSouthOverrideHandle.ToString();
  711. parameters["?regionAssetURI"] = regiondata.regionAssetURI.ToString();
  712. parameters["?regionAssetRecvKey"] = regiondata.regionAssetRecvKey.ToString();
  713. parameters["?regionAssetSendKey"] = regiondata.regionAssetSendKey.ToString();
  714. parameters["?regionUserURI"] = regiondata.regionUserURI.ToString();
  715. parameters["?regionUserRecvKey"] = regiondata.regionUserRecvKey.ToString();
  716. parameters["?regionUserSendKey"] = regiondata.regionUserSendKey.ToString();
  717. parameters["?regionMapTexture"] = regiondata.regionMapTextureID.ToString();
  718. parameters["?serverHttpPort"] = regiondata.httpPort.ToString();
  719. parameters["?serverRemotingPort"] = regiondata.remotingPort.ToString();
  720. parameters["?owner_uuid"] = regiondata.owner_uuid.ToString();
  721. parameters["?originUUID"] = regiondata.originUUID.ToString();
  722. bool returnval = false;
  723. try
  724. {
  725. IDbCommand result = Query(sql, parameters);
  726. //Console.WriteLine(result.CommandText);
  727. int x;
  728. if ((x = result.ExecuteNonQuery()) > 0)
  729. {
  730. returnval = true;
  731. }
  732. result.Dispose();
  733. }
  734. catch (Exception e)
  735. {
  736. m_log.Error(e.ToString());
  737. return false;
  738. }
  739. return returnval;
  740. }
  741. /// <summary>
  742. /// Delete a region from the database
  743. /// </summary>
  744. /// <param name="profile">The region to insert</param>
  745. /// <returns>Success?</returns>
  746. //public bool deleteRegion(RegionProfileData regiondata)
  747. public bool deleteRegion(string uuid)
  748. {
  749. bool returnval = false;
  750. string sql = "DELETE FROM regions WHERE uuid = ?uuid;";
  751. Dictionary<string, string> parameters = new Dictionary<string, string>();
  752. try
  753. {
  754. parameters["?uuid"] = uuid;
  755. IDbCommand result = Query(sql, parameters);
  756. int x;
  757. if ((x = result.ExecuteNonQuery()) > 0)
  758. {
  759. returnval = true;
  760. }
  761. result.Dispose();
  762. }
  763. catch (Exception e)
  764. {
  765. m_log.Error(e.ToString());
  766. return false;
  767. }
  768. return returnval;
  769. }
  770. /// <summary>
  771. /// Creates a new agent and inserts it into the database
  772. /// </summary>
  773. /// <param name="agentdata">The agent data to be inserted</param>
  774. /// <returns>Success?</returns>
  775. public bool insertAgentRow(UserAgentData agentdata)
  776. {
  777. string sql = String.Empty;
  778. sql += "REPLACE INTO ";
  779. sql += "agents (UUID, sessionID, secureSessionID, agentIP, agentPort, agentOnline, loginTime, logoutTime, currentRegion, currentHandle, currentPos) VALUES ";
  780. sql += "(?UUID, ?sessionID, ?secureSessionID, ?agentIP, ?agentPort, ?agentOnline, ?loginTime, ?logoutTime, ?currentRegion, ?currentHandle, ?currentPos);";
  781. Dictionary<string, string> parameters = new Dictionary<string, string>();
  782. parameters["?UUID"] = agentdata.UUID.ToString();
  783. parameters["?sessionID"] = agentdata.sessionID.ToString();
  784. parameters["?secureSessionID"] = agentdata.secureSessionID.ToString();
  785. parameters["?agentIP"] = agentdata.agentIP.ToString();
  786. parameters["?agentPort"] = agentdata.agentPort.ToString();
  787. parameters["?agentOnline"] = (agentdata.agentOnline == true) ? "1" : "0";
  788. parameters["?loginTime"] = agentdata.loginTime.ToString();
  789. parameters["?logoutTime"] = agentdata.logoutTime.ToString();
  790. parameters["?currentRegion"] = agentdata.currentRegion.ToString();
  791. parameters["?currentHandle"] = agentdata.currentHandle.ToString();
  792. parameters["?currentPos"] = "<" + ((int)agentdata.currentPos.X).ToString() + "," + ((int)agentdata.currentPos.Y).ToString() + "," + ((int)agentdata.currentPos.Z).ToString() + ">";
  793. bool returnval = false;
  794. try
  795. {
  796. IDbCommand result = Query(sql, parameters);
  797. //Console.WriteLine(result.CommandText);
  798. int x;
  799. if ((x = result.ExecuteNonQuery()) > 0)
  800. {
  801. returnval = true;
  802. }
  803. result.Dispose();
  804. }
  805. catch (Exception e)
  806. {
  807. m_log.Error(e.ToString());
  808. return false;
  809. }
  810. return returnval;
  811. }
  812. }
  813. }