sqlserver合并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;

}