一起谈.NET技术,详解ADO.NET连接池

简介: ADO.NET中提供了连接池的功能,多数开发人员很少设置它,因为它是默认的。界面设置如下图: 关闭连接池也很简单,在连接字符串如下:Data Source=(local);Initial Catalog=AdventureWorks;Integrated Security=SSPI;P...

ADO.NET中提供了连接池的功能,多数开发人员很少设置它,因为它是默认的。

界面设置如下图:

 

关闭连接池也很简单,在连接字符串如下:

Data Source=(local);Initial Catalog=AdventureWorks;Integrated Security=SSPI;Pooling=False;

但连接池的本质是什么样的呢?

 

Reflector,打开System.Data.SqlClient.SqlConnectionConnectionString属性的设置值的方法,如下:

 

代码
 
  
private void ConnectionString_Set( string value)
{
DbConnectionOptions userConnectionOptions
= null ;
DbConnectionPoolGroup group
= this .ConnectionFactory.GetConnectionPoolGroup(value, null ,
 
ref userConnectionOptions);
DbConnectionInternal innerConnection
= this .InnerConnection;
bool allowSetConnectionString = innerConnection.AllowSetConnectionString;
if (allowSetConnectionString)
{
allowSetConnectionString
= this .SetInnerConnectionFrom(DbConnectionClosedBusy.
SingletonInstance, innerConnection);
if (allowSetConnectionString)
{
this ._userConnectionOptions = userConnectionOptions;
this ._poolGroup = group;
this ._innerConnection = DbConnectionClosedNeverOpened.SingletonInstance;
}
}
if ( ! allowSetConnectionString)
{
throw ADP.OpenConnectionPropertySet( " ConnectionString " , innerConnection.State);
}
if (Bid.TraceOn)
{
string str = (userConnectionOptions != null ) ? userConnectionOptions.
UsersConnectionStringForTrace() :
"" ;
Bid.Trace(
" %d#, '%ls'\n " , this .ObjectID, str);
}

}

 

 

 

再连接 到红色的GetConnectionPoolGroup方法,如下代码

 

 
 
internal DbConnectionPoolGroup GetConnectionPoolGroup( string connectionString,
DbConnectionPoolGroupOptions poolOptions,
ref DbConnectionOptions userConnectionOptions)
{

DbConnectionPoolGroup group;

if (ADP.IsEmpty(connectionString))

{

return null ;

}

if ( ! this ._connectionPoolGroups.TryGetValue(connectionString, out group) ||
(group.IsDisabled
&& (group.PoolGroupOptions != null )))

{

DbConnectionOptions options
= this .CreateConnectionOptions(connectionString,
userConnectionOptions);

if (options == null )

{

throw ADP.InternalConnectionError(ADP.ConnectionError.ConnectionOptionsMissing);

}

string str = connectionString;

if (userConnectionOptions == null )

{

userConnectionOptions
= options;

str
= options.Expand();

if (str != connectionString)

{

return this .GetConnectionPoolGroup(str, null , ref userConnectionOptions);

}

}

if ((poolOptions == null ) && ADP.IsWindowsNT)

{

if (group != null )

{

poolOptions
= group.PoolGroupOptions;

}

else

{

poolOptions
= this .CreateConnectionPoolGroupOptions(options);

}

}

DbConnectionPoolGroup group2
= new DbConnectionPoolGroup(options, poolOptions) {

ProviderInfo
= this .CreateConnectionPoolGroupProviderInfo(options)

};

lock ( this )

{

Dictionary dictionary
= this ._connectionPoolGroups;

if ( ! dictionary.TryGetValue(str, out group))

{

Dictionary dictionary2
= new Dictionary( 1 + dictionary.Count);

foreach (KeyValuePair pair in dictionary)

{

dictionary2.Add(pair.Key, pair.Value);

}

dictionary2.Add(str, group2);

this .PerformanceCounters.NumberOfActiveConnectionPoolGroups.Increment();

group
= group2;

this ._connectionPoolGroups = dictionary2;

}

return group;

}

}

if (userConnectionOptions == null )

{

userConnectionOptions
= group.ConnectionOptions;

}

return group;

}

 

 

 

TryGetValue是判断是否存在连接字符串为connectionString的连接,存在返回到group,不存在就调用CreateConnectionOptions创建一个DbConnectionOptions,最后用

 

 
 
