class1.cs

一个实用的数据库连接池源码

using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.SqlTypes;
using System.Data.Common;

namespace ConnectionPool
{
	/// <summary>
	/// Summary description for Class1.
	/// </summary>
	class Class1
	{
		/// <summary>
		/// The main entry point for the application.
		/// </summary>
		[STAThread]
		static void Main(string[] args)
		{
			Console.WriteLine("Entering main point ...");

            //ConnectionPool.Instance().ConnectString = "Persist Security Info=False;Integrated Security=SSPI;server=127.0.0.1;database=UDS";
            ConnectionPool.Instance().CreatePool("127.0.0.1", "UDS");

            DBConn conn = ConnectionPool.Instance().Acquire();
            if (conn == null)
                return;
            Console.WriteLine("conn:" + conn.IsUsed.ToString() + ":"+ conn.IsOutOfPool.ToString() + ":"+ conn.Conn.ConnectionString + ":"+ conn.Conn.State.ToString());
            Console.WriteLine("used={0}", ConnectionPool.Instance().UsedConnection);

            conn.Updator("update UDS_Action set Act_Desc = 'YYY' where Act_ID=3;");
            Console.WriteLine("AffectCount = {0}", conn.AffectCount);

            DataSet ds = conn.Selector("select * from UDS_Action;");
            for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
            {
                string val = ds.Tables[0].Rows[i][2].ToString();
                Console.WriteLine("value = {0}", val);
            }
            ConnectionPool.Instance().Release(conn);
            Console.WriteLine("used={0}", ConnectionPool.Instance().UsedConnection);

            ConnectionPool.Instance().DestroyPool();

            Console.Write("Press any key to continuing ...");
			Console.Read();
		}
	}
}