MS SQL Server
  1. MS SQL Server
  3. SqlDataReader déjà ouvert dans une command différente
Intereting Posts
Impossible de mettre à jour la database car la database est en lecture seule Comment mapper une relation unaire à une table distincte dans EF? Quelles sont les causes d'une exception TypeLoadException sur Migrate.exe pour EF6? Comment récupérer des lignes uniques où plusieurs enfants qui le referencent existent pour différents types? Comment exécuter une requête SQL pour extraire des données de l'une des trois colonnes? Classes ASP.NET MVC 5 pour contenir les résultats de requêtes SQL complexes Comment écrire "pas dans ()" requête SQL en utilisant la jointure sélectionner / afficher le dernier numéro de série inséré dans postgres Comment returnner plusieurs valeurs de la procédure stockée dans la requête tsql Flux d'exception dans une procédure stockée appelant une autre procédure stockée Visual Studio + localdb sur Windows 10 SQL: première ligne de groupe après la jointure et l'ordre Passer le paramètre de vb.net en utilisant la procédure strored Combinaison de colonnes dans une colonne SQL Server Que fait exactement SaveChanges () dans EF6?

SqlDataReader déjà ouvert dans une command différente

Je reçois une erreur intéressante que je veux corriger. Voici ma class, 

public class SqlCommandWrapper { private readonly ISettings _settings; private readonly ILogger _logger; public SqlCommandWrapper(ISettings settings, ILogger logger) { _settings = settings; _logger = logger; } private enum ExecutionType { Reader, NonQuery, Scaler } public async Task<SqlDataReader> ExecuteReaderAsync(ssortingng commandText, params SqlParameter[] parameters) { return (SqlDataReader)await ExecuteAsync(ExecutionType.Reader, CommandType.StoredProcedure, commandText, IsolationLevel.ReadUncommitted, parameters).ConfigureAwait(false); } public async Task<SqlDataReader> ExecuteReaderAsync(CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, params SqlParameter[] parameters) { return (SqlDataReader)await ExecuteAsync(ExecutionType.Reader, commandType, commandText, isolationLevel, parameters).ConfigureAwait(false); } public async Task<SqlDataReader> ExecuteReaderAsync(CommandType commandType, ssortingng commandText, params SqlParameter[] parameters) { return (SqlDataReader) await ExecuteAsync(ExecutionType.Reader, commandType, commandText, IsolationLevel.ReadUncommitted, parameters).ConfigureAwait(false); } public async Task<int> ExecuteNonQueryAsync(ssortingng commandText, params SqlParameter[] parameters) { return (int)await ExecuteAsync(ExecutionType.NonQuery, CommandType.StoredProcedure, commandText, IsolationLevel.ReadUncommitted, parameters).ConfigureAwait(false); } public async Task<int> ExecuteNonQueryAsync(CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, params SqlParameter[] parameters) { return (int) await ExecuteAsync(ExecutionType.NonQuery, commandType, commandText, isolationLevel, parameters).ConfigureAwait(false); } public async Task<int> ExecuteNonQueryAsync(CommandType commandType, ssortingng commandText, params SqlParameter[] parameters) { return (int) await ExecuteAsync(ExecutionType.NonQuery, commandType, commandText, IsolationLevel.ReadUncommitted, parameters).ConfigureAwait(false); } public Task<object> ExecuteScalarAsync(ssortingng commandText, params SqlParameter[] parameters) { return ExecuteAsync(ExecutionType.Scaler, CommandType.StoredProcedure, commandText, IsolationLevel.ReadUncommitted, parameters); } public Task<object> ExecuteScalarAsync(CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, params SqlParameter[] parameters) { return ExecuteAsync(ExecutionType.Scaler, commandType, commandText, isolationLevel, parameters); } public Task<object> ExecuteScalarAsync(CommandType commandType, ssortingng commandText, params SqlParameter[] parameters) { return ExecuteAsync(ExecutionType.Scaler, commandType, commandText, IsolationLevel.ReadUncommitted, parameters); } private async Task<object> ExecuteAsync(ExecutionType executionType, CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, params SqlParameter[] parameters) { using (var connection = new SqlConnection(_settings.DatabaseConnectionSsortingng)) { using (var command = new SqlCommand(commandText, connection) {CommandType = commandType}) { command.Parameters.AddRange(parameters); command.CommandTimeout = _settings.CommandTimeout; await connection.OpenAsync().ConfigureAwait(false); var transaction = connection.BeginTransaction(isolationLevel); command.Transaction = transaction; try { object result; switch (executionType) { case ExecutionType.Reader: result = await command.ExecuteReaderAsync().ConfigureAwait(false); break; case ExecutionType.NonQuery: result = await command.ExecuteNonQueryAsync().ConfigureAwait(false); break; default: result = await command.ExecuteScalarAsync().ConfigureAwait(false); break; } transaction.Commit(); return result; } catch (Exception exception) { _logger.Log(exception); transaction.Rollback(); throw; } } } } }

