Moving MySQL into new class

[z_archive/kelsier.git] / Database.cs

diff --git a/Database.cs b/Database.cs
new file mode 100644 (file)
index 0000000..6497ca2
--- /dev/null
+++ b/Database.cs
@@ -0,0 +1,39 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using MySql.Data.MySqlClient;
+
+namespace Kelsier {
+    class Database {
+        protected MySqlConnection _dbh = null;
+        public MySqlConnection dbh { get { return _dbh; } }
+
+
+        /// <summary>
+        /// Construct a Database, using the MySQL connector string.
+        /// </summary>
+        /// <param name="dbinfo">Connector string</param>
+        public Database(string dbinfo) {
+            _dbh = new MySqlConnection(dbinfo);
+        }
+
+        public void Connect() {
+            try {
+                dbh.Open();
+            } catch (MySqlException e) {
+                Root.log.error("Error: {0}", e.ToString());
+            }
+        }
+
+        public object queryScalar(string query) {
+            MySqlCommand cmdo = new MySqlCommand(query, dbh);
+            return cmdo.ExecuteScalar();
+        }
+
+        public MySqlDataReader queryReader(string query) {
+            MySqlCommand cmdo = new MySqlCommand(query, dbh);
+            return cmdo.ExecuteReader();
+        }
+    }
+}