欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

sqlserver合并DataTable并排除重复数据的通用方法分享

程序员文章站 2023-12-04 13:16:16
代码如下: 复制代码 代码如下: /// /// 将两个列不同的datatable合并成一个新的datatable ///
代码如下:
复制代码 代码如下:

///<summary>
/// 将两个列不同的datatable合并成一个新的datatable
///</summary>
///<param name="dt1">源表</param>
///<param name="dt2">需要合并的表</param>
///<param name="primarykey">需要排重列表(为空不排重)</param>
///<param name="maxrows">合并后table的最大行数</param>
///<returns>合并后的datatable</returns>
public static datatable mergedatatable(datatable dt1, datatable dt2, string primarykey, int maxrows)
{
//判断是否需要合并
if (dt1 == null && dt2 == null)
{
return null;
}
if (dt1 == null && dt2 != null)
{
return dt2.copy();
}
else if (dt1 != null && dt2 == null)
{
return dt1.copy();
}
//复制dt1的数据
datatable dt = dt1.copy();
//补充dt2的结构(dt1中没有的列)到dt中
for (int i = 0; i < dt2.columns.count; i++)
{
string cname = dt2.columns[i].columnname;
if (!dt.columns.contains(cname))
{
dt.columns.add(new datacolumn(cname));
}
}
//复制dt2的数据
if (dt2.rows.count > 0)
{
type t = dt2.rows[0][primarykey].gettype();
bool isneedfilter = string.isnullorempty(primarykey) ? false : true;
bool isneedquotes = t.name == "string" ? true : false;
int mergetablenum = dt.rows.count;
for (int i = 0; i < dt2.rows.count && mergetablenum < maxrows; i++)
{
bool isneedadd = true;
//如果需要排重时,判断是否需要添加当前行
if (isneedfilter)
{
string primaryvalue = dt2.rows[i][primarykey].tostring();
string fileter = primarykey + "=" + primaryvalue;
if(isneedquotes)
{
fileter = primarykey + "='" + primaryvalue + "'";
}
datarow[] drs = dt.select(fileter);
if (drs != null && drs.length > 0)
{
isneedadd = false;
}
}
//添加数据
if (isneedadd)
{
datarow dr = dt.newrow();
for (int j = 0; j < dt.columns.count; j++)
{
string cname = dt.columns[j].columnname;
if (dt2.columns.contains(cname))
{
//防止因同一字段不同类型赋值出错
if (dt2.rows[i][cname] != null && dt2.rows[i][cname] != dbnull.value && dt2.rows[i][cname].tostring() != "")
{
dr[cname] = dt2.rows[i][cname];
}
}
}
dt.rows.add(dr);
mergetablenum++;
}
}
}
return dt;
}