在C#的实际开发中,DataTable是常用的内存数据表结构,当我们需要整合多个来源的数据时,合并两个DataTable是高频操作。合并场景主要分为两种,一种是待合并的两个DataTable结构完全一致,另一种是两者的列结构存在差异,不同场景的处理方式有所区别。
结构相同的两个DataTable合并
如果两个DataTable的列名、列顺序、数据类型完全一致,合并操作非常简单,直接使用DataTable.Merge方法即可,该方法会将源DataTable的所有行合并到目标DataTable中。
基础合并示例
以下是两个结构相同的DataTable合并的完整代码:
using System;
using System.Data;
namespace DataTableMergeDemo
{
class Program
{
static void Main(string[] args)
{
// 创建第一个DataTable,结构为用户信息表
DataTable dt1 = new DataTable();
dt1.Columns.Add("UserId", typeof(int));
dt1.Columns.Add("UserName", typeof(string));
dt1.Columns.Add("Age", typeof(int));
// 添加测试数据
dt1.Rows.Add(1, "张三", 20);
dt1.Rows.Add(2, "李四", 22);
// 创建第二个DataTable,结构和dt1完全一致
DataTable dt2 = new DataTable();
dt2.Columns.Add("UserId", typeof(int));
dt2.Columns.Add("UserName", typeof(string));
dt2.Columns.Add("Age", typeof(int));
// 添加测试数据
dt2.Rows.Add(3, "王五", 25);
dt2.Rows.Add(4, "赵六", 23);
// 合并两个DataTable,将dt2的数据合并到dt1中
dt1.Merge(dt2);
// 输出合并后的结果
Console.WriteLine("合并后的数据:");
foreach (DataRow row in dt1.Rows)
{
Console.WriteLine($"UserId:{row["UserId"]}, UserName:{row["UserName"]}, Age:{row["Age"]}");
}
}
}
}
Merge方法的参数说明
Merge方法有多个重载版本,常用的参数如下:
- table:要合并到当前DataTable的源DataTable对象
- preserveChanges:布尔值,指示是否保留当前DataTable中的更改,默认值为false,如果设为true,合并时不会覆盖当前表的现有行更改
- missingSchemaAction:指定当源DataTable中有当前表不存在的列时的处理方式,可选值有Add(添加新列)、Ignore(忽略新列)、Error(抛出错误)等
结构不同的两个DataTable合并
如果两个DataTable的列结构不同,比如列名不一致、列数量不同,直接使用Merge方法可能会出现数据丢失或者错误,此时需要先统一两个DataTable的结构,再进行合并。
统一结构后合并示例
假设dt1有UserId、UserName、Age三列,dt2有UserId、UserNickName、Gender三列,我们需要合并成一个包含UserId、UserName、Age、UserNickName、Gender五列的DataTable,实现代码如下:
using System;
using System.Data;
namespace DataTableMergeDemo
{
class Program
{
static void Main(string[] args)
{
// 创建第一个DataTable
DataTable dt1 = new DataTable();
dt1.Columns.Add("UserId", typeof(int));
dt1.Columns.Add("UserName", typeof(string));
dt1.Columns.Add("Age", typeof(int));
dt1.Rows.Add(1, "张三", 20);
dt1.Rows.Add(2, "李四", 22);
// 创建第二个DataTable,结构和dt1不同
DataTable dt2 = new DataTable();
dt2.Columns.Add("UserId", typeof(int));
dt2.Columns.Add("UserNickName", typeof(string));
dt2.Columns.Add("Gender", typeof(string));
dt2.Rows.Add(1, "小张", "男");
dt2.Rows.Add(3, "小王", "女");
// 创建目标DataTable,包含所有需要的列
DataTable targetDt = new DataTable();
targetDt.Columns.Add("UserId", typeof(int));
targetDt.Columns.Add("UserName", typeof(string));
targetDt.Columns.Add("Age", typeof(int));
targetDt.Columns.Add("UserNickName", typeof(string));
targetDt.Columns.Add("Gender", typeof(string));
// 先将dt1的数据导入目标表
foreach (DataRow row in dt1.Rows)
{
DataRow newRow = targetDt.NewRow();
newRow["UserId"] = row["UserId"];
newRow["UserName"] = row["UserName"];
newRow["Age"] = row["Age"];
targetDt.Rows.Add(newRow);
}
// 再将dt2的数据导入目标表,根据UserId匹配已有行,没有则新增行
foreach (DataRow row in dt2.Rows)
{
int userId = Convert.ToInt32(row["UserId"]);
DataRow[] existRows = targetDt.Select($"UserId = {userId}");
if (existRows.Length > 0)
{
// 已有该UserId的行,补充其他列数据
existRows[0]["UserNickName"] = row["UserNickName"];
existRows[0]["Gender"] = row["Gender"];
}
else
{
// 没有该UserId的行,新增一行
DataRow newRow = targetDt.NewRow();
newRow["UserId"] = row["UserId"];
newRow["UserNickName"] = row["UserNickName"];
newRow["Gender"] = row["Gender"];
targetDt.Rows.Add(newRow);
}
}
// 输出合并后的结果
Console.WriteLine("结构不同合并后的数据:");
foreach (DataRow row in targetDt.Rows)
{
Console.WriteLine($"UserId:{row["UserId"]}, UserName:{row["UserName"]}, Age:{row["Age"]}, UserNickName:{row["UserNickName"]}, Gender:{row["Gender"]}");
}
}
}
}
合并时的注意事项
- 如果两个DataTable都设置了主键,合并时如果出现主键重复的情况,默认会抛出异常,需要提前处理重复主键的数据,或者设置
MissingSchemaAction参数调整处理逻辑 - 合并时列的数据类型必须兼容,比如源表的某一列是int类型,目标表对应列是string类型,合并时不会报错但可能出现数据转换异常,建议合并前先校验列的数据类型
- 如果DataTable中包含自增列,合并后自增列的值会保留源表的值,不会重新生成,需要根据业务需求调整自增列的逻辑
- 合并大量数据时,
Merge方法的性能优于逐行复制,建议优先使用Merge方法处理结构相同的合并场景
常见问题解答
合并后如何去除重复行
如果合并后存在重复行,可以使用DataView的ToTable方法去重,示例如下:
// 假设mergedDt是合并后的DataTable,去除所有列都相同的重复行 DataView dv = new DataView(mergedDt); DataTable distinctDt = dv.ToTable(true);
合并时如何只合并部分列
如果只需要合并部分列,可以先在源DataTable中删除不需要的列,或者创建只包含需要列的新DataTable,再复制对应列的数据进行合并。