Dapper的嵌套“使用”子句-澄清？
Dapper的嵌套“使用”子句-澄清？
提问于 2015-07-04 07:56:11
我在学习达珀是如何在幕后工作的。
然而，我看到了这种处理的模式，这是我所不理解的。
大致上-- 这是如何实现QueryAsync的：
/*1*/ public async Task<IEnumerable<T>> QueryAsync<T>(string sql, Func<IDataRecord, T> projector, DbConnection _conn, dynamic param = null)
/*2*/ {
/*3*/
/*4*/ DbDataReader reader = null;
/*5*/ bool wasClosed = _conn.State == ConnectionState.Closed;
/*6*/ try
/*7*/ {
/*8*/
/*9*/ using (var cmd = _conn.CreateCommand())
/*10*/ {
/*11*/ if (param!=null)
/*12*/ foreach (var prop in param.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public))
/*13*/ {
/*14*/ var parameter = cmd.CreateParameter();
/*15*/ parameter.ParameterName = prop.Name;
/*16*/ parameter.Value = prop.GetValue(param, null);
/*17*/ cmd.Parameters.Add(parameter);
/*18*/ }
/*19*/
/*20*/ await _conn.OpenAsync().ConfigureAwait(false);
/*21*/ cmd.CommandTimeout = 100000;
/*22*/ cmd.CommandText = sql;
/*23*/ reader = await cmd.ExecuteReaderAsync().ConfigureAwait(false);
/*24*/ List<T> buffer = new List<T>();
/*25*/ while (await reader.ReadAsync().ConfigureAwait(false)) buffer.Add(projector(reader));
/*26*/ return buffer;
/*27*/ }
/*28*/
/*29*/ }
/*30*/ finally
/*31*/ {
/*32*/ using (reader) { }
/*33*/ if (wasClosed) _conn.Close();
/*34*/ }
/*35*/ }我可以理解为什么他没有在连接上使用using，因为他想通过wasClosed变量有条件地关闭连接。
为此，他必须使用try/finally子句。(因此条件结束将在finally子句中)
但我的问题是关于第32行。
与其执行在finally子句中使用，他还可以：
using (DbDataReader reader = await cmd.ExecuteReaderAsync().ConfigureAwait(false))
{
List<T> buffer = new List<T>();
while (await reader.ReadAsync().ConfigureAwait(false)) buffer.Add(projector(reader));
return buffer;
}因此，finally子句保留如下：
finally
{
//using (reader) { } //removed
if (wasClosed) _conn.Close();
}问题
我在dapper中多次看到using子句中的finally子句。
我在这里一定遗漏了什么，但是这个模式实现了什么，而我的建议却没有呢？
Stack Overflow用户
回答已采纳
发布于 2015-07-05 10:07:21
“我不是”MarcGravell，但我认为你遗漏了一件事。您粘贴的代码与您引用的链接不完全匹配。相关的代码路径如下所示：
try
{
if (command.Buffered)
{
List<T> buffer = new List<T>();
while (await reader.ReadAsync(cancel).ConfigureAwait(false))
{
buffer.Add((T)func(reader));
}
while (await reader.NextResultAsync().ConfigureAwait(false)) { }
command.OnCompleted();
return buffer;
}
else
{
// can't use ReadAsync / cancellation; but this will have to do
wasClosed = false; // don't close if handing back an open reader;
// rely on the command-behavior.
var deferred = ExecuteReaderSync<T>(reader, func, command.Parameters);
reader = null; // to prevent it being disposed before the caller gets to see it
return deferred;
}
}
finally
{
using (reader) { } // dispose if non-null
if (wasClosed) cnn.Close();
}该方法可以返回缓冲结果(由command.Buffered标志指示)，也可以返回延迟迭代器。如果Marc用一个using语句包装阅读器并返回一个迭代器，那么在调用站点执行它时，它(读取器)就会被释放。通过将读取器设置为null (在返回延迟结果之前的行中)，可以防止对读取器进行处理，因为最终块中的使用将被转换为以下内容：
finally
{
IDisposable disposable = reader;
try
{
}
finally
{
if (dispoable != null)
{
disposable.Dispose();
}
}
}当他将读取器设置为null时，它不会被释放，迭代器中存在的引用仍然有效，指向读取器。通过这种方式，他可以将读取器配置在正常的代码描述中，但如果请求延迟迭代器，则可以使其保持活动状态。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/31218376
复制相关文章
相似问题
腾讯云开发者
