在實際項目開發中，業務邏輯層的處理速度往往很快，特別是在開發Socket通信服務的時候，網絡傳輸很快，但是一旦加上數據庫操作，性能一落千丈，數據庫操作的效率往往成為一個系統整體性能的瓶頸。面對這問題，我們怎么辦呢？好，下面我就為大家介紹一種方法：構建SQL池，分離業務邏輯層和數據訪問層，讓業務邏輯層從低效的數據庫操作解脫，以提高系統整體性能。

（一）SQL池

　　SQL池是SQL容器，用于存放業務邏輯層拋過來的SQL語句。SQL池主要提供以下幾種方法：

　　1）internal string Pop()，從池中取出SQL。

　　2）internal void Push(string item)，增加一個SQL到池中。

　　3）internal string[] Clear()，清空SQL池，清空前，返回SQL池中所有SQL語句。

　　特別提醒一下，SQL池是面向多線程的，所以必須對公共資源SQL采取鎖機制。這里采用互斥鎖，當業務邏輯層線程往SQL池中拋入SQL語句時，禁止SQL執行線程執行SQL語句，反之，當SQL執行線程執行SQL語句時，也不允許業務邏輯層線程往SQL池中拋入SQL語句。為什么要這么做？因為SQL執行線程是批量執行SQL語句，在批量執行SQL語句前，會從池中取出所有SQL語句，如果此時業務邏輯層線程往SQL池中拋入SQL語句，則會導致這些SQL語句丟失，得不到執行。

　　下面是SQL池代碼：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace Test1
{
    sealed class SQLPool
    {
        //互斥鎖
        public static Mutex mutexSQLPool = new Mutex();

        //SQL池
        Stack<string> pool;

        /// <summary>
        /// 初始化SQL池
        /// </summary>
        internal SQLPool()
        {
            this.pool = new Stack<string>();
        }


        /// <summary>
        /// 獲取SQL池數量
        /// </summary>
        internal Int32 Count
        {
            get { return this.pool.Count; }
        }


        /// <summary>
        /// 從池中取出SQL
        /// </summary>
        /// <returns></returns>
        internal string Pop()
        {
            lock (this.pool)
            {
                return this.pool.Pop();
            }
        }


        /// <summary>
        /// 增加一個SQL到池中
        /// </summary>
        /// <param name="item"></param>
        internal void Push(string item)
        {
            if (item.Trim() == "")
            {
                throw new ArgumentNullException("Items added to a SQLPool cannot be null");
            }

            //此處向SQL池中push SQL必須與Clear互斥
            mutexSQLPool.WaitOne();
            try
            {
                this.pool.Push(item);    //此處如果出錯，則不會執行ReleaseMutex，將會死鎖
            }
            catch
            { 
            }
            mutexSQLPool.ReleaseMutex();
        }


        /// <summary>
        /// 清空SQL池
        /// 清空前，返回SQL池中所有SQL語句，
        /// </summary>
        internal string[] Clear()
        {
            string[] array = new string[] { };

            //此處必須與Push互斥
            mutexSQLPool.WaitOne();
            try
            {
                array = this.pool.ToArray();     //此處如果出錯，則不會執行ReleaseMutex，將會死鎖
                this.pool.Clear();
            }
            catch
            { 
            }
            mutexSQLPool.ReleaseMutex();

            return array;
        }
    }
}

it知識庫：【原創】c#實現用SQL池（多線程），定時批量執行SQL語句，轉載需保留來源！

鄭重聲明：本文版權歸原作者所有，轉載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯系我們修改或刪除，多謝。