>백엔드 개발 >C#.Net 튜토리얼 >MySQL 운영을 위한 C# 도구 클래스 MySqlHelper

MySQL 운영을 위한 C# 도구 클래스 MySqlHelper

大家讲道理
大家讲道理원래의
2016-11-10 14:57:523732검색

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

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.