C# 连接Oracle 连接池请有经验朋友指点

0 0

C# 连接Oracle 连接池请有经验朋友指点20

这个是我参考ＪＡＶＡ连接池写的，也手动测试了，感觉没什么效果。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;
using Oracle.DataAccess.Client;
using System.Threading;
using System.Data;

namespace DBHelp
{
    public class ConnectionPool
    {
        /// <summary>
        /// 最少连接数
        /// </summary>
        private static int minConn;
        /// <summary>
        /// 最大连接数
        /// </summary>
        private static int maxConn;
        /// <summary>
        /// 现有连接数
        /// </summary>
        private static int connAmount;
        /// <summary>
        /// 使用Stack保存数据库连接
        /// </summary>
        private static Stack connStack;
        /// <summary>
        /// 连接池类对象
        /// </summary>
        private static ConnectionPool connectionPoll;
        /// <summary>
        /// 繁忙时等待时间
        /// </summary>
        private static int waitTime;
        /// <summary>
        /// 连接字符串
        /// </summary>
        private static string connstr = null;

        string serverPath = System.Reflection.Assembly.GetExecutingAssembly().Location.Substring(0, System.Reflection.Assembly.GetExecutingAssembly().Location.LastIndexOf("\\"));
        ///　<summary>
        ///　程序运行时，创建一个静态只读的进程辅助对象
        ///　</summary>
        private static readonly object _object = new object();

        /// <summary>
        /// 返回一个实例，如果是第一次调用此方法则创建一个新实例
        /// </summary>
        /// <returns></returns>
        public static ConnectionPool getInstance()
        {

            if (connectionPoll == null)
            {
                lock (_object)
                {
                    connectionPoll = new ConnectionPool();
                }
            }
            return connectionPoll;
        }

        /// <summary>
        /// 读取属性文件获得数据库连接信息及连接池信息
        /// </summary>
        public string getConn()
        {

            if (connstr == null)
            {
                try
                {
                    ArrayList host = getConfig.PrintAttributes(serverPath + "\\config.xml", "datehost");
                    ArrayList port = getConfig.PrintAttributes(serverPath + "\\config.xml", "dateport");
                    ArrayList user = getConfig.PrintAttributes(serverPath + "\\config.xml", "dateuser");
                    ArrayList password = getConfig.PrintAttributes(serverPath + "\\config.xml", "datepassword");
                    ArrayList databasename = getConfig.PrintAttributes(serverPath + "\\config.xml", "databasename");
                    ArrayList CminConn = getConfig.PrintAttributes(serverPath + "\\config.xml", "minConn");
                    ArrayList CmaxConn = getConfig.PrintAttributes(serverPath + "\\config.xml", "maxConn");
                    ArrayList CwaitTime = getConfig.PrintAttributes(serverPath + "\\config.xml", "waitTime");
                    minConn = Convert.ToInt32(CminConn[0].ToString());
                    maxConn = Convert.ToInt32(CmaxConn[0].ToString());
                    waitTime = Convert.ToInt32(CwaitTime[0].ToString());

                    connstr = "Data Source=(DESCRIPTION="
                     + "(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=" + host[0].ToString() + ")(PORT=" + port[0].ToString() + ")))"
                     + "(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=" + databasename[0].ToString() + ")));"
                     + "User Id=" + user[0].ToString() + ";Password=" + password[0].ToString() + ";";
                }
                catch (Exception ex)
                {
                    throw ex;
                }

            } return connstr;

        }

        /// <summary>
        /// 连接池
        /// </summary>
        public ConnectionPool()
        {
            getConn();
            connStack = new Stack();

            for (int i = 0; i < minConn; i++)
            {
                connStack.Push(newConnection());
            }
        }


        /// <summary>
        /// 从连接池中得到连接
        /// </summary>
        /// <returns></returns>
        public static OracleConnection getConnection()
        {
            OracleConnection conn = null;
            if (connStack.Count > 0)
            {
                conn = (OracleConnection)connStack.Pop();
            }
            else if (connAmount < maxConn)
            {
                conn = newConnection();
            }
            else
            {
                try
                {
                    Thread.Sleep(waitTime);//等待一会
                    Console.WriteLine("等待……");
                    return getConnection();
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
            return conn;
        }


        /// <summary>
        /// 归还连接
        /// </summary>
        /// <param name="conn"></param>
        public static void freeConnection(OracleConnection conn)
        {
            connStack.Push(conn);
        }


        /// <summary>
        /// 创建新连接
        /// </summary>
        /// <returns></returns>
        public static OracleConnection newConnection()
        {
            OracleConnection conn = null;
            try
            {
                conn = new OracleConnection(connstr);
                connAmount++;
                Console.WriteLine("连接池创建一个连接" + conn.ToString() + "现在连接池中的连接数是：" + connAmount);
                if (conn != null && conn.State != ConnectionState.Open)
                {
                    conn.Open();//打开连接
                }
                return conn;
            }
            catch (Exception e)
            {
                e.Message.ToString();
            }
            return conn;
        }

    }
}

各位朋友，发飙吧！