比较两个DataTable数据（结构相同）,返回新增的，删除的，修改前的，修改后的 DataTab

admin1

3. /// <summary>
4.         /// 比较两个DataTable数据（结构相同）
5.         /// </summary>
6.         /// <param name="dt1">来自数据库的DataTable</param>
7.         /// <param name="dt2">来自文件的DataTable</param>
8.         /// <param name="keyField">关键字段名</param>
9.         /// <param name="dtRetAdd">新增数据（dt2中的数据）</param>
10.         /// <param name="dtRetDif1">不同的数据（数据库中的数据）</param>
11.         /// <param name="dtRetDif2">不同的数据（图2中的数据）</param>
12.         /// <param name="dtRetDel">删除的数据（dt2中的数据）</param>
13.         public static void CompareDt(DataTable dt1, DataTable dt2, string keyField,
14.             out DataTable dtRetAdd, out DataTable dtRetDif1, out DataTable dtRetDif2,
15.             out DataTable dtRetDel)
16.         {
17.             //为三个表拷贝表结构
18.             dtRetDel = dt1.Clone();
19.             dtRetAdd = dtRetDel.Clone();
20.             dtRetDif1 = dtRetDel.Clone();
21.             dtRetDif2 = dtRetDel.Clone();
23.             int colCount = dt1.Columns.Count;
25.             DataView dv1 = dt1.DefaultView;
26.             DataView dv2 = dt2.DefaultView;
28.             //先以第一个表为参照，看第二个表是修改了还是删除了
29.             foreach (DataRowView dr1 in dv1)
30.             {
31.                 dv2.RowFilter = keyField + " = '" + dr1[keyField].ToString() + "'";
32.                 if (dv2.Count > 0)
33.                 {
34.                     if (!CompareUpdate(dr1, dv2[0]))//比较是否有不同的
35.                     {
36.                         dtRetDif1.Rows.Add(dr1.Row.ItemArray);//修改前
37.                         dtRetDif2.Rows.Add(dv2[0].Row.ItemArray);//修改后
38.                         dtRetDif2.Rows[dtRetDif2.Rows.Count - 1]["FID"] = dr1.Row["FID"];//将ID赋给来自文件的表，因为它的ID全部==0
39.                         continue;
40.                     }
41.                 }
42.                 else
43.                 {
44.                     //已经被删除的
45.                     dtRetDel.Rows.Add(dr1.Row.ItemArray);
46.                 }
47.             }
49.             //以第一个表为参照，看记录是否是新增的
50.             dv2.RowFilter = "";//清空条件
51.             foreach (DataRowView dr2 in dv2)
52.             {
53.                 dv1.RowFilter = keyField + " = '" + dr2[keyField].ToString() + "'";
54.                 if (dv1.Count == 0)
55.                 {
56.                     //新增的
57.                     dtRetAdd.Rows.Add(dr2.Row.ItemArray);
58.                 }
59.             }
60.         }
62.         //比较是否有不同的
63.         private static bool CompareUpdate(DataRowView dr1, DataRowView dr2)
64.         {
65.             //行里只要有一项不一样，整个行就不一样,无需比较其它
66.             object val1;
67.             object val2;
68.             for (int i = 1; i < dr1.Row.ItemArray.Length; i++)
69.             {
70.                 val1 = dr1[i];
71.                 val2 = dr2[i];
72.                 if (!val1.Equals(val2))
73.                 {
74.                     return false;
75.                 }
76.             }
77.             return true;
78.         }

复制代码