2016-04-14 27 views
0

我有一个非常繁忙的应用程序,它通过大约10-20个连接(通过sp_who2)哼哼,但偶尔连接会激增(300-500),并且Azure Sql数据库将开始终止他们。这会杀死应用程序。它很少发生,但现在更多的是我们添加了第三个应用程序。检测Azure Sql数据库上的泄漏连接

目前有4种不同的应用程序打到数据库 - 一个管理站点和三个不同的应用程序实例。

因此,如果没有Sql Server Profiler,如何确定泄漏来自哪里?另外,应用程序主要使用实体框架6,但一些更复杂/使用频繁的数据访问方法使用一些自定义存储过程和ado.net代码。这里有一个例子,如果任何人都可以判断这是一个潜在的问题:

public Content FindContent(int id) 
{ 
    Content content = null; 
    using (SqlCommand command = CreateProcedure("dbo.FindContent")) 
    { 
     AddParam(command, "Id", SqlDbType.Int, id); 

     var results = ExecuteReader<Content, Content, ContentFile>(command, x => BindContent(x), x => BindContent(x), x => BindContentFile(x)); 
     if (results.Result1.Count > 0) 
     { 
      content = results.Result1[0]; 
      content.AttachRelatedItems(results.Result2); 
      content.Files = results.Result3; 
     } 
    } 
    return content; 
} 

BindContent和BindContentFile与结果执行的功能。他们只是循环阅读并建立收藏。

这需要一个通用的ExecuteReader方法,它处理从操作3分的结果集:

private ThreeResults<T1, T2, T3> ExecuteReader<T1, T2, T3>(SqlCommand command, Func<SqlDataReader, T1> rowConverter1, Func<SqlDataReader, T2> rowConverter2, Func<SqlDataReader, T3> rowConverter3) 
{ 
    ThreeResults<T1, T2, T3> resultsets = new ThreeResults<T1, T2, T3>(); 
    using (SqlConnection connection = new SqlConnection(this.ConnectionString)) 
    { 
     command.Connection = connection; 
     connection.Open(); 
     using (SqlDataReader reader = command.ExecuteReader()) 
     { 
      List<T1> ret1 = new List<T1>(); 
      List<T2> ret2 = new List<T2>(); 
      List<T3> ret3 = new List<T3>(); 
      while (reader.Read()) 
      { 
       ret1.Add(rowConverter1(reader)); 
      } 

      reader.NextResult(); 
      while (reader.Read()) 
      { 
       ret2.Add(rowConverter2(reader)); 
      } 

      reader.NextResult(); 
      while (reader.Read()) 
      { 
       ret3.Add(rowConverter3(reader)); 
      } 

      resultsets.Result1 = ret1; 
      resultsets.Result2 = ret2; 
      resultsets.Result3 = ret3; 

      reader.Close(); 
     } 
    } 
    return resultsets; 
} 

回答