lock ( this )
{

Dictionary dictionary
= this ._connectionPoolGroups;

if ( ! dictionary.TryGetValue(str, out group))

{

Dictionary dictionary2
= new Dictionary( 1 + dictionary.Count);

foreach (KeyValuePair pair in dictionary)

{

dictionary2.Add(pair.Key, pair.Value);

}

dictionary2.Add(str, group2);

this .PerformanceCounters.NumberOfActiveConnectionPoolGroups.Increment();

group
= group2;

this ._connectionPoolGroups = dictionary2;

}

return group;

}

 

 

 

这段代码放到连接池中,在这里,可能显示的看到,ado.NET的连接池实质上是一个Dictionary泛型集合。

所谓的连接池,就是一个与连接对象Connection相关的集合,这不只是简单的集合,而是有一定的机制在内部。我们做开发时,可能建立Connection连接对象,关闭连接对象,有时候还调用Dispose来释放连接。下次再用时,便重新实例化一个连接。但在池中的连接不随连接对象的CloseDispose而释放。如果下次重新建立连接,连接字符串与前一次完全一模一样,则连接池就会把上次可用的连接对象赋给连接去用。如果两个连接字符串有一点不一样,即使在某一个地方多一个空格,连接池也不会以为是相同的连接,这点微软可能在内部只直接去比较两个字符串了,而不是比较连接数据库字符串的键值互相匹配。

连接池的好处就是保留连接对象,防止下次重头再来实例化一个连接对象。

 
 
string constr1 = " Data Source=(local);Initial Catalog=AdventureWorks;Integrated
Security=SSPI;
" ;
string constr2 = " Data Source=(local);Initial Catalog=Pubs;Integrated Security=SSPI; " ;
string AssMark = " System.Data,Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561
934e089
" ;
Assembly ass
= Assembly.Load(AssMark);

Type SqlConType
= null ;

foreach (Type conType in ass.GetExportedTypes())
{

Console.WriteLine(conType .ToString ());

if ( " System.Data.SqlClient.SqlConnection " == conType.ToString())
{
SqlConType
= conType;

}

}

if (SqlConType != null )

{

Type[] types1
= new Type[ 0 ];

ConstructorInfo constructorInfoObj1
= SqlConType.GetConstructor(

BindingFlags.Instance
| BindingFlags.Public, null ,

CallingConventions.HasThis, types1,
null );

SqlConnection con1
= (SqlConnection)constructorInfoObj1.Invoke( null );

con1.ConnectionString
= constr1;

SqlConnection con2
= (SqlConnection)constructorInfoObj1.Invoke( null );

con2.ConnectionString
= constr2;

PropertyInfo PI
= SqlConType.GetProperty( " PoolGroup " , BindingFlags.Instance |
BindingFlags.NonPublic);

object poolGroup1 = PI.GetValue(con1, null );

object poolGroup2 = PI.GetValue(con2, null );

}

 

说明:可能找到结果后觉得非常简单,但怎么找到结果的,却是费了很大劲,几乎是5个小时,所以相把找到结果的过程简单说一下:

一开始用Reflector发现SqlConnection中有一个PoolGroup的属性,于是就想在运行时候比较两个SqlConnection对象的这个属性,但由于这个属性是的访问修饰符是internal的,不能直接访问,只有用反射,代码(是经过优化的)如下:

然后在倒数第一行设置断点,为比较poolGroup1poolGroup2的不同,结果发现,当连接字符串一样时,这两个对象的_objectID相同,字符串有一点不同就会不同,这点说明连接池中是用字符串本身比较的,而不是字符串中键值对进行比较。同还发现当con1con2ConnectionString不赋值时这两个对象都是null,由此说明关键是ConnectionString赋值上,所以才开始用Reflector查看这个属性的赋值方法,才有上面的代码。)

