要将DataReader查询结果转换为DataTable,你可以按照以下步骤进行操作:
-
创建一个空的DataTable对象。
-
使用DataReader的GetSchemaTable方法获取结果集的架构信息,包括列的名称和数据类型。
-
遍历DataReader,并将每一行的数据添加到DataTable中。
-
返回填充好数据的DataTable对象。
以下是一个示例代码:
public DataTable ConvertDataReaderToDataTable(SqlDataReader reader) { DataTable dt = new DataTable(); // 获取查询结果的架构信息 DataTable schemaTable = reader.GetSchemaTable(); // 创建DataTable的列 foreach (DataRow row in schemaTable.Rows) { string columnName = row["ColumnName"].ToString(); Type dataType = (Type)row["DataType"]; DataColumn column = new DataColumn(columnName, dataType); dt.Columns.Add(column); } // 添加查询结果的数据行 while (reader.Read()) { DataRow dataRow = dt.NewRow(); for (int i = 0; i < reader.FieldCount; i++) { dataRow[i] = reader.GetValue(i); } dt.Rows.Add(dataRow); } return dt; }
使用示例:
using (SqlConnection connection = new SqlConnection("your_connection_string")) { SqlCommand command = new SqlCommand("SELECT * FROM your_table", connection); connection.Open(); SqlDataReader reader = command.ExecuteReader(); DataTable dt = ConvertDataReaderToDataTable(reader); // 可以使用DataTable进行后续的操作 }
在上面的示例中,我们首先创建了一个空的DataTable对象。然后使用GetSchemaTable方法获取结果集的架构信息,并根据这些信息创建DataTable的列。接下来,我们遍历DataReader,将每一行的数据添加到DataTable中。最后,返回填充好数据的DataTable对象。