Restituzione di uno SqlDataReader

Question

ho questo codice:

public static SqlDataReader GetGeneralInformation (int RecID) 
{ 
    using (var conn = new SqlConnection(GetConnectionString())) 
    using (var cmd = conn.CreateCommand()) 
    { 
     conn.Open(); 
     cmd.CommandText = 
     @"SELECT cs.Status, cs.Completed 
      FROM NC_Steps s 
      INNER JOIN NC_ClientSteps cs 
       ON cs.RecID = s.RecID 
      WHERE cs.ClientID = 162 
      AND s.RecID = @value"; 
     cmd.Parameters.AddWithValue("@value", RecID); 
     using (var reader = cmd.ExecuteReader()) 
     { 
      if (reader.Read()) 
      { 
       return reader; 
      } 
      return null; 
     } 
    } 
} 

Come faccio riferimento a questo?

Ho provato questo ma non funziona.

SqlDataReader reader = GeneralFunctions.GetGeneralInformation(); 

Inoltre, come leggerei dal lettore?

Reader.GetString(reader.GetOrdinal("Status")) 

Edit:

Ora sto ottenendo il seguente errore:

Exception Details: System.NullReferenceException: Object reference not set to an instance of an object.

Ecco il codice aggiornato:

public static IEnumerable<IDataRecord> GetGeneralInformation (int ClientID) 
{ 
    using (var conn = new SqlConnection(GetConnectionString())) 
    using (var cmd = conn.CreateCommand()) 
    { 
     conn.Open(); 
     cmd.CommandText = 
     @"SELECT i.GoLiveDate, i.FirstBonusRun, i.TechFName, i.TechLName, i.TechEmail, i.TechPhone, i.WebISPFName, i.WebISPLName, 
      i.WebISPEmail, i.WebISPPhone, i.FullFillFName, i.FullFillLName, i.FullFillEmail, i.FullFillPhone, d.FName, 
      d.LName, d.HomePhone, d.Email 
      FROM NC_Information i 
      INNER JOIN Distributor d 
      ON d.DistID = i.ClientID 
      WHERE clientID = @value"; 
     cmd.Parameters.AddWithValue("@value", ClientID); 
     using (var reader = cmd.ExecuteReader()) 
     { 
      while (reader.Read()) 
      { 
       yield return reader; 
      } 
      yield return null; 
     } 
    } 
} 

protected void Page_Load(object sender, EventArgs e) 
{ 
    IEnumerable<IDataRecord> reader = GeneralFunctions.GetGeneralInformation((int)Session[ "DistID" ]); 

    //string result = GeneralFunctions.GetGeneralInformation(Globals.GeneralInformation).First()[ "Status" ].ToString(); 
} 

Answer 1

Il problema è che lasciare la funzione (tramite la dichiarazione di ritorno) ti prende a calci fuori dal using blocchi e quindi SqlDataReader e SqlConnections in uso sono eliminati. Per aggirare il problema, provare a cambiare la firma funzione come questa:

public static IEnumerable<IDataRecord> GetGeneralInformation (int RecID) 

e quindi aggiornare il centro della funzione come questa:

using (var reader = cmd.ExecuteReader()) 
{ 
    while (reader.Read()) 
    { 
     yield return reader; 
    } 
} 

Per la finale "Come leggo da esso? " parte, potrebbe assomigliare a questo:

string result = reader.First()["Status"].ToString(); 

Answer 2

Per definizione, una dichiarazione using si suppone di disporre di un oggetto dopo che è stato chiamato.

Pertanto, dopo aver restituito il lettore di dati, viene eliminato.

Answer 3

Il problema è che si sta creando la connessione al database all'interno del metodo.

Se si sta andando a condividere risorse di database tra diversi metodi, spostare SqlConnection al di fuori di questo ambito.

In questo modo è possibile restituire il Reader da questa funzione e persisterà.

Inoltre, non. Leggi() all'interno di questa funzione, è sufficiente restituire l'oggetto.

Answer 4

Aggiungere la stringa di connessione alla sezione AppSettings in app.config o web.config.

public string GetSqlConnection() 
    { 
     return System.Configuration.ConfigurationManager.AppSettings["SqlConnectionString"]; 
    } 

// funzione per restituire SqlDataReader risultati

public SqlDataReader executeReader(string sql, SqlParameter[] parameters=null) 
    { 
     SqlConnection conn = new SqlConnection(); 
     conn.ConnectionString = GetSqlConnection(); 
     conn.Open(); 
     SqlCommand cmd = new SqlCommand(); 
     cmd.Connection = conn; 
     cmd.CommandText = sql; 
     if (parameters != null) 
     { 
      cmd.CommandType = CommandType.StoredProcedure; 
      foreach (SqlParameter p in parameters) 
      { 
       cmd.Parameters.Add(p); 
      } 
     } 
     else 
     { 
      cmd.CommandType = CommandType.Text; 
     } 
     SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); 
     return reader; 
    } 

Per utilizzare la funzione:

 string query = @"SELECT cs.Status, cs.Completed 
     FROM NC_Steps s 
     INNER JOIN NC_ClientSteps cs 
      ON cs.RecID = s.RecID 
     WHERE cs.ClientID = 162 
     AND s.RecID = @value"; 
     //you can add more parameters by adding commas 
     var parameters = new SqlParameter[] { 
      new SqlParameter("@value", RecID) 
      }; 

     SqlDataReader dr = executeReader(query, parameters); 
     while (dr.Read()) 
     { 
      //fill your controls with data 
     } 
     dr.Close(); 

Answer 5

Credo this StackOverflow answer merita menzione. Una soluzione molto semplice e piacevole da usare.