使用DataReader高效转化为DataTable的技巧

"将DataReader转换成DataTable的技巧与方法" 在.NET框架中，当我们从数据库检索数据时，经常使用ADO.NET组件，如SqlCommand和IDataReader。IDataReader接口提供了一个高效的方式，按需逐行读取数据，而不会一次性加载所有结果到内存中。然而，在某些情况下，我们可能需要将这些数据转换成DataTable对象，以便于进一步处理或操作。以下是如何将DataReader转换成DataTable的详细步骤和相关知识点： 1. 创建DataTable对象： 首先，我们需要创建一个新的DataTable实例，这将是存储从DataReader中读取的数据的容器。代码如下： ```csharp DataTable dt = new DataTable(); ``` 2. 创建和执行数据库命令： 使用IDbCommand接口创建一个数据库命令，设置SQL查询语句，然后执行这个命令以获取IDataReader。例如： ```csharp IDbCommand command = UserInfo.localDB.DataLayer.CreateCommand(); command.CommandText = "SELECT * FROM SYS_PROVINCE"; IDataReader IReader = command.ExecuteReader(); ``` 这里的`UserInfo.localDB.DataLayer.CreateCommand()`是根据实际的数据访问层实现来创建数据库命令的方法。 3. 将DataReader数据填充到DataTable： 检查IDataReader是否包含任何记录，如果有的话，调用一个方法（如`GetTable`）来填充DataTable。 ```csharp if (IReader.Read()) { dt = GetTable(IReader); } ``` 4. 实现`GetTable`方法： 该方法接收IDataReader作为参数，并构建DataTable结构，然后逐行填充数据。 ```csharp public DataTable GetTable(IDataReader reader) { DataTable dataTable1 = reader.GetSchemaTable(); DataTable dataTable2 = new DataTable(); // 创建列数组用于存储列名 string[] arrayList = new string[dataTable1.Rows.Count]; // 遍历SchemaTable，为DataTable2添加列 for (int i = 0; i < dataTable1.Rows.Count; i++) { DataColumn dataColumn = new DataColumn(); if (!dataTable2.Columns.Contains(dataTable1.Rows[i]["ColumnName"].ToString())) { dataColumn.ColumnName = dataTable1.Rows[i]["ColumnName"].ToString(); dataColumn.Unique = false; dataColumn.AllowDBNull = Convert.ToBoolean(dataTable1.Rows[i]["AllowDBNull"]); dataColumn.ReadOnly = true; dataColumn.DataType = (Type)dataTable1.Rows[i]["DataType"]; arrayList[i] = dataColumn.ColumnName; dataTable2.Columns.Add(dataColumn); } } // 开始异步加载数据 dataTable2.BeginLoadData(); // 循环读取DataReader中的数据并添加到DataTable2 do { DataRow dataRow = dataTable2.NewRow(); // 填充数据行（此处省略具体字段的赋值） dataRow.SetField(0, reader[0]); // ... dataTable2.Rows.Add(dataRow); } while (reader.Read()); // 结束数据加载 dataTable2.EndLoadData(); return dataTable2; } ``` 在这个`GetTable`方法中，我们首先获取DataReader的SchemaTable，它包含了关于结果集列的信息。然后，根据SchemaTable创建新的DataTable结构，确保列的名称、数据类型和允许空值的属性与原始表一致。最后，我们在循环中读取DataReader的每一行数据，将其转换成DataRow并添加到新创建的DataTable中。 5. 注意事项： - 在大数据量时，这种转换可能会消耗大量内存，因为DataTable会一次性加载所有数据。因此，只有在必要时才进行此转换，以保持性能。 - 读取DataReader时，务必小心处理数据库连接，确保在操作完成后关闭连接，以避免资源泄露。 通过以上步骤，我们可以有效地将从数据库查询返回的IDataReader转换为DataTable对象，便于后续处理。但请记住，始终权衡效率和灵活性，选择最适合特定场景的数据处理方式。