调用 ExecuteReader 时从 DAL 基类处置 SqlConnection

Question

我被分配到一个项目，其中 DAL 由一个基类组成，该基类具有返回 IDataReader、一个对象（int、字符串等）或一个 DataSet 的函数。 还存在 ExecuteNonQuery 函数。 该DAL仅访问USP（SQL Server），并使用MS的SqlHelper来执行查询。 以下是来自基类的两个示例函数：

    protected IDataReader ExecuteReader(string storedProcedure, params object[] parameterValues)
    {
        SqlConnection HConnection = new SqlConnection(myConnString);
        IDataReader ret = null;
        try
        {
            ret = SqlHelper.ExecuteReader(HConnection, storedProcedure, parameterValues);
        }
        catch (Exception ex)
        {
            HanldeError(ex, storedProcedure, parameterValues);
        }
        return ret;
    }

    protected object ExecuteScalar(string storedProcedure, params object[] parameterValues)
    {
        using (SqlConnection HConnection = new SqlConnection(myConnString))
        {
            object ret = null;
            try
            {
                ret = SqlHelper.ExecuteScalar(HConnection, storedProcedure, parameterValues);
            }
            catch (Exception ex)
            {
                HanldeError(ex, storedProcedure, parameterValues);
            }
            return ret;
        }
    }

其他类从该基类派生，创建特定于任务的 DAL 类，例如：

public class Orders : BaseDal {
    public IDataReader GetOrdersList(int clientId, int agentId)
    {
        return ExecuteReader("usp_Orders_GetOrdersList", clientId, agentId);
    }
    ...
}

然后是调用 DAL 函数并用数据填充对象（例如 Order 对象）的 BLL 类基于从 IDataReader 对象读取的数据：

    public Order[] GetOrdersList(int ClientIDX, int AgentIDX)
    {
        List<Order> ret = null;
        using (IDataReader dr = objDAL.GetOrdersList(ClientIDX, AgentIDX))
        {
            if (dr != null)
            {
                ret = new List<Order>();
                while (dr.Read())
                {
                    ret.Add(xReadOrder(dr, 0));
                }
            }
        }
        return ret.ToArray();
    }

我的问题是这样的 - 如果您查看从 BaseDal 获取的代码，您会注意到只有 ExecuteScalar 实际上终止了 SqlConnection 对象（using 语句） - 所有情况都是如此我在那里的职能。 使用 ExecuteReader 我无法做到这一点，因为我返回一个打开的 SqlDataReader 对象并关闭连接将使读取器无效。 我从 DAL 获取和使用 IDataReader 的所有代码都使用 using 语句，但是 SqlConnection 对象是否也被释放，或者是否在稍后阶段被 GC 处理，不尽快释放它会损害连接池？ 如果是这样，该如何治疗？

另外，是否有比上述方法更好的创建 DAL 的方法？ 我不太关心与数据存储无关的 DAL，我们只需要一个可靠且易于维护的 DAL，一个可以从多个线程获取多个并发连接的 DAL。

预先感谢您对此的任何帮助。

Answer 1

如果您在执行命令时指定CommandBehavior.CloseConnection，SqlDataReader 将关闭连接。 不过，总感觉有点丑。

相反，将 SqlConnection 传递到方法中并使用它。 然后调用者可以控制何时处理它。 或者，采用 Action 与打开的读取器一起执行，并在执行操作后使该方法关闭读取器和连接。 当然，该行动必须为读者做一切需要做的事情。