123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690 |
- /*
- * Copyright (c) Contributors, http://opensimulator.org/
- * See CONTRIBUTORS.TXT for a full list of copyright holders.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * * Neither the name of the OpenSim Project nor the
- * names of its contributors may be used to endorse or promote products
- * derived from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
- * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
- * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
- * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
- * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
- * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
- * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
- * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
- * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- *
- */
- using System;
- using System.Collections.Generic;
- using System.Data;
- using System.IO;
- using System.Reflection;
- using libsecondlife;
- using MySql.Data.MySqlClient;
- using OpenSim.Framework.Console;
- namespace OpenSim.Framework.Data.MySQL
- {
- /// <summary>
- /// A MySQL Database manager
- /// </summary>
- internal class MySQLManager
- {
- /// <summary>
- /// The database connection object
- /// </summary>
- private MySqlConnection dbcon;
- /// <summary>
- /// Connection string for ADO.net
- /// </summary>
- private string connectionString;
- /// <summary>
- /// Initialises and creates a new MySQL connection and maintains it.
- /// </summary>
- /// <param name="hostname">The MySQL server being connected to</param>
- /// <param name="database">The name of the MySQL database being used</param>
- /// <param name="username">The username logging into the database</param>
- /// <param name="password">The password for the user logging in</param>
- /// <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>
- public MySQLManager(string hostname, string database, string username, string password, string cpooling,
- string port)
- {
- try
- {
- connectionString = "Server=" + hostname + ";Port=" + port + ";Database=" + database + ";User ID=" +
- username + ";Password=" + password + ";Pooling=" + cpooling + ";";
- dbcon = new MySqlConnection(connectionString);
- dbcon.Open();
- MainLog.Instance.Verbose("MYSQL", "Connection established");
- }
- catch (Exception e)
- {
- throw new Exception("Error initialising MySql Database: " + e.ToString());
- }
- }
- /// <summary>
- /// Get the connection being used
- /// </summary>
- public MySqlConnection Connection
- {
- get { return dbcon; }
- }
- /// <summary>
- /// Shuts down the database connection
- /// </summary>
- public void Close()
- {
- dbcon.Close();
- dbcon = null;
- }
- /// <summary>
- /// Reconnects to the database
- /// </summary>
- public void Reconnect()
- {
- lock (dbcon)
- {
- try
- {
- // Close the DB connection
- dbcon.Close();
- // Try reopen it
- dbcon = new MySqlConnection(connectionString);
- dbcon.Open();
- }
- catch (Exception e)
- {
- MainLog.Instance.Error("Unable to reconnect to database " + e.ToString());
- }
- }
- }
- /// <summary>
- /// Returns the version of this DB provider
- /// </summary>
- /// <returns>A string containing the DB provider</returns>
- public string getVersion()
- {
- Module module = GetType().Module;
- string dllName = module.Assembly.ManifestModule.Name;
- Version dllVersion = module.Assembly.GetName().Version;
- return
- string.Format("{0}.{1}.{2}.{3}", dllVersion.Major, dllVersion.Minor, dllVersion.Build,
- dllVersion.Revision);
- }
- /// <summary>
- /// Extract a named string resource from the embedded resources
- /// </summary>
- /// <param name="name">name of embedded resource</param>
- /// <returns>string contained within the embedded resource</returns>
- private string getResourceString(string name)
- {
- Assembly assem = GetType().Assembly;
- string[] names = assem.GetManifestResourceNames();
- foreach (string s in names)
- if (s.EndsWith(name))
- using (Stream resource = assem.GetManifestResourceStream(s))
- {
- using (StreamReader resourceReader = new StreamReader(resource))
- {
- string resourceString = resourceReader.ReadToEnd();
- return resourceString;
- }
- }
- throw new Exception(string.Format("Resource '{0}' was not found", name));
- }
- /// <summary>
- /// Execute a SQL statement stored in a resource, as a string
- /// </summary>
- /// <param name="name"></param>
- public void ExecuteResourceSql(string name)
- {
- MySqlCommand cmd = new MySqlCommand(getResourceString(name), dbcon);
- cmd.ExecuteNonQuery();
- }
- /// <summary>
- /// Given a list of tables, return the version of the tables, as seen in the database
- /// </summary>
- /// <param name="tableList"></param>
- public void GetTableVersion(Dictionary<string, string> tableList)
- {
- lock (dbcon)
- {
- MySqlCommand tablesCmd =
- new MySqlCommand(
- "SELECT TABLE_NAME, TABLE_COMMENT FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA=?dbname",
- dbcon);
- tablesCmd.Parameters.AddWithValue("?dbname", dbcon.Database);
- using (MySqlDataReader tables = tablesCmd.ExecuteReader())
- {
- while (tables.Read())
- {
- try
- {
- string tableName = (string) tables["TABLE_NAME"];
- string comment = (string) tables["TABLE_COMMENT"];
- if (tableList.ContainsKey(tableName))
- tableList[tableName] = comment;
- }
- catch (Exception e)
- {
- MainLog.Instance.Error(e.ToString());
- }
- }
- tables.Close();
- }
- }
- }
- // at some time this code should be cleaned up
- /// <summary>
- /// Runs a query with protection against SQL Injection by using parameterised input.
- /// </summary>
- /// <param name="sql">The SQL string - replace any variables such as WHERE x = "y" with WHERE x = @y</param>
- /// <param name="parameters">The parameters - index so that @y is indexed as 'y'</param>
- /// <returns>A MySQL DB Command</returns>
- public IDbCommand Query(string sql, Dictionary<string, string> parameters)
- {
- try
- {
- MySqlCommand dbcommand = (MySqlCommand) dbcon.CreateCommand();
- dbcommand.CommandText = sql;
- foreach (KeyValuePair<string, string> param in parameters)
- {
- dbcommand.Parameters.AddWithValue(param.Key, param.Value);
- }
- return (IDbCommand) dbcommand;
- }
- catch
- {
- lock (dbcon)
- {
- // Close the DB connection
- try
- {
- dbcon.Close();
- }
- catch
- {
- }
- // Try reopen it
- try
- {
- dbcon = new MySqlConnection(connectionString);
- dbcon.Open();
- }
- catch (Exception e)
- {
- MainLog.Instance.Error("Unable to reconnect to database " + e.ToString());
- }
- // Run the query again
- try
- {
- MySqlCommand dbcommand = (MySqlCommand) dbcon.CreateCommand();
- dbcommand.CommandText = sql;
- foreach (KeyValuePair<string, string> param in parameters)
- {
- dbcommand.Parameters.AddWithValue(param.Key, param.Value);
- }
- return (IDbCommand) dbcommand;
- }
- catch (Exception e)
- {
- // Return null if it fails.
- MainLog.Instance.Error("Failed during Query generation: " + e.ToString());
- return null;
- }
- }
- }
- }
- /// <summary>
- /// Reads a region row from a database reader
- /// </summary>
- /// <param name="reader">An active database reader</param>
- /// <returns>A region profile</returns>
- public RegionProfileData readSimRow(IDataReader reader)
- {
- RegionProfileData retval = new RegionProfileData();
- if (reader.Read())
- {
- // Region Main
- retval.regionHandle = Convert.ToUInt64(reader["regionHandle"].ToString());
- retval.regionName = (string) reader["regionName"];
- retval.UUID = new LLUUID((string) reader["uuid"]);
- // Secrets
- retval.regionRecvKey = (string) reader["regionRecvKey"];
- retval.regionSecret = (string) reader["regionSecret"];
- retval.regionSendKey = (string) reader["regionSendKey"];
- // Region Server
- retval.regionDataURI = (string) reader["regionDataURI"];
- retval.regionOnline = false; // Needs to be pinged before this can be set.
- retval.serverIP = (string) reader["serverIP"];
- retval.serverPort = uint.Parse(reader["serverPort"].ToString());
- //retval.serverPort = (uint) reader["serverPort"]; // this caused exceptions
- retval.serverURI = (string) reader["serverURI"];
- retval.httpPort = Convert.ToUInt32(reader["serverHttpPort"].ToString());
- retval.remotingPort = Convert.ToUInt32(reader["serverRemotingPort"].ToString());
- // Location
- retval.regionLocX = Convert.ToUInt32(reader["locX"].ToString());
- retval.regionLocY = Convert.ToUInt32(reader["locY"].ToString());
- retval.regionLocZ = Convert.ToUInt32(reader["locZ"].ToString());
- // Neighbours - 0 = No Override
- retval.regionEastOverrideHandle = Convert.ToUInt64(reader["eastOverrideHandle"].ToString());
- retval.regionWestOverrideHandle = Convert.ToUInt64(reader["westOverrideHandle"].ToString());
- retval.regionSouthOverrideHandle = Convert.ToUInt64(reader["southOverrideHandle"].ToString());
- retval.regionNorthOverrideHandle = Convert.ToUInt64(reader["northOverrideHandle"].ToString());
- // Assets
- retval.regionAssetURI = (string) reader["regionAssetURI"];
- retval.regionAssetRecvKey = (string) reader["regionAssetRecvKey"];
- retval.regionAssetSendKey = (string) reader["regionAssetSendKey"];
- // Userserver
- retval.regionUserURI = (string) reader["regionUserURI"];
- retval.regionUserRecvKey = (string) reader["regionUserRecvKey"];
- retval.regionUserSendKey = (string) reader["regionUserSendKey"];
- // World Map Addition
- string tempRegionMap = reader["regionMapTexture"].ToString();
- if (tempRegionMap != "")
- {
- retval.regionMapTextureID = new LLUUID(tempRegionMap);
- }
- else
- {
- retval.regionMapTextureID = LLUUID.Zero;
- }
- }
- else
- {
- return null;
- }
- return retval;
- }
- /// <summary>
- /// Reads a reservation row from a database reader
- /// </summary>
- /// <param name="reader">An active database reader</param>
- /// <returns>A reservation data object</returns>
- public ReservationData readReservationRow(IDataReader reader)
- {
- ReservationData retval = new ReservationData();
- if (reader.Read())
- {
- retval.gridRecvKey = (string) reader["gridRecvKey"];
- retval.gridSendKey = (string) reader["gridSendKey"];
- retval.reservationCompany = (string) reader["resCompany"];
- retval.reservationMaxX = Convert.ToInt32(reader["resXMax"].ToString());
- retval.reservationMaxY = Convert.ToInt32(reader["resYMax"].ToString());
- retval.reservationMinX = Convert.ToInt32(reader["resXMin"].ToString());
- retval.reservationMinY = Convert.ToInt32(reader["resYMin"].ToString());
- retval.reservationName = (string) reader["resName"];
- retval.status = Convert.ToInt32(reader["status"].ToString()) == 1;
- retval.userUUID = new LLUUID((string) reader["userUUID"]);
- }
- else
- {
- return null;
- }
- return retval;
- }
- /// <summary>
- /// Reads an agent row from a database reader
- /// </summary>
- /// <param name="reader">An active database reader</param>
- /// <returns>A user session agent</returns>
- public UserAgentData readAgentRow(IDataReader reader)
- {
- UserAgentData retval = new UserAgentData();
- if (reader.Read())
- {
- // Agent IDs
- retval.UUID = new LLUUID((string) reader["UUID"]);
- retval.sessionID = new LLUUID((string) reader["sessionID"]);
- retval.secureSessionID = new LLUUID((string) reader["secureSessionID"]);
- // Agent Who?
- retval.agentIP = (string) reader["agentIP"];
- retval.agentPort = Convert.ToUInt32(reader["agentPort"].ToString());
- retval.agentOnline = Convert.ToBoolean(reader["agentOnline"].ToString());
- // Login/Logout times (UNIX Epoch)
- retval.loginTime = Convert.ToInt32(reader["loginTime"].ToString());
- retval.logoutTime = Convert.ToInt32(reader["logoutTime"].ToString());
- // Current position
- retval.currentRegion = (string) reader["currentRegion"];
- retval.currentHandle = Convert.ToUInt64(reader["currentHandle"].ToString());
- LLVector3.TryParse((string) reader["currentPos"], out retval.currentPos);
- }
- else
- {
- return null;
- }
- return retval;
- }
- /// <summary>
- /// Reads a user profile from an active data reader
- /// </summary>
- /// <param name="reader">An active database reader</param>
- /// <returns>A user profile</returns>
- public UserProfileData readUserRow(IDataReader reader)
- {
- UserProfileData retval = new UserProfileData();
- if (reader.Read())
- {
- retval.UUID = new LLUUID((string) reader["UUID"]);
- retval.username = (string) reader["username"];
- retval.surname = (string) reader["lastname"];
- retval.passwordHash = (string) reader["passwordHash"];
- retval.passwordSalt = (string) reader["passwordSalt"];
- retval.homeRegion = Convert.ToUInt64(reader["homeRegion"].ToString());
- retval.homeLocation = new LLVector3(
- Convert.ToSingle(reader["homeLocationX"].ToString()),
- Convert.ToSingle(reader["homeLocationY"].ToString()),
- Convert.ToSingle(reader["homeLocationZ"].ToString()));
- retval.homeLookAt = new LLVector3(
- Convert.ToSingle(reader["homeLookAtX"].ToString()),
- Convert.ToSingle(reader["homeLookAtY"].ToString()),
- Convert.ToSingle(reader["homeLookAtZ"].ToString()));
- retval.created = Convert.ToInt32(reader["created"].ToString());
- retval.lastLogin = Convert.ToInt32(reader["lastLogin"].ToString());
- retval.userInventoryURI = (string) reader["userInventoryURI"];
- retval.userAssetURI = (string) reader["userAssetURI"];
- retval.profileCanDoMask = Convert.ToUInt32(reader["profileCanDoMask"].ToString());
- retval.profileWantDoMask = Convert.ToUInt32(reader["profileWantDoMask"].ToString());
- retval.profileAboutText = (string) reader["profileAboutText"];
- retval.profileFirstText = (string) reader["profileFirstText"];
- retval.profileImage = new LLUUID((string) reader["profileImage"]);
- retval.profileFirstImage = new LLUUID((string) reader["profileFirstImage"]);
- retval.webLoginKey = new LLUUID((string)reader["webLoginKey"]);
- }
- else
- {
- return null;
- }
- return retval;
- }
- /// <summary>
- /// Inserts a new row into the log database
- /// </summary>
- /// <param name="serverDaemon">The daemon which triggered this event</param>
- /// <param name="target">Who were we operating on when this occured (region UUID, user UUID, etc)</param>
- /// <param name="methodCall">The method call where the problem occured</param>
- /// <param name="arguments">The arguments passed to the method</param>
- /// <param name="priority">How critical is this?</param>
- /// <param name="logMessage">Extra message info</param>
- /// <returns>Saved successfully?</returns>
- public bool insertLogRow(string serverDaemon, string target, string methodCall, string arguments, int priority,
- string logMessage)
- {
- string sql = "INSERT INTO logs (`target`, `server`, `method`, `arguments`, `priority`, `message`) VALUES ";
- sql += "(?target, ?server, ?method, ?arguments, ?priority, ?message)";
- Dictionary<string, string> parameters = new Dictionary<string, string>();
- parameters["?server"] = serverDaemon;
- parameters["?target"] = target;
- parameters["?method"] = methodCall;
- parameters["?arguments"] = arguments;
- parameters["?priority"] = priority.ToString();
- parameters["?message"] = logMessage;
- bool returnval = false;
- try
- {
- IDbCommand result = Query(sql, parameters);
- if (result.ExecuteNonQuery() == 1)
- returnval = true;
- result.Dispose();
- }
- catch (Exception e)
- {
- MainLog.Instance.Error(e.ToString());
- return false;
- }
- return returnval;
- }
- /// <summary>
- /// Creates a new user and inserts it into the database
- /// </summary>
- /// <param name="uuid">User ID</param>
- /// <param name="username">First part of the login</param>
- /// <param name="lastname">Second part of the login</param>
- /// <param name="passwordHash">A salted hash of the users password</param>
- /// <param name="passwordSalt">The salt used for the password hash</param>
- /// <param name="homeRegion">A regionHandle of the users home region</param>
- /// <param name="homeLocX">Home region position vector</param>
- /// <param name="homeLocY">Home region position vector</param>
- /// <param name="homeLocZ">Home region position vector</param>
- /// <param name="homeLookAtX">Home region 'look at' vector</param>
- /// <param name="homeLookAtY">Home region 'look at' vector</param>
- /// <param name="homeLookAtZ">Home region 'look at' vector</param>
- /// <param name="created">Account created (unix timestamp)</param>
- /// <param name="lastlogin">Last login (unix timestamp)</param>
- /// <param name="inventoryURI">Users inventory URI</param>
- /// <param name="assetURI">Users asset URI</param>
- /// <param name="canDoMask">I can do mask</param>
- /// <param name="wantDoMask">I want to do mask</param>
- /// <param name="aboutText">Profile text</param>
- /// <param name="firstText">Firstlife text</param>
- /// <param name="profileImage">UUID for profile image</param>
- /// <param name="firstImage">UUID for firstlife image</param>
- /// <returns>Success?</returns>
- public bool insertUserRow(LLUUID uuid, string username, string lastname, string passwordHash,
- string passwordSalt, UInt64 homeRegion, float homeLocX, float homeLocY, float homeLocZ,
- float homeLookAtX, float homeLookAtY, float homeLookAtZ, int created, int lastlogin,
- string inventoryURI, string assetURI, uint canDoMask, uint wantDoMask,
- string aboutText, string firstText,
- LLUUID profileImage, LLUUID firstImage, LLUUID webLoginKey)
- {
- string sql =
- "INSERT INTO users (`UUID`, `username`, `lastname`, `passwordHash`, `passwordSalt`, `homeRegion`, ";
- sql +=
- "`homeLocationX`, `homeLocationY`, `homeLocationZ`, `homeLookAtX`, `homeLookAtY`, `homeLookAtZ`, `created`, ";
- sql +=
- "`lastLogin`, `userInventoryURI`, `userAssetURI`, `profileCanDoMask`, `profileWantDoMask`, `profileAboutText`, ";
- sql += "`profileFirstText`, `profileImage`, `profileFirstImage`, `webLoginKey`) VALUES ";
- sql += "(?UUID, ?username, ?lastname, ?passwordHash, ?passwordSalt, ?homeRegion, ";
- sql +=
- "?homeLocationX, ?homeLocationY, ?homeLocationZ, ?homeLookAtX, ?homeLookAtY, ?homeLookAtZ, ?created, ";
- sql +=
- "?lastLogin, ?userInventoryURI, ?userAssetURI, ?profileCanDoMask, ?profileWantDoMask, ?profileAboutText, ";
- sql += "?profileFirstText, ?profileImage, ?profileFirstImage, ?webLoginKey)";
- Dictionary<string, string> parameters = new Dictionary<string, string>();
- parameters["?UUID"] = uuid.ToString();
- parameters["?username"] = username.ToString();
- parameters["?lastname"] = lastname.ToString();
- parameters["?passwordHash"] = passwordHash.ToString();
- parameters["?passwordSalt"] = passwordSalt.ToString();
- parameters["?homeRegion"] = homeRegion.ToString();
- parameters["?homeLocationX"] = homeLocX.ToString();
- parameters["?homeLocationY"] = homeLocY.ToString();
- parameters["?homeLocationZ"] = homeLocZ.ToString();
- parameters["?homeLookAtX"] = homeLookAtX.ToString();
- parameters["?homeLookAtY"] = homeLookAtY.ToString();
- parameters["?homeLookAtZ"] = homeLookAtZ.ToString();
- parameters["?created"] = created.ToString();
- parameters["?lastLogin"] = lastlogin.ToString();
- parameters["?userInventoryURI"] = "";
- parameters["?userAssetURI"] = "";
- parameters["?profileCanDoMask"] = "0";
- parameters["?profileWantDoMask"] = "0";
- parameters["?profileAboutText"] = "";
- parameters["?profileFirstText"] = "";
- parameters["?profileImage"] = LLUUID.Zero.ToString();
- parameters["?profileFirstImage"] = LLUUID.Zero.ToString();
- parameters["?webLoginKey"] = LLUUID.Random().ToString();
- bool returnval = false;
- try
- {
- IDbCommand result = Query(sql, parameters);
- if (result.ExecuteNonQuery() == 1)
- returnval = true;
- result.Dispose();
- }
- catch (Exception e)
- {
- MainLog.Instance.Error(e.ToString());
- return false;
- }
- return returnval;
- }
- /// <summary>
- /// Inserts a new region into the database
- /// </summary>
- /// <param name="profile">The region to insert</param>
- /// <returns>Success?</returns>
- public bool insertRegion(RegionProfileData regiondata)
- {
- bool GRID_ONLY_UPDATE_NECESSARY_DATA = false;
- string sql = "";
- if (GRID_ONLY_UPDATE_NECESSARY_DATA)
- {
- sql += "INSERT INTO ";
- }
- else
- {
- sql += "REPLACE INTO ";
- }
- sql += "regions (regionHandle, regionName, uuid, regionRecvKey, regionSecret, regionSendKey, regionDataURI, ";
- sql +=
- "serverIP, serverPort, serverURI, locX, locY, locZ, eastOverrideHandle, westOverrideHandle, southOverrideHandle, northOverrideHandle, regionAssetURI, regionAssetRecvKey, ";
- sql +=
- "regionAssetSendKey, regionUserURI, regionUserRecvKey, regionUserSendKey, regionMapTexture, serverHttpPort, serverRemotingPort) VALUES ";
- sql += "(?regionHandle, ?regionName, ?uuid, ?regionRecvKey, ?regionSecret, ?regionSendKey, ?regionDataURI, ";
- sql +=
- "?serverIP, ?serverPort, ?serverURI, ?locX, ?locY, ?locZ, ?eastOverrideHandle, ?westOverrideHandle, ?southOverrideHandle, ?northOverrideHandle, ?regionAssetURI, ?regionAssetRecvKey, ";
- sql +=
- "?regionAssetSendKey, ?regionUserURI, ?regionUserRecvKey, ?regionUserSendKey, ?regionMapTexture, ?serverHttpPort, ?serverRemotingPort)";
- if (GRID_ONLY_UPDATE_NECESSARY_DATA)
- {
- sql += "ON DUPLICATE KEY UPDATE serverIP = ?serverIP, serverPort = ?serverPort, serverURI = ?serverURI;";
- }
- else
- {
- sql += ";";
- }
- Dictionary<string, string> parameters = new Dictionary<string, string>();
- parameters["?regionHandle"] = regiondata.regionHandle.ToString();
- parameters["?regionName"] = regiondata.regionName.ToString();
- parameters["?uuid"] = regiondata.UUID.ToString();
- parameters["?regionRecvKey"] = regiondata.regionRecvKey.ToString();
- parameters["?regionSecret"] = regiondata.regionSecret.ToString();
- parameters["?regionSendKey"] = regiondata.regionSendKey.ToString();
- parameters["?regionDataURI"] = regiondata.regionDataURI.ToString();
- parameters["?serverIP"] = regiondata.serverIP.ToString();
- parameters["?serverPort"] = regiondata.serverPort.ToString();
- parameters["?serverURI"] = regiondata.serverURI.ToString();
- parameters["?locX"] = regiondata.regionLocX.ToString();
- parameters["?locY"] = regiondata.regionLocY.ToString();
- parameters["?locZ"] = regiondata.regionLocZ.ToString();
- parameters["?eastOverrideHandle"] = regiondata.regionEastOverrideHandle.ToString();
- parameters["?westOverrideHandle"] = regiondata.regionWestOverrideHandle.ToString();
- parameters["?northOverrideHandle"] = regiondata.regionNorthOverrideHandle.ToString();
- parameters["?southOverrideHandle"] = regiondata.regionSouthOverrideHandle.ToString();
- parameters["?regionAssetURI"] = regiondata.regionAssetURI.ToString();
- parameters["?regionAssetRecvKey"] = regiondata.regionAssetRecvKey.ToString();
- parameters["?regionAssetSendKey"] = regiondata.regionAssetSendKey.ToString();
- parameters["?regionUserURI"] = regiondata.regionUserURI.ToString();
- parameters["?regionUserRecvKey"] = regiondata.regionUserRecvKey.ToString();
- parameters["?regionUserSendKey"] = regiondata.regionUserSendKey.ToString();
- parameters["?regionMapTexture"] = regiondata.regionMapTextureID.ToString();
- parameters["?serverHttpPort"] = regiondata.httpPort.ToString();
- parameters["?serverRemotingPort"] = regiondata.remotingPort.ToString();
- bool returnval = false;
- try
- {
- IDbCommand result = Query(sql, parameters);
- //Console.WriteLine(result.CommandText);
- int x;
- if ((x = result.ExecuteNonQuery()) > 0)
- {
- returnval = true;
- }
- result.Dispose();
- }
- catch (Exception e)
- {
- MainLog.Instance.Error(e.ToString());
- return false;
- }
- return returnval;
- }
- }
- }
|