c# - 使用陈述题

Question

我有两个问题。

1) 是否应该始终在连接上使用 using 语句？那么，我会在连接上使用它，然后在连接内的阅读器上使用另一个吗？所以我会使用两个 using 语句。

2) 假设您在连接上使用了 using 语句，并且还在连接上返回了一个阅读器。所以你有两个 using 语句。它会创建两个 Try{}Finally{} block 还是只创建一个？

谢谢!

Answer 1

注意这里。您应该始终在任何 实现 IDisposable 的本地对象上使用 using 语句。这不仅包括连接和阅读器，还包括命令。但有时 using 语句的确切位置可能会很棘手。如果你不小心，它可能会导致问题。例如，在 using 语句后面的代码中，在您开始使用它之前将关闭您的阅读器:

DataReader MyQuery()
{
    string sql="some query";
    using (var cn = new SqlConnection("connection string"))
    using (var cmd = new SqlCommand(sql, cn))
    {
        cn.Open();
        using (var rdr = cmd.ExecuteReader())
        {
            return rdr;
        }
    }
}

相反，您有四种选择。一种是等待创建 using block ，直到您调用该函数:

DataReader MyQuery()
{
    string sql="some query";
    using (var cn = new SqlConnection("connection string"))
    using (var cmd = new SqlCommand(sql, cn))
    {
        cn.Open();
        return cmd.ExecuteReader();
    }
}

using (var rdr = MyQuery())
{
    while (rdr.Read())
    {
        //...
    }
}

当然，您仍然需要小心处理那里的连接，这意味着请记住在您使用该函数的任何地方都写一个 using block 。

选项二只是在方法本身中处理查询结果，但这打破了数据层与程序其余部分的分离。第三个选项是让您的 MyQuery() 函数接受一个 Action 类型的参数，您可以在 while (rdr.Read()) 循环中调用它，但这很尴尬。

我通常更喜欢选项四:将数据读取器变成 IEnumerable，如下所示:

IEnumerable<IDataRecord> MyQuery()
{
    string sql="some query";
    using (var cn = new SqlConnection("connection string"))
    using (var cmd = new SqlCommand(sql, cn))
    {
        cn.Open();
        using (var rdr = cmd.ExecuteReader())
        {
            while (rdr.Read())
              yield return rdr;
        }
    }
}

现在一切都将正确关闭，处理它的代码都在一个地方。您还会得到一个不错的奖励:您的查询结果将适用于任何 linq 运算符。

最后，我将在下一次构建一个全新的项目时使用一些新的东西，该项目将 IEnumerable 与传递的委托(delegate)参数相结合:

//part of the data layer
private static IEnumerable<IDataRecord> Retrieve(string sql, Action<SqlParameterCollection> addParameters)
{
    //DL.ConnectionString is a private static property in the data layer
    // depending on the project needs, it can be implementing to read from a config file or elsewhere
    using (var cn = new SqlConnection(DL.ConnectionString))
    using (var cmd = new SqlCommand(sql, cn))
    {
        addParameters(cmd.Parameters);

        cn.Open();
        using (var rdr = cmd.ExecuteReader())
        {
            while (rdr.Read())
              yield return rdr;
        }
    }
}

然后我将像这样在数据层中使用它:

public IEnumerable<IDataRecord> GetFooChildrenByParentID(int ParentID)
{
    //I could easily use a stored procedure name instead, and provide overloads for commandtypes.
    return Retrieve(
        "SELECT c.* 
         FROM [ParentTable] p 
         INNER JOIN [ChildTable] c ON c.ParentID = f.ID 
         WHERE f.ID= @ParentID", p => 
       {
          p.Add("@ParentID", SqlDbType.Int).Value = ParentID;
       }
     );
}