Database.cs

   1 using System;
   2 using System.Collections.Generic;
   3 using System.Linq;
   4 using System.Text;
   5 using MySql.Data.MySqlClient;
   6
   7 namespace Kelsier {
   8     class Database {
   9         protected MySqlConnection _dbh = null;
  10         public MySqlConnection dbh { get { return _dbh; } }
  11
  12
  13         /// <summary>
  14         /// Construct a Database, using the MySQL connector string.
  15         /// </summary>
  16         /// <param name="dbinfo">Connector string</param>
  17         public Database(string dbinfo) {
  18             _dbh = new MySqlConnection(dbinfo);
  19         }
  20
  21         public void Connect() {
  22             try {
  23                 dbh.Open();
  24             } catch (MySqlException e) {
  25                 Root.log.error("Error: {0}", e.ToString());
  26             }
  27         }
  28
  29         public object queryScalar(string query) {
  30             MySqlCommand cmdo = new MySqlCommand(query, dbh);
  31             return cmdo.ExecuteScalar();
  32         }
  33
  34         public MySqlDataReader queryReader(string query) {
  35             MySqlCommand cmdo = new MySqlCommand(query, dbh);
  36             return cmdo.ExecuteReader();
  37         }
  38     }
  39 }