目录
相关文章
|
1月前
|
自然语言处理 物联网 图形学
.NET 技术凭借其独特的优势和特性,为开发者们提供了一种高效、可靠且富有创造力的开发体验
本文深入探讨了.NET技术的独特优势及其在多个领域的应用,包括企业级应用、Web应用、桌面应用、移动应用和游戏开发。通过强大的工具集、高效的代码管理、跨平台支持及稳定的性能,.NET为开发者提供了高效、可靠的开发体验,并面对技术更新和竞争压力,不断创新发展。
47 7
|
1月前
|
开发框架 安全 .NET
在数字化时代,.NET 技术凭借跨平台兼容性、丰富的开发工具和框架、高效的性能及强大的安全稳定性,成为软件开发的重要支柱
在数字化时代,.NET 技术凭借跨平台兼容性、丰富的开发工具和框架、高效的性能及强大的安全稳定性,成为软件开发的重要支柱。它不仅加速了应用开发进程,提升了开发质量和可靠性,还促进了创新和业务发展,培养了专业人才和技术社区,为软件开发和数字化转型做出了重要贡献。
24 5
|
1月前
|
传感器 人工智能 供应链
.NET开发技术在数字化时代的创新作用,从高效的开发环境、强大的性能表现、丰富的库和框架资源等方面揭示了其关键优势。
本文深入探讨了.NET开发技术在数字化时代的创新作用,从高效的开发环境、强大的性能表现、丰富的库和框架资源等方面揭示了其关键优势。通过企业级应用、Web应用及移动应用的创新案例,展示了.NET在各领域的广泛应用和巨大潜力。展望未来,.NET将与新兴技术深度融合,拓展跨平台开发,推动云原生应用发展,持续创新。
32 4
|
1月前
|
开发框架 .NET C#
.NET 技术凭借高效开发环境、强大框架支持及跨平台特性,在软件开发中占据重要地位
.NET 技术凭借高效开发环境、强大框架支持及跨平台特性,在软件开发中占据重要地位。从企业应用到电子商务,再到移动开发,.NET 均展现出卓越性能,助力开发者提升效率与项目质量,推动行业持续发展。
28 4
|
1月前
|
机器学习/深度学习 人工智能 物联网
.NET 技术:引领未来开发潮流
.NET 技术以其跨平台兼容性、高效的开发体验、强大的性能表现和安全可靠的架构,成为引领未来开发潮流的重要力量。本文深入探讨了 .NET 的核心优势与特点,及其在企业级应用、移动开发、云计算、人工智能等领域的广泛应用,展示了其卓越的应用价值和未来发展前景。
60 5
|
1月前
|
机器学习/深度学习 人工智能 Cloud Native
在数字化时代,.NET 技术凭借其跨平台兼容性、丰富的类库和工具集以及卓越的性能与效率,成为软件开发的重要平台
在数字化时代,.NET 技术凭借其跨平台兼容性、丰富的类库和工具集以及卓越的性能与效率,成为软件开发的重要平台。本文深入解析 .NET 的核心优势,探讨其在企业级应用、Web 开发及移动应用等领域的应用案例,并展望未来在人工智能、云原生等方面的发展趋势。
34 3
|
1月前
|
敏捷开发 缓存 中间件
.NET技术的高效开发模式,涵盖面向对象编程、良好架构设计及高效代码编写与管理三大关键要素
本文深入探讨了.NET技术的高效开发模式,涵盖面向对象编程、良好架构设计及高效代码编写与管理三大关键要素,并通过企业级应用和Web应用开发的实践案例,展示了如何在实际项目中应用这些模式,旨在为开发者提供有益的参考和指导。
24 3
|
1月前
|
开发框架 安全 Java
.NET技术的独特魅力与优势,涵盖高效的开发体验、强大的性能表现、高度的可扩展性及丰富的生态系统等方面,展示了其在软件开发领域的核心竞争力
本文深入探讨了.NET技术的独特魅力与优势,涵盖高效的开发体验、强大的性能表现、高度的可扩展性及丰富的生态系统等方面,展示了其在软件开发领域的核心竞争力。.NET不仅支持跨平台开发,具备出色的安全性和稳定性,还能与多种技术无缝集成,为企业级应用提供全面支持。
30 3
|
1月前
|
人工智能 开发框架 前端开发
C#/.NET/.NET Core技术前沿周刊 | 第 12 期(2024年11.01-11.10)
C#/.NET/.NET Core技术前沿周刊 | 第 12 期(2024年11.01-11.10)
|
1月前
|
人工智能 开发框架 安全
C#/.NET/.NET Core技术前沿周刊 | 第 13 期(2024年11.11-11.17)
C#/.NET/.NET Core技术前沿周刊 | 第 13 期(2024年11.11-11.17)