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();                    }                }            }