با درود.
می دانید که در ASP.NET وقتی که می خواهید بوسیله DataAdapteer یک DataSet را Fill کنید ،می توانید از یک Connection باز مشترک استفاده کنید، ولی برای DataReader اینطور نیست چون ReadOnly و ForwardOnly است و مستقیم با دیتا بیس در ارتباط است و وقتی یک کانشن را در اختیار او قرار می دهیم دیگر هیچ کس نمی توانید از این کانکشن استفاده کند.
معماری چند لایه در وب هم به صورت DisConnected است یعنی شما در لایه دیتا یک BusinessEntity را [که معمولا یک Typed DataSet است ] از اطلاعات پر می کنید و به لایه های با لا تحویل می دهید. و برای update کردن هم به همین ترتیب BusinessEntity را تحویل می گیرید و تغیرات را بروی بانک اعمال می کنید.
حالا بگذریم از اینکه مضیت های یک DataReader نسبت به DataSet در چه مواردی است و چه حافظه کمی می گیرد و چه سرعت بالایی دارد و ....
می گویم بگذریم برای اینکه در ASP.NET 2.0 ماکروسافت آمد این مشکل را حل کرد و شما با چندDataReader می توانید از یک کانکشن مشترک استفاده کنید.
این همه صغری کبری کردم که این را بگم :
این کلاسی که احتمالا کدش را پایین می بینید یک ConnectionProvider است .یعنی هر جایی که از یک Connection در برنامه تان استفاده کنید باید از این کلاس در خواست کانکشن کنید.
شما نمی توانید از این کلاس یک instance بسازید .
این کلاس یک Indexer داخلی دارد که چنانچه شما برای اولین بار به آن مراجعه کنید.یک کانکشن باز می کند و به شما می دهد.
حالا در عین حال که این کانکشن باز است یک نفر دیگه در خواست کانکشن می کند.نیازی نیست کانکشن جدید بگیرد. همین کانکشن را به او هم تحویل می دهد.و به همین ترتیب...
مسئله ای این است که وقتی کاربران کارشان با کانکشن تمام شد باید به این کلاس بگویند که
کارشان تمام شده و خودشان نباید کانکشن را ببندند.
و ConnectionProvider خودش چنانچه ببیند هیچ کاربری با کانکشن سروکار ندارد خودش کانکشن را برای شما می بندد.
من دوتا متد برای DataReader هم گذاشته ام که عملا هیچ کاری انجام نمی دهند به شما کمک می کنند که شما از یک جا کانکشن حاضر آماده بگیرد و خودتان باید مدیریتش کنید. تا انگیزه ای هم باشد برای مهاجرت به نسخه بعدی دات نت.
من این ver از این کلاس را برای 5 کاربر که همزمان با دیتا سرو کار دارند پیش نهاد می کنم.
برای کاربران بیشتر و سایتهای پر بیننده باید از ConnectionManager MultiThread استفاده کنیم.
که اگرطالب داشته باشد AND عمری باشد AND آقای نگاهی دعای خیری پشت سر ما بکند، حتما در همین مکان قرار می دهم و در باره اش بحث خواهیم کرد.
احتمالا در ذهن دوستان خیلی ابهامات به وجود خواهد آمد من پیشنهاد می کنم قبل از هر گونه پیش داوری فقط ابهاماتشان را بیان کنند.
من پیشاپیش از املاء و انشاء بد فارسی خودم عذر خواهی می کنم.
به امید موفقیت.
using System;
using System.Data.SqlClient;
using IPICS_BASE_V00.Public.Configuration;
namespace IPICS_BASE_V00.CommonDA
{
/// <summary>
/// this class implement the singleton pattern.
/// Manage Connection in all around program.
/// and each object need connection to DB should be get from this class;
/// </summary>
/// <Ver>0.1</Ver>
public class ConnectionManager
{
#region Class Variables
private static int index = 0;
private static SqlConnection cnn = null;
#endregion
#region Class Constructor
private ConnectionManager()
{
}
#endregion
#region Class Methods
/// <summary>
/// get same connection for all request
/// </summary>
/// <example>SqlDataAdapter</example>
/// <returns>a opened connection</returns>
public static SqlConnection GetSharedConnection()
{
index++;
if(null == cnn)
{
cnn = new SqlConnection(IPICSConfiguration.ConnectionString) ;
cnn.Open();
}
return cnn;
}
/// <summary>
/// free opened connection from memory.
/// </summary>
/// <remarks>
/// each user get a connection should be free that connection else the connection will be open..
/// </remarks>
public static void FreeSharedConnection()
{
index--;
if(0 == index)
{ cnn.Close();}
}
/// <summary>
/// get new connection for each request
/// </summary>
/// <example>SqlDataReader</example>
/// <returns>a opened connection</returns>
public static SqlConnection GetSingleConnection()
{
SqlConnection cnn = new SqlConnection(IPICSConfiguration.ConnectionString) ;
cnn.Open();
return cnn;
}
/// <summary>
/// get new connection for each request
/// </summary>
/// <param name="opened">if opened is true get open connection else get close connection</param>
/// <returns>a connection</returns>
public static SqlConnection GetSingleConnection(bool opened)
{
if(opened)
{
SqlConnection cnn = new SqlConnection(IPICSConfiguration.ConnectionString) ;
cnn.Open();
return cnn;
}
else
{
SqlConnection cnn = new SqlConnection(IPICSConfiguration.ConnectionString) ;
return cnn;
}
}
/// <summary>
/// free opened connection from memory.
/// </summary>
/// <remarks>
/// each user get a connection should be free that connection else the connection will be open..
/// </remarks>
public static void FreeSingleConnection(SqlConnection cnn)
{
if(cnn.State == System.Data.ConnectionState.Open)
{ cnn.Close();}
}
#endregion
}
}
و نحوه استفاده در جاهای مختلف :
public dsPerson GetFreshData()
{
//var
//SqlConnection cnn = ConnectionManager.GetConnection();
dsPerson ds = new dsPerson();
SqlDataAdapter da = new SqlDataAdapter("select * from com_person",
ConnectionManager.GetSharedConnection() );
//
da.Fill(ds.com_person);
ConnectionManager.FreeSharedConnection();
return ds;
}
public bool Insert(dsPerson.com_personRow row)
{
bool retVal = false;
cmd = new SqlCommand();
//identify stored procedure
cmd.CommandText = "com_insert_new_person";
cmd.CommandType = CommandType.StoredProcedure;
//identify new parameters
cmd.Parameters.Add("@first_name" ,SqlDbType.NChar ,30);
cmd.Parameters.Add("@last_name" ,SqlDbType.NChar ,30);
cmd.Parameters.Add("@sex" ,SqlDbType.Bit);
cmd.Parameters.Add("@job_title" ,SqlDbType.NChar ,50);
cmd.Parameters.Add("@business_phone_1" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@business_phone_2" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@home_phone" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@mobile" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@business_fax" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@internal_phone" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@e_mail" ,SqlDbType.Char ,50);
cmd.Parameters.Add("@home_address" ,SqlDbType.NChar ,250);
cmd.Parameters.Add("@section_" ,SqlDbType.Int);
cmd.Parameters.Add("@company" ,SqlDbType.Int);
cmd.Parameters.Add("@access_type" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@personally_number" ,SqlDbType.Int);
cmd.Parameters.Add("@e_sign" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@user_name" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@password" ,SqlDbType.Char ,15);
cmd.Parameters.Add("@roles" ,SqlDbType.NVarChar ,250);
//assign value to sql parameters
cmd.Parameters["@first_name"].Value = row.first_name;
cmd.Parameters["@last_name"].Value = row.last_name;
cmd.Parameters["@sex"].Value = row.sex;
cmd.Parameters["@job_title"].Value = row.job_title;
cmd.Parameters["@business_phone_1"].Value = row.business_phone_1;
cmd.Parameters["@business_phone_2"].Value = row.business_phone_2;
cmd.Parameters["@home_phone"].Value = row.home_phone;
cmd.Parameters["@mobile"].Value = row.mobile;
cmd.Parameters["@business_fax"].Value = row.business_fax;
cmd.Parameters["@internal_phone"].Value = row.internal_phone;
cmd.Parameters["@e_mail"].Value = row.e_mail;
cmd.Parameters["@home_address"].Value = row.home_address;
cmd.Parameters["@section_"].Value = row.section_;
cmd.Parameters["@company"].Value = row.company;
cmd.Parameters["@access_type"].Value = row.access_type;
cmd.Parameters["@personally_number"].Value = row.personally_number;
cmd.Parameters["@e_sign"].Value = row.e_sign;
cmd.Parameters["@user_name"].Value = row.user_name;
cmd.Parameters["@password"].Value = row.password;
cmd.Parameters["@roles"].Value = row.roles;
//get new connection from connection manager
cmd.Connection = ConnectionManager.GetConnection();
if(cmd.ExecuteNonQuery() == 1)
{ retVal = true;}
else
{ retVal = false;}
//close connection
ConnectionManager.FreeSharedConnection();
return retVal;
}