在实际项目开发中，业务逻辑层的处理速度往往很快，特别是在开发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语句，转载需保留来源！

郑重声明：本文版权归原作者所有，转载文章仅为传播更多信息之目的，如作者信息标记有误，请第一时间联系我们修改或删除，多谢。