using System;  using System.Collections.Generic;  using System.Linq;  using System.Text;  using MySql.Data.MySqlClient;  using System.Data;  class MySqlHelper:IDisposable      {          private MySqlConnection m_conn = null;          private MySqlTransaction m_trans = null;          private bool m_tran_enabled = false;              public MySqlHelper()          {              m_conn = new MySqlConnection();              m_conn.ConnectionString = "Server=localhost;Port=3301;Uid=sa;Pwd=000";              m_conn.Open();          }              public void BeginTrans()          {              m_trans = m_conn.BeginTransaction();              m_tran_enabled = true;          }              public void Commit()          {              if (m_trans != null && m_tran_enabled)              {                  m_tran_enabled = false;                  m_trans.Commit();              }          }              public void Rollback()          {              if (m_trans != null && m_tran_enabled)              {                  m_tran_enabled = false;                  m_trans.Rollback();              }          }              public object QuerySome(string sql,int fieldindex)          {              using (MySqlCommand cmd = new MySqlCommand(sql, m_conn))              {                  using (MySqlDataReader sr = cmd.ExecuteReader())                  {                      if (sr.Read())                      {                          return sr.GetValue(fieldindex);                      }                  }              }              return null;          }              public delegate void FillValues(MySqlDataReader sr);                   public void QuerySomes(string sql, FillValues fill)          {              using (MySqlCommand cmd = new MySqlCommand(sql, m_conn))              {                  using (MySqlDataReader sr = cmd.ExecuteReader())                  {                      fill(sr);                  }              }          }              public DataTable Source(string sql)          {              DataTable dt = null;              MySqlCommand cmd = null;              MySqlDataAdapter ad = null;              try              {                  lock (dt = new DataTable())                  {                      cmd = new MySqlCommand(sql, m_conn);                      ad = new MySqlDataAdapter((MySqlCommand)cmd);                      dt.Clear();                      ad.Fill(dt);                  }              }              catch (Exception e)              {                  throw e;              }              return dt;          }              public void ExecProc(string proc, params MySqlParameter[] ps)          {              using (MySqlCommand cmd = new MySqlCommand(proc, m_conn))              {                  cmd.CommandType = System.Data.CommandType.StoredProcedure;                  foreach (MySqlParameter p in ps)                  {                      cmd.Parameters.Add(p);                  }                  cmd.ExecuteNonQuery();              }          }              void IDisposable.Dispose()          {              m_conn.Close();              m_conn.Dispose();              if (m_trans != null)              {                  m_trans.Dispose();              }          }      }