et je l'appelle en utilisant, 

 using (var reader = await _sqlCommandWrapper.ExecuteReaderAsync("MySP", parameters)) { // My code }

Quand je cours ma class je reçois une erreur:

Il y a déjà un DataReader ouvert associé à cette command qui doit être fermé en premier.

Je le répare en ajoutant une méthode de callback, 

 public class SqlCommandWrapper { private readonly ISettings _settings; private readonly ILogger _logger; public SqlCommandWrapper(ISettings settings, ILogger logger) { _settings = settings; _logger = logger; } public enum ExecutionType { Reader, NonQuery, Scaler } public Task<IEnumerable<T>> ExecuteReaderAsync<T>(ssortingng commandText, Func<IDataReader, T> callback, params SqlParameter[] parameters) { return ExecuteReaderAsync(CommandType.StoredProcedure, commandText, callback, parameters); } public Task<IEnumerable<T>> ExecuteReaderAsync<T>(CommandType commandType, ssortingng commandText, Func<IDataReader, T> callback, params SqlParameter[] parameters) { return ExecuteReaderAsync(ExecutionType.Reader, commandType, commandText, IsolationLevel.ReadUncommitted, callback, parameters); } public async Task<IEnumerable<T>> ExecuteReaderAsync<T>(ExecutionType executionType, CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, Func<IDataReader, T> callback, params SqlParameter[] parameters) { return (IEnumerable<T>)await ExecuteAsync(executionType, commandType, commandText, isolationLevel, parameters, callback).ConfigureAwait(false); } public Task<int> ExecuteNonQueryAsync(ssortingng commandText, params SqlParameter[] parameters) { return ExecuteNonQueryAsync(CommandType.StoredProcedure, commandText, parameters); } public Task<int> ExecuteNonQueryAsync(CommandType commandType, ssortingng commandText, params SqlParameter[] parameters) { return ExecuteNonQueryAsync(ExecutionType.NonQuery, commandType, commandText, IsolationLevel.ReadUncommitted, parameters); } public async Task<int> ExecuteNonQueryAsync(ExecutionType executionType, CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, params SqlParameter[] parameters) { return (int)await ExecuteAsync(executionType, commandType, commandText, isolationLevel, parameters).ConfigureAwait(false); } public Task<object> ExecuteScalarAsync(ssortingng commandText, params SqlParameter[] parameters) { return ExecuteScalarAsync(CommandType.StoredProcedure, commandText, parameters); } public Task<object> ExecuteScalarAsync(CommandType commandType, ssortingng commandText, params SqlParameter[] parameters) { return ExecuteScalarAsync(ExecutionType.Scaler, commandType, commandText, IsolationLevel.ReadUncommitted, parameters); } public Task<object> ExecuteScalarAsync(ExecutionType executionType,CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, params SqlParameter[] parameters) { return ExecuteAsync(executionType, commandType, commandText, isolationLevel, parameters); } private Task<object> ExecuteAsync(ExecutionType executionType, CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, SqlParameter[] parameters) { return ExecuteAsync<object>(executionType, commandType, commandText, isolationLevel, parameters); } private async Task<object> ExecuteAsync<T>(ExecutionType executionType, CommandType commandType, ssortingng commandText, IsolationLevel isolationLevel, SqlParameter[] parameters, Func<IDataReader, T> callback = null) { using (var connection = new SqlConnection(_settings.DatabaseConnectionSsortingng)) { using (var command = new SqlCommand(commandText, connection) {CommandType = commandType}) { command.Parameters.AddRange(parameters); command.CommandTimeout = _settings.CommandTimeout; await connection.OpenAsync().ConfigureAwait(false); var transaction = connection.BeginTransaction(isolationLevel); command.Transaction = transaction; try { object result; switch (executionType) { case ExecutionType.Reader: var reader = await command.ExecuteReaderAsync().ConfigureAwait(false); using (reader) { var list = new List<T>(); while (reader.Read()) { if (callback != null) { list.Add(callback(reader)); } } result = list; } break; case ExecutionType.NonQuery: result = await command.ExecuteNonQueryAsync().ConfigureAwait(false); break; default: result = await command.ExecuteScalarAsync().ConfigureAwait(false); break; } transaction.Commit(); return result; } catch (Exception exception) { _logger.Log(exception); transaction.Rollback(); throw; } } } } }

usage, 

  (await _sqlCommandWrapper.ExecuteReaderAsync("MySP", r => new Product { Id = (int) r["Id"], ........................ ........................ ........................ }, parameters)).ToList()