Heim > Backend-Entwicklung > C#.Net-Tutorial > C#-Zugriff auf die SqlServer-Toolklasse SqlServerHelper

C#-Zugriff auf die SqlServer-Toolklasse SqlServerHelper

大家讲道理
Freigeben: 2016-11-10 14:56:56
Original
3375 Leute haben es durchsucht

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();
            }
        }
    }
Nach dem Login kopieren

Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage