如果我在方法中使用 SqlCommand 作为参数，它是否会阻止 SqlConnection 处理？

如何解决如果我在方法中使用 SqlCommand 作为参数，它是否会阻止 SqlConnection 处理？

我的服务出现连接池问题（已达到最大值），在我尝试打开连接的任何地方，我都将它包装在 using 语句中以正确处理它，但我认为有些事情不允许它上班。我认为这是因为我使用的方法需要 SqlCommand 作为参数，这是一个例子：

private void QueryDB(string sConnString,SqlCommand oComm)
{
    using (SqlConnection connection = new SqlConnection(sConnString))
    {
        try
        {
            connection.Open();
            oComm.Connection = connection;
            oComm.CommandTimeout = 2;
            oComm.ExecuteNonQuery();
        }
        catch (SqlException e)
        {
            //log exception
        }
        catch (Exception e)
        {
            //log exception
        }
    }
}

之所以这样做是因为我需要在该方法之外组装参数，如下所示：

public void Example1()
{
    using (SqlCommand command = new SqlCommand())
    {
        command.CommandText = "SELECT TOP 1 FROM Table ORDER BY column1 DESC";
        QueryDB(_connString,command));
    }
}

public void Example2()
{
    SqlCommand command= new SqlCommand();
    command.CommandText = "UPDATE Table set column1 = @value where column2 = @number";
    command.Parameters.Add(new SqlParameter { ParameterName = "@value",Value = "someValue",SqlDbType = SqlDbType.VarChar });
    command.Parameters.Add(new SqlParameter { ParameterName = "@number",Value = 3,SqlDbType = SqlDbType.Int });

    QueryDB(_connString,command));
}

在 Example1 中，我尝试处理 SqlCommand，但我不知道它是否像那样工作。另一件要考虑的事情是我每秒都在运行一个执行 Example1 或 Example2 的计时器，我不知道这是否与问题有关，发生了 Max pool size 错误有时，不是每天，它会延迟其他查询。我可以做些什么来改善这种行为？谢谢

解决方法

我真的不知道这是否会解决您在连接池问题方面的问题，但是，扩展@Jack A 对您的问题的评论，也许，构建代码的更好方法是更改​​您的 { {1}} 方法采用委托更新 QueryDB 变量的必要信息，然后，您可以确保您的 SqlCommand 和 SqlConnection 并在其中正确处理方法。

SqlCommand

然后您可以在代码中通过以下任一方式使用它：

private void QueryDB(string sConnString,Action<SqlCommand> commandDelegate)
{
    using (SqlConnection oCon = new SqlConnection(sConnString))
        using(SqlCommand oComm = new SqlCommand())
        {
            try
            {
                oCon.Open();
                oComm.Connection = oCon;
                oComm.CommandTimeout = 2;
                commandDelegate(oComm);
                oComm.ExecuteNonQuery();
            }
            catch (SqlException e)
            {
                //log exception
            }
            catch (Exception e)
            {
                //log exception
            }
        }
}

同样，我不确定这是否会解决您的池化问题，但它至少可以确保所有内容都整齐地包装在您的 public void Uses() { QueryDB(_connString,(oComm) => oComm.CommandText = "SELECT TOP 1 FROM Table ORDER BY column1 DESC"); QueryDB(_connString,longerDelegate); } private void longerDelegate(SqlCommand oComm) { oComm.CommandText = "UPDATE Table set column1 = @value where column2 = @number"; oComm.Parameters.Add(new SqlParameter { ParameterName = "@value",Value = "someValue",SqlDbType = SqlDbType.VarChar }); oComm.Parameters.Add(new SqlParameter { ParameterName = "@number",Value = 3,SqlDbType = SqlDbType.Int }); } 方法中。

,

我要感谢大家的回复！在做了大量的研究和修改之后，我实施了@Jack A 和@Jhon Busto 的建议。但是你说得对，约翰它没有解决连接池问题，事实证明真正的问题是计时器，我没有注意到它一直在执行 Example1 和 Example2 但不是每个其次，它是每 50 毫秒或更短时间，所以我认为它在池中创建了很多连接。我正在更改计时器的 Timer.Interval 属性，但我不知道这一点：

如果 Enabled 和 AutoReset 都设置为 false，并且之前已启用计时器，则设置 Interval 属性会导致 Elapsed 事件引发一次，就好像 Enabled 属性已设置为 true。要设置间隔而不引发事件，您可以暂时将 Enabled 属性设置为 true，将 Interval 属性设置为所需的时间间隔，然后立即将 Enabled 属性设置回 false。

来源：https://docs.microsoft.com/en-us/dotnet/api/system.timers.timer.interval?view=netframework-4.7.2

因此，如果我需要更改 Timer.Interval，我遵循了 Microsoft 的文档，我再次测试了所有内容，并且成功了。小心使用定时器！呵呵:)