1 files changed, 153 insertions, 0 deletions
diff --git a/OpenGridServices/OpenGrid.Framework.Data.MySQL/MySQLUserData.cs b/OpenGridServices/OpenGrid.Framework.Data.MySQL/MySQLUserData.cs
new file mode 100644
index 0000000..57dbfc6
--- /dev/null
+++ b/OpenGridServices/OpenGrid.Framework.Data.MySQL/MySQLUserData.cs
@@ -0,0 +1,153 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+using OpenGrid.Framework.Data;
+using libsecondlife;
+namespace OpenGrid.Framework.Data.MySQL
+{
+    class MySQLUserData : IUserData
+    {
+        public MySQLManager database;
+        public void Initialise()
+        {
+            IniFile GridDataMySqlFile = new IniFile("mysql_connection.ini");
+            string settingHostname = GridDataMySqlFile.ParseFileReadValue("hostname");
+            string settingDatabase = GridDataMySqlFile.ParseFileReadValue("database");
+            string settingUsername = GridDataMySqlFile.ParseFileReadValue("username");
+            string settingPassword = GridDataMySqlFile.ParseFileReadValue("password");
+            string settingPooling = GridDataMySqlFile.ParseFileReadValue("pooling");
+            string settingPort = GridDataMySqlFile.ParseFileReadValue("port");
+            database = new MySQLManager(settingHostname, settingDatabase, settingUsername, settingPassword, settingPooling, settingPort);
+        }
+        public UserProfileData getUserByName(string name)
+        {
+            return getUserByName(name.Split(' ')[0], name.Split(' ')[1]);
+        }
+        public UserProfileData getUserByName(string user, string last)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?first"] = user;
+                    param["?second"] = last;
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM users WHERE username = ?first AND lastname = ?second", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    UserProfileData row = database.getUserRow(reader);
+                    
+                    reader.Close();
+                    result.Dispose();
+                    return row;
+                }
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+        public UserProfileData getUserByUUID(LLUUID uuid)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?uuid"] = uuid.ToStringHyphenated();
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM users WHERE UUID = ?uuid", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    UserProfileData row = database.getUserRow(reader);
+                    reader.Close();
+                    result.Dispose();
+                    return row;
+                }
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+        public UserAgentData getAgentByName(string name)
+        {
+            return getAgentByName(name.Split(' ')[0], name.Split(' ')[1]);
+        }
+        public UserAgentData getAgentByName(string user, string last)
+        {
+            UserProfileData profile = getUserByName(user, last);
+            return getAgentByUUID(profile.UUID);
+        }
+        public UserAgentData getAgentByUUID(LLUUID uuid)
+        {
+            try
+            {
+                lock (database)
+                {
+                    Dictionary<string, string> param = new Dictionary<string, string>();
+                    param["?uuid"] = uuid.ToStringHyphenated();
+                    System.Data.IDbCommand result = database.Query("SELECT * FROM agents WHERE UUID = ?uuid", param);
+                    System.Data.IDataReader reader = result.ExecuteReader();
+                    UserAgentData row = database.getAgentRow(reader);
+                    reader.Close();
+                    result.Dispose();
+                    return row;
+                }
+            }
+            catch (Exception e)
+            {
+                Console.WriteLine(e.ToString());
+                return null;
+            }
+        }
+        public void addNewUserProfile(UserProfileData user)
+        {
+        }
+        public void addNewUserAgent(UserAgentData agent)
+        {
+            // Do nothing.
+        }
+        public bool moneyTransferRequest(LLUUID from, LLUUID to, uint amount)
+        {
+            return false;
+        }
+        public bool inventoryTransferRequest(LLUUID from, LLUUID to, LLUUID item)
+        {
+            return false;
+        }
+        public string getName()
+        {
+            return "MySQL Userdata Interface";
+        }
+        public string getVersion()
+        {
+            return "0.1";
+        }
+    }
+}

