返回一個SqlDataReader

Question

我有這樣的代碼：

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

我如何引用呢？

我試過這個，但它不起作用。

SqlDataReader reader = GeneralFunctions.GetGeneralInformation(); 

而且我將如何從閱讀器讀取？

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

編輯：

現在我收到以下錯誤：

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

下面是更新後的代碼：

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

的問題是，離開功能（通過回報聲明）將您踢出using塊，因此您正在使用的SqlDataReader和SqlConnections被丟棄。爲了解決這個問題，嘗試改變函數簽名是這樣的：

public static IEnumerable<IDataRecord> GetGeneralInformation (int RecID) 

，然後更新這樣的函數中：

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

對於最後的「我如何從它讀？ 「部分，它可能是這樣的：

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

Answer 2

根據定義，using語句應該它被稱爲後處置的對象。

因此，在您返回數據讀取器後，它將被處置。

Answer 3

問題是你正在創建數據庫連接在你的方法之內。

如果你要去共享數據庫資源之間的很多方法，請將SqlConnection移到這個範圍之外。

這樣你就可以從這個函數返回Reader，它會一直存在。

另外，請不要在此函數中讀取（），只是返回對象。

Answer 4

將您的連接字符串添加到app.config或web.config中的AppSettings部分。

​​3210

//函數返回SqlDataReader的結果

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

要使用的功能：

 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

我相信this StackOverflow answer值得一提。一個非常簡單和令人愉快的解決方案。