SQL Server 连接超时和使用带有命令和连接对象的语句

Question

请在回答之前阅读整个问题。我很抱歉，我似乎从不写简短的问题......

我支持在 Windows Small Business Server 2011 SP1 机器上运行 SQL Server 2008 R2 的 C# 内部 Web 应用程序。

我们最近遇到了很多 SQL 超时，这里是一个异常示例：

System.Web.HttpUnhandledException：引发了“System.Web.HttpUnhandledException”类型的异常。 ---> System.InvalidOperationException：超时已过期。在从池中获取连接之前超时时间已过。这可能是因为所有池连接都在使用中并且达到了最大池大小。 在 System.Data.ProviderBase.DbConnectionFactory.GetConnection（DbConnection owningConnection） 在 System.Data.ProviderBase.DbConnectionClosed.OpenConnection（DbConnection outerConnection，DbConnectionFactory connectionFactory） 在 System.Data.SqlClient.SqlConnection.Open()

我检查了一些东西，其中之一是代码如何处理连接和关闭连接。我在其他线程中读到，在连接中使用 Using 语句就足够了，因为它“......将连接创建包装在 try .. finally 中，并将连接处理调用放在 finally 中”。即使发生异常，连接也会关闭。

所以，我同意并且多年来一直使用这种方法。即使在连接中使用 Using 语句，其他人也建议显式关闭连接。我认为这将是多余的......

然而，我的问题是关于命令对象。其他人为此应用程序编写了一个大型数据库方法库，并且他们（在所有数据库方法中）在 SqlConnection 对象 using 语句之前声明了 SqlCommand 对象。他们还在连接使用语句之前将连接对象分配给命令对象。

在连接使用语句中声明和使用命令对象是更好的做法吗，否则会导致 sql 连接超时（除非其他原因导致 sql 连接超时）？以这段代码为例：

    public Musician GetMusician(int recordId)
    {
        Musician objMusician = null;
        SqlConnection con = new SqlConnection(_connectionString);
        SqlCommand cmd = new SqlCommand();
        cmd.Connection = con;
        cmd.CommandText = "selectMusician";
        cmd.CommandType = CommandType.StoredProcedure;
        cmd.Parameters.AddWithValue("@id", recordId);

        using (con)
        {
            con.Open();
            SqlDataReader reader = cmd.ExecuteReader();
            if (reader.HasRows)
            {
                reader.Read();
                objMusician = new Musician((int)reader["id"]);
                objMusician.Name = (string)reader["name"];
            }
        }

        if objMusician != null)
        {
            objMusician.Albums = Albums.GetAlbums((int)objMusician.ID);
            objMusician.Tours = Tours.GetTours((int)objMusician.ID);
            objMusician.Interviews = Interviews.GetInterviews((int)objMusician.ID);
        }
        return objMusician;
    }

还知道调用页面中包含尝试捕获，并且该页面将错误记录到我们的日志记录数据库中。我们让异常冒泡到页面上的调用方法，并在那里得到处理。

Answer 1

您应该在完成连接后明确关闭它。您永远不会关闭任何连接，因此在达到连接池限制后，您将收到错误，直到您手动回收池或它自行循环。在 using 块内移动属性分配块并执行 con.Close(); cmd.Dispose();在归还您的 objMusician 之前：

using (con)
{
    con.Open();
    SqlDataReader reader = cmd.ExecuteReader();
    if (reader.HasRows)
    {
        reader.Read();
        objMusician = new Musician((int)reader["id"]);
        objMusician.Name = (string)reader["name"];
    }

    if objMusician != null)
    {
        objMusician.Albums = Albums.GetAlbums((int)objMusician.ID);
        objMusician.Tours = Tours.GetTours((int)objMusician.ID);
        objMusician.Interviews = Interviews.GetInterviews((int)objMusician.ID);
    }

    con.Close();
    cmd.Dispose();        

    return objMusician;
}

Answer 2

不知道它是否会帮助您解决超时问题，但我一直将我的代码结构如下，并且没有遇到这个问题：

using(var cmd = new SqlCommand())
{
    using(var con = new SqlConnection(ConnectionString))
    {
        con.Open();
        cmd.Connection = con;
        cmd.CommandText = "selectMusician";
        cmd.CommandType = CommandType.StoredProcedure;
        cmd.Parameters.AddWithValue("@id", recordId);
        ...
    }
}

刚刚在 MSDN 上阅读，它说“使用完组件后调用 Dispose。Dispose 方法使组件处于不可用状态。调用 Dispose 后，您必须释放对该组件的所有引用，以便垃圾收集器可以回收组件占用的内存。”这意味着为了让 GC 立即收集连接，您必须在释放命令之前释放连接，否则连接会一直挂起，直到 GC 开始对其调用 Finalize。

Answer 3

重构您的方法如下。您可能会遇到数据读取器对连接的引用但尚未处理的情况。

public Musician GetMusician(int recordId)
{
    Musician objMusician = null;

    using(SqlConnection con = new SqlConnection(_connectionString))
    {
        con.Open();
        using (SqlCommand cmd = new SqlCommand())
        {
            cmd.Connection = con;
            cmd.CommandText = "selectMusician";
            cmd.CommandType = CommandType.StoredProcedure;
            cmd.Parameters.AddWithValue("@id", recordId);

            using (SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection))
            {
                if (reader.HasRows)
                {
                    reader.Read();
                    objMusician = new Musician((int) reader["id"]);
                    objMusician.Name = (string) reader["name"];
                }

                if objMusician != null)
                {
                    objMusician.Albums = Albums.GetAlbums((int)objMusician.ID);
                    objMusician.Tours = Tours.GetTours((int)objMusician.ID);
                    objMusician.Interviews = Interviews.GetInterviews((int)objMusician.ID);
                }
            }
        }

        return objMusician;
    }
}