diff --git a/OpenGridServices/OpenGrid.Framework.Data.MySQL/MySQLUserData.cs b/OpenGridServices/OpenGrid.Framework.Data.MySQL/MySQLUserData.cs new file mode 100644 index 0000000..57dbfc6 --- /dev/null +++ b/OpenGridServices/OpenGrid.Framework.Data.MySQL/MySQLUserData.cs
@@ -0,0 +1,153 @@
	1	using System;
	2	using System.Collections.Generic;
	3	using System.Text;
	4	using OpenGrid.Framework.Data;
	5	using libsecondlife;
	6
	7	namespace OpenGrid.Framework.Data.MySQL
	8	{
	9	class MySQLUserData : IUserData
	10	{
	11	public MySQLManager database;
	12
	13	public void Initialise()
	14	{
	15	IniFile GridDataMySqlFile = new IniFile("mysql_connection.ini");
	16	string settingHostname = GridDataMySqlFile.ParseFileReadValue("hostname");
	17	string settingDatabase = GridDataMySqlFile.ParseFileReadValue("database");
	18	string settingUsername = GridDataMySqlFile.ParseFileReadValue("username");
	19	string settingPassword = GridDataMySqlFile.ParseFileReadValue("password");
	20	string settingPooling = GridDataMySqlFile.ParseFileReadValue("pooling");
	21	string settingPort = GridDataMySqlFile.ParseFileReadValue("port");
	22
	23	database = new MySQLManager(settingHostname, settingDatabase, settingUsername, settingPassword, settingPooling, settingPort);
	24	}
	25
	26	public UserProfileData getUserByName(string name)
	27	{
	28	return getUserByName(name.Split(' ')[0], name.Split(' ')[1]);
	29	}
	30
	31	public UserProfileData getUserByName(string user, string last)
	32	{
	33	try
	34	{
	35	lock (database)
	36	{
	37	Dictionary<string, string> param = new Dictionary<string, string>();
	38	param["?first"] = user;
	39	param["?second"] = last;
	40
	41	System.Data.IDbCommand result = database.Query("SELECT * FROM users WHERE username = ?first AND lastname = ?second", param);
	42	System.Data.IDataReader reader = result.ExecuteReader();
	43
	44	UserProfileData row = database.getUserRow(reader);
	45
	46	reader.Close();
	47	result.Dispose();
	48
	49	return row;
	50	}
	51	}
	52	catch (Exception e)
	53	{
	54	Console.WriteLine(e.ToString());
	55	return null;
	56	}
	57	}
	58
	59	public UserProfileData getUserByUUID(LLUUID uuid)
	60	{
	61	try
	62	{
	63	lock (database)
	64	{
	65	Dictionary<string, string> param = new Dictionary<string, string>();
	66	param["?uuid"] = uuid.ToStringHyphenated();
	67
	68	System.Data.IDbCommand result = database.Query("SELECT * FROM users WHERE UUID = ?uuid", param);
	69	System.Data.IDataReader reader = result.ExecuteReader();
	70
	71	UserProfileData row = database.getUserRow(reader);
	72
	73	reader.Close();
	74	result.Dispose();
	75
	76	return row;
	77	}
	78	}
	79	catch (Exception e)
	80	{
	81	Console.WriteLine(e.ToString());
	82	return null;
	83	}
	84	}
	85
	86	public UserAgentData getAgentByName(string name)
	87	{
	88	return getAgentByName(name.Split(' ')[0], name.Split(' ')[1]);
	89	}
	90
	91	public UserAgentData getAgentByName(string user, string last)
	92	{
	93	UserProfileData profile = getUserByName(user, last);
	94	return getAgentByUUID(profile.UUID);
	95	}
	96
	97	public UserAgentData getAgentByUUID(LLUUID uuid)
	98	{
	99	try
	100	{
	101	lock (database)
	102	{
	103	Dictionary<string, string> param = new Dictionary<string, string>();
	104	param["?uuid"] = uuid.ToStringHyphenated();
	105
	106	System.Data.IDbCommand result = database.Query("SELECT * FROM agents WHERE UUID = ?uuid", param);
	107	System.Data.IDataReader reader = result.ExecuteReader();
	108
	109	UserAgentData row = database.getAgentRow(reader);
	110
	111	reader.Close();
	112	result.Dispose();
	113
	114	return row;
	115	}
	116	}
	117	catch (Exception e)
	118	{
	119	Console.WriteLine(e.ToString());
	120	return null;
	121	}
	122	}
	123
	124	public void addNewUserProfile(UserProfileData user)
	125	{
	126	}
	127
	128	public void addNewUserAgent(UserAgentData agent)
	129	{
	130	// Do nothing.
	131	}
	132
	133	public bool moneyTransferRequest(LLUUID from, LLUUID to, uint amount)
	134	{
	135	return false;
	136	}
	137
	138	public bool inventoryTransferRequest(LLUUID from, LLUUID to, LLUUID item)
	139	{
	140	return false;
	141	}
	142
	143	public string getName()
	144	{
	145	return "MySQL Userdata Interface";
	146	}
	147
	148	public string getVersion()
	149	{
	150	return "0.1";
	151	}
	152	}
	153	}