Bu kodu vardır bir SqlDataReader

Question

dönersek: Bunu başvuru nasıl

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; 
     } 
    } 
} 

?

Denedim ama işe yaramıyor.

SqlDataReader reader = GeneralFunctions.GetGeneralInformation(); 

Okuyucudan nasıl okurum?

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

Düzenleme:

Şimdi aşağıdaki hatayı alıyorum:

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

sorun fonksiyonunu bırakarak olmasıdır: Burada

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

güncellenmiş koddur (dönüş ifadesiyle) sizi'den çıkarırblokları, ve kullanmakta olduğunuz SqlDataReader ve SqlConnections atılmıştır.

public static IEnumerable<IDataRecord> GetGeneralInformation (int RecID) 

ve sonra böyle fonksiyonun ortasını güncellemek: soruna çözüm olarak, böyle fonksiyon imza değiştirmeyi deneyin final

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

"Nasıl ondan okunur? " bölüm, bu gibi görünebilir:

Tanım olarak

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

Answer 2

, bir using açıklamada denir sonra bir nesnenin imha gerekiyordu.

Bu nedenle, veri okuyucunuzu geri verdikten sonra atılır.

Answer 3

Sorun, yönteminiz içinde veritabanı bağlantısı oluşturuyorsunuz.

veritabanı kaynaklarını birçok yöntem arasında paylaşacaksanız, bu kapsamın dışında SqlConnection öğesini taşıyın.

Bu sayede Reader'ı bu işlevden döndürebilirsiniz ve kalıcı olacaktır.

Ayrıca, bu işlevin içinde .Read() işlevini kullanmayın, yalnızca nesneyi döndürün.

Answer 4

Bağlantı dizenizi app.config veya web.config dosyasındaki AppSettings bölümüne ekleyin.

 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

Ben this StackOverflow answer söz hak inanıyoruz: SqlDataReader dönmek için

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

// Fonksiyon işlevini kullanmak için

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; 
    } 

sonuçlanır. Çok basit ve hoş kullanımlı bir çözüm.