dbconnectionpool.cs

监控系统

using System;
using System.Data;
using System.Data.SqlClient;

using MonitorSystem.LogFileModule;

namespace MonitorSystem.MonitorCenter
{
	/// <summary>
	/// 
	/// </summary>
	public class DBConnectionPool
	{
		/// <summary>
		/// 数据库连接相关信息
		/// </summary>
		private string ConnString="";

		private MonitorSystem.BasicClass.SystemLog m_SysLog = new MonitorSystem.BasicClass.SystemLog();
		
		public DBConnectionPool()
		{
			// 
			// TODO: Add constructor logic here
			//
		}
		public DBConnectionPool(string iConnStr)
		{
			ConnString = iConnStr;
		}		
		/// <summary>
		/// 从配置文件中读取数据库相关的配置项
		/// </summary>
		public int InitDBString(string iConnStr)
		{			
			ConnString = iConnStr;
			if (ConnString == null)
				return -1;
			return 0;
		}		
		
		/// <summary>
		/// 从连接池中获得一个连接
		/// </summary>		
		public SqlConnection GetDBConnect()
		{
			System.Data.SqlClient.SqlConnection curr_Connect = new SqlConnection();
						
			if (ConnString == null)
				return null;			
			curr_Connect.ConnectionString = ConnString;
			try
			{
				curr_Connect.Open();
			}
			catch(Exception e)
			{
				m_SysLog.WriteToSysLog(0,e.ToString());
				return null;  
			}
			return curr_Connect;
		}

		public int ReleaseDBConnect(SqlConnection iDBConnect)
		{//将指定连接放回连接池
			try
			{
				iDBConnect.Close();
			}
			catch(Exception e)
			{
				m_SysLog.WriteToSysLog(0,e.ToString());
				return -1;
			}
			return 0;
		}		
	}
}