2016-11-24 9 views
5

私はストアドプロシージャの呼び出し結果を返すことができる奇妙な問題が発生していますが、コードは遡及的に失敗します。このコードを呼び出すSqlDataReaderのConnectionプロパティがNullです

public IEnumerable<T> ExecuteStoredProcedure<T>(string storedProcedureName, IDataMapper<T> mapper, IDictionary<string, object> parameters) 
{ 
    using (var connection = new SqlConnection(connectionString)) 
    { 
     using (var cmd = new SqlCommand(storedProcedureName, connection)) 
     { 
      cmd.CommandType = CommandType.StoredProcedure; 
      foreach (var key in parameters.Keys) 
      { 
       cmd.Parameters.AddWithValue(key, parameters[key]); 
      } 
      connection.Open(); 
      SqlDataReader reader = cmd.ExecuteReader(); 
      //return MapRecordsToDTOs(reader, mapper); 

      //let's test: 
      IEnumerable<T> result = MapRecordsToDTOs(reader, mapper); 
      var x = (new List<T>(result)).Count; 
      System.Diagnostics.Debug.WriteLine(x); 
      return result; 
     } 
    } 
} 


private static IEnumerable<T> MapRecordsToDTOs<T>(SqlDataReader reader, IDataMapper<T> mapper) 
{ 
    if (reader.HasRows) 
    { 
     while (reader.Read()) 
     { 
      System.Diagnostics.Debug.WriteLine(reader["Id"]); //what's going on... 
      yield return mapper.MapToDto((IDataRecord)reader); 
     } 
    } 
} 

x変数は、常に私は私のストアドプロシージャへの呼び出しから見ることを期待したい行数を表していることを示しています。

また、デバッグ出力には、私が見たいと思うID値が表示されます。

しかし、これらの結果が返された後、if (reader.HasRows)というエラー(つまり、既に実行されている)からエラーAn exception of type 'System.InvalidOperationException' occurred in System.Data.dll but was not handled in user codeが返されます。このリクエストを呼び出すブラウザはHTTP Error 502.3 - Bad Gatewayです。

Screenshot of Error

Screenshot of HasRows Behaviour

私は理由は、それが実際のユーザーの出力を返すだろうかとは別に、デバッグのためのIDX値を、システムの計算された疑いがあります。そのため、IEnumerable値を返す必要がある時点でIEnumerable値を取得するために遅延操作を実行します。この点だけusingステートメントによってdisposeメソッドが呼び出されたため、読み取り側の接続はnullになります(これは、デバッグ中にreader変数のプロパティを検査するときに表示されます)。

これまでにこのような動作を見たことがありますか?これはバグです。または私はちょうど明白な何かを逃したか?


追加コード:

public interface IDataMapper<T> 
{ 
    T MapToDto(IDataRecord record); 
} 

public class CurrencyMapper: IDataMapper<CurrencyDTO> 
{ 
    const string FieldNameCode = "Code"; 
    const string FieldNameId = "Id"; 
    const string FieldNameName = "Name"; 
    const string FieldNameNum = "Num"; 
    const string FieldNameE = "E"; 
    const string FieldNameSymbol = "Symbol"; 

    public CurrencyMapper() { } 

    public CurrencyDTO MapToDto(IDataRecord record) 
    { 
     var code = record[FieldNameCode] as string; 
     var id = record[FieldNameId] as Guid?; 
     var name = record[FieldNameName] as string; 
     var num = record[FieldNameNum] as string; 
     var e = record[FieldNameE] as int?; 
     var symbol = record[FieldNameSymbol] as char?; 
     return new CurrencyDTO(id, code, num, e, name, symbol); 
    } 
} 

public class CurrencyRepository 
{ 

    const string SPReadAll = "usp_CRUD_Currency_ReadAll"; 

    readonly SqlDatabase db; 
    public CurrencyRepository() 
    { 
     db = new SqlDatabase(); //stick to SQL only for the moment for simplicity 
    } 
    public IEnumerable<CurrencyDTO> GetCurrencyCodes() 
    { 
     var mapper = new CurrencyMapper(); 
     return db.ExecuteStoredProcedure(SPReadAll, mapper); 
    } 
} 

public class CurrencyDTO 
{ 

    readonly Guid? id; 
    readonly string code; 
    readonly string num; 
    readonly int? e; 
    readonly string name; 
    readonly char? symbol; 

    public CurrencyDTO(Guid? id,string code,string num,int? e,string name, char? symbol) 
    { 
     this.id = id; 
     this.code = code; 
     this.num = num; 
     this.e = e; 
     this.name = name; 
     this.symbol = symbol; 
    } 

    public Guid? Id { get { return id; } } 
    public string Code { get { return code; } } 
    public string Num { get { return num; } } 
    public int? E { get { return e; } } 
    public string Name { get { return name; } } 
    public char? Symbol { get { return symbol; } } 
} 
+1

は、あなただけのSqlDataReaderのリーダー= cmd.ExecuteReader ''後reader.HasRows'()検査(またはあなたのコード内で使用)しようとしました; 'MapRecordsToDTOs'を呼び出す前に? – McNets

+1

あなたは次のように試してみることができます: 'reader = await cmd.ExecuteReaderAsync();' – McNets

+0

@mcNets: 'MapRecordsToDTOs'関数は' reader 'を確認します。HasRows'は真であり、 'x'が正しい値を取得できるように行を反復し、' ID'が 'Debug.WriteLine'によって正しく出力されるようにします。ステートメント。 – JohnLBevan

答えて

2

私は一時的にこの問題を解決する回避策を実装しました。

これは動作します。

private static IEnumerable<T> MapRecordsToDTOs<T>(SqlDataReader reader, IDataMapper<T> mapper) 
{ 
    var list = new List<T>(); //use a list to force eager evaluation 
    if (reader.HasRows) 
    { 
     while (reader.Read()) 
     { 
      list.Add(mapper.MapToDto((IDataRecord)reader)); 
     } 
    } 
    return list.ToArray(); 
} 

元に対し:

private static IEnumerable<T> MapRecordsToDTOs<T>(SqlDataReader reader, IDataMapper<T> mapper) 
{ 
    if (reader.HasRows) 
    { 
     while (reader.Read()) 
     { 
      yield return mapper.MapToDto((IDataRecord)reader); 
     } 
    } 
} 

Iは、リスト内の結果を通してそれだけ反復することを反復子によって影響を受けるコードを移動さの差、コンパイラがIDisposableオブジェクトに関する要件を賢明に理解しているとは限りません。

コンパイラが私のためにこれを処理できるはずです(ここで確認してください:https://stackoverflow.com/a/13504789/361842)。だから私はそれがコンパイラのバグだと思っています。ここで報告

:ここhttps://connect.microsoft.com/VisualStudio/feedback/details/3113138

追加のデモコード: https://gist.github.com/JohnLBevan/a910d886df577e442e2f5a9c2dd41293/

関連する問題