私はストアドプロシージャの呼び出し結果を返すことができる奇妙な問題が発生していますが、コードは遡及的に失敗します。このコードを呼び出す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
です。
私は理由は、それが実際のユーザーの出力を返すだろうかとは別に、デバッグのためのID
とX
値を、システムの計算された疑いがあります。そのため、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; } }
}
は、あなただけのSqlDataReaderのリーダー= cmd.ExecuteReader ''後reader.HasRows'()検査(またはあなたのコード内で使用)しようとしました; 'MapRecordsToDTOs'を呼び出す前に? – McNets
あなたは次のように試してみることができます: 'reader = await cmd.ExecuteReaderAsync();' – McNets
@mcNets: 'MapRecordsToDTOs'関数は' reader 'を確認します。HasRows'は真であり、 'x'が正しい値を取得できるように行を反復し、' ID'が 'Debug.WriteLine'によって正しく出力されるようにします。ステートメント。 – JohnLBevan