如何使用 DataReader 填充 DataTable

Question

我想使用 DataReader 填充 DataTable。

我创建了这样的对象

SqlDataReader dr = cmd.ExecuteReader();

if(dr.HasRows)
{

}

Answer 1

如果您想要的只是用于报告或网络的只读数据表，请尝试以下操作：

  conn = new SqlConnection(connString);
  string query = "SELECT * FROM Customers";
  SqlCommand cmd = new SqlCommand(query, conn);
  conn.Open();
  SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
  DataTable dt = new DataTable();
  dt.Load(dr);

应得的信用： http://www.dotnetcurry.com/showarticle.aspx?ID=143

Answer 2

DataTable.load() 可用于通用方法。

do {
    var table = new DataTable();
    table.Load(reader);
    dataset.Tables.Add(table);
} while(!reader.IsClosed);

Answer 3

您可以从 SqlDataReader dr 获取架构表以获取列名称，将名称保存到 List 并将它们添加为新 上的列DataTable，然后使用 dr 上的索引使用列表中的名称填充该 DataTable：

DataSet ds = new DataSet();
DataTable dtSchema = dr.GetSchemaTable();
DataTable dt = new DataTable();
List<DataColumn> listCols = new List<DataColumn>();
List<DataColumn> listTypes = new List<DataColumn>();

if (dtSchema != null)
{
   foreach (DataRow drow in dtSchema.Rows)
   {
        string columnName = System.Convert.ToString(drow["ColumnName"]);
        DataColumn column = new DataColumn(columnName, (Type)(drow["DataType"]));
        listCols.Add(column);
        listTypes.Add(drow["DataType"].ToString()); // necessary in order to record nulls
        dt.Columns.Add(column);
    }
}

// Read rows from DataReader and populate the DataTable
if (dr.HasRows)
{
    while (dr.Read())
    {            
        DataRow dataRow = dt.NewRow();
        for (int i = 0; i < listCols.Count; i++)
        {
            if (!dr.IsDBNull[i])
            {
                // If your query will go against a table with null CLOB fields 
                // and that column is the 5th column...
                if (strSQL == "SELECT * FROM TableWithNullCLOBField" && i == 4)
                    dataRow[((DataColumn)listCols[i])] = dr.GetOracleClob(i).Value;
                // If you might have decimal values of null... 
                // I found dr.GetOracleDecimal(i) and dr.GetDecimal(i) do not work
                else if (listTypes[i] == System.Decimal)
                    dataRow[((DataColumn)listCols[i])] = dr.GetFloat(i);                
                else 
                    dataRow[((DataColumn)listCols[i])] = dr[i];  // <-- gets index on dr
            }
            else  // value was null
            {
                byte[] nullArray = new byte[0];
                switch (listTypes[i])
                {
                    case "System.String":
                        dataRow[((DataColumn)listCols[i])] = String.Empty;
                    break;
                    case "System.Decimal":
                    case "System.Int16":  // Boolean
                    case "System.Int32":  // Number
                        dataRow[((DataColumn)listCols[i])] = 0;
                    break;
                    case "System.DateTime":
                        dataRow[((DataColumn)listCols[i])] = DBNull.Value;
                    break;
                    case "System.Byte[]":  // Blob
                        dataRow[((DataColumn)listCols[i])] = nullArray;
                    break;
                    default:
                        dataRow[((DataColumn)listCols[i])] = String.Empty;
                    break;
                }
            }
        }
        dt.Rows.Add(dataRow);
    }
    ds.Tables.Add(dt);
}

// Put this after everything is closed
if (ds.Tables.Count > 0)
    return ds.Tables[0]; // there should only be one table if we got results
else
    return null;

显然，您需要 try...catch。 ..finally 阻止这一切来处理异常和处置连接，并使用 finally 之后的最后一个条件。我发现这有助于查明何时有结果，并避免了在没有结果时失败的 dt.Load(dr) 问题。 ds.Fill(adapter) 也好不了多少，因为当我尝试使用 SELECT * FROM MyTable 获取包含 97 列和大约 80 行的表格时，它失败了。对我来说，只有上面的代码能够在所有场景中工作。

最初发布于 sarathkumar 的从数据读取器填充数据表。我提供了摘要，对其进行了压缩，添加了空检查并分配它是否为空值，并将表添加到了 DataSet 并在末尾添加了 DataSet 条件。

注意：对于那些使用 OracleDataReader 的用户，我发现如果您的 NCLOB 或 CLOB 字段在您正在阅读的表/结果集。我发现如果我通过查看索引 i 来检查该列并执行 dr.GetOracleClob(i) 而不是 dr[i]，我不再收到异常。请参阅 EF + ODP 的答案.NET + CLOB = Value Cannot be Null - Parameter name: byteArray? 并且我在 if (!dr.IsDBNull[i]) 时在上面的代码中添加了此条件。同样，如果您有一个空的 Decimal 字段，我必须使用 dr.GetFloat(i); 检查它，因为 dr.GetOracleDecimal(i); 都没有。 和 dr.GetDecimal(i); 似乎正确地适应了空值。

Answer 4

要填充DataSet，您可以使用以下内容：

var da = new SqlDataAdapter();
da.SelectCommand = cmd; // your SqlCommand object
var ds = new DataSet();
da.Fill(ds);