C#數據庫連接池 MySql SqlServer

查閱了一天的資料來學習MySql數據庫連接池，終於在一篇博文上找到了，自己也整理了一下，希望對大家有用處

1. 建立連接池

using MySql.Data.MySqlClient;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace LianJieChiTest
{
    public class ConnectionPool
    {
        private static ConnectionPool cpool = null;//池管理對象
        private static Object objlock = typeof(ConnectionPool);//池管理對象實例
        private int size = 1;//池中連接數
        private int useCount = 0;//已經使用的連接數
        private ArrayList pool = null;//連接保存的集合
        private String ConnectionStr = "";//連接字符串

        public ConnectionPool()
        {
            //數據庫連接字符串
            ConnectionStr = "server=localhost;User ID=root;Password=123456;database=test;";
            //創建可用連接的集合
            pool = new ArrayList();
        }

        #region 創建獲取連接池對象
        public static ConnectionPool getPool()
        {
            lock (objlock)
            {
                if (cpool == null)
                {
                    cpool = new ConnectionPool();
                }
                return cpool;
            }
        }
        #endregion

        #region 獲取池中的連接
        public MySqlConnection getConnection()
        {
            lock (pool)
            {
                MySqlConnection tmp = null;
                //可用連接數量大於0
                if (pool.Count > 0)
                {
                    //取第一個可用連接
                    tmp = (MySqlConnection)pool[0];
                    //在可用連接中移除此鏈接
                    pool.RemoveAt(0);
                    //不成功
                    if (!isUserful(tmp))
                    {
                        //可用的連接數據已去掉一個
                        useCount--;
                        tmp = getConnection();
                    }
                }
                else
                {
                    //可使用的連接小於連接數量
                    if (useCount <= size)
                    {
                        try
                        {
                            //創建連接
                            tmp = CreateConnection(tmp);
                        }
                        catch (Exception e)
                        {
                        }
                    }
                }
                //連接為null
                if (tmp == null)
                {
                    //達到最大連接數遞歸調用獲取連接否則創建新連接
                    if (useCount <= size)
                    {
                        tmp = getConnection();
                    }
                    else
                    {
                        tmp = CreateConnection(tmp);
                    }
                }
                return tmp;
            }
        }
        #endregion

        #region 創建連接
        private MySqlConnection CreateConnection(MySqlConnection tmp)
        {
            //創建連接
            MySqlConnection conn = new MySqlConnection(ConnectionStr);
            conn.Open();
            //可用的連接數加上一個
            useCount++;
            tmp = conn;
            return tmp;
        }
        #endregion

        #region 關閉連接,加連接回到池中
        public void closeConnection(MySqlConnection con)
        {
            lock (pool)
            {
                if (con != null)
                {
                    //將連接添加在連接池中
                    pool.Add(con);
                }
            }
        }
        #endregion

        #region 目的保證所創連接成功,測試池中連接
        private bool isUserful(MySqlConnection con)
        {
            //主要用於不同用戶
            bool result = true;
            if (con != null)
            {
                string sql = "select 1";//隨便執行對數據庫操作
                MySqlCommand cmd = new MySqlCommand(sql, con);
                try
                {
                    cmd.ExecuteScalar().ToString();
                }
                catch
                {
                    result = false;
                }

            }
            return result;
        }
        #endregion
    }
}

2. 使用

MySqlConnection conn = null;
for (int i = 1; i <= 100000; ++i)
{
        //獲取連接
        conn = ConnectionPool.getPool().getConnection();
        try
        {
             //數據操作
             MySqlCommand cmd = new MySqlCommand("Select * from zhy_testLianJie", conn);
             MySqlDataReader dr = cmd.ExecuteReader();
             while (dr.Read())
             {
                  Console.WriteLine("ID:" + i + "，姓名：" + dr[1]);
              }
              dr.Close();
              //將連接添加回連接池中
              ConnectionPool.getPool().closeConnection(conn);
        }
        catch (Exception ex)
        {
           Console.WriteLine("\n異常信息:\n{0}", ex.Message);
           break;
        }
}                

這里是MySql的使用方法，SqlServer與之相差就是去掉所有對象的“My”，希望可以幫助到大家