sqlserver合并DataTable并排除重復(fù)數(shù)據(jù)的通用方法分享

///summary>
/// 將兩個(gè)列不同的DataTable合并成一個(gè)新的DataTable
////summary>
///param name="dt1">源表/param>
///param name="dt2">需要合并的表/param>
///param name="primaryKey">需要排重列表（為空不排重）/param>
///param name="maxRows">合并后Table的最大行數(shù)/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();
}
//復(fù)制dt1的數(shù)據(jù)
DataTable dt = dt1.Copy();
//補(bǔ)充dt2的結(jié)構(gòu)（dt1中沒(méi)有的列）到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));
}
}
//復(fù)制dt2的數(shù)據(jù)
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;
//如果需要排重時(shí)，判斷是否需要添加當(dāng)前行
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;
}
}
//添加數(shù)據(jù)
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))
{
//防止因同一字段不同類型賦值出錯(cuò)
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;
}