如何左外连接c#中的两个DataTable?

我如何保持左外连接(我认为它是左外连接,但我不是100%确定)两个数据表具有以下表和条件,同时保留两个表中的所有列?

dtblLeft:

id col1 anotherColumn2 1 1 any2 2 1 any2 3 2 any2 4 3 any2 5 3 any2 6 3 any2 7 any2 

dtblRight:

  col1 col2 anotherColumn1 1 Hi any1 2 Bye any1 3 Later any1 4 Never any1 

dtblJoined:

  id col1 col2 anotherColumn1 anotherColumn2 1 1 Hi any1 any2 2 1 Hi any1 any2 3 2 Bye any1 any2 4 3 Later any1 any2 5 3 Later any1 any2 6 3 Later any1 any2 7 any2 

条件:

  • 在dtblLeft中,col1不需要具有唯一值。
  • 在dtblRight中,col1具有唯一值。
  • 如果dtblLeft缺少col1中的外键或者它具有dtblRight中不存在的外键,则将插入空字段或空字段。
  • 加入col1。

我可以使用常规的DataTable操作,LINQ或其他任何操作。

我尝试了这个,但它删除了重复:

 dtblA.PrimaryKey = new DataColumn[] {dtblA.Columns["col1"]} DataTable dtblJoined = new DataTable(); dtblJoined.Merge(dtblA, false, MissingSchemaAction.AddWithKey); dtblJoined.Merge(dtblB, false, MissingSchemaAction.AddWithKey); 

编辑1:

这接近我想要的但它只有一个表中的列(在此链接中找到):

  dtblJoined = (from t1 in dtblA.Rows.Cast() join t2 in dtblB.Rows.Cast() on t1["col1"] equals t2["col1"] select t1).CopyToDataTable(); 

编辑2:

这个链接的答案似乎对我有用,但我不得不改变它如下:

 DataTable targetTable = dtblA.Clone(); var dt2Columns = dtblB.Columns.OfType().Select(dc => new DataColumn(dc.ColumnName, dc.DataType, dc.Expression, dc.ColumnMapping)); var dt2FinalColumns = from dc in dt2Columns.AsEnumerable() where targetTable.Columns.Contains(dc.ColumnName) == false select dc; targetTable.Columns.AddRange(dt2FinalColumns.ToArray()); var rowData = from row1 in dtblA.AsEnumerable() join row2 in dtblB.AsEnumerable() on row1["col1"] equals row2["col1"] select row1.ItemArray.Concat(row2.ItemArray.Where(r2 => row1.ItemArray.Contains(r2) == false)).ToArray(); foreach (object[] values in rowData) targetTable.Rows.Add(values); 

我也找到了这个链接 ,我可能会尝试一下,因为它看起来更简洁。

编辑3(11/18/2013):

更新了表格以反映更多情况。

感谢你的帮助。 以下是我基于多种资源提出的建议:

 public static class DataTableHelper { public enum JoinType { ///  /// Same as regular join. Inner join produces only the set of records that match in both Table A and Table B. ///  Inner = 0, ///  /// Same as Left Outer join. Left outer join produces a complete set of records from Table A, with the matching records (where available) in Table B. If there is no match, the right side will contain null. ///  Left = 1 } ///  /// Joins the passed in DataTables on the colToJoinOn. /// Returns an appropriate DataTable with zero rows if the colToJoinOn does not exist in both tables. ///  ///  ///  ///  ///  ///  ///  /// http://stackoverflow.com/questions/2379747/create-combined-datatable-from-two-datatables-joined-with-linq-c-sharp?rq=1 /// http://msdn.microsoft.com/en-us/library/vstudio/bb397895.aspx /// http://www.codinghorror.com/blog/2007/10/a-visual-explanation-of-sql-joins.html /// http://stackoverflow.com/questions/406294/left-join-and-left-outer-join-in-sql-server ///  public static DataTable JoinTwoDataTablesOnOneColumn(DataTable dtblLeft, DataTable dtblRight, string colToJoinOn, JoinType joinType) { //Change column name to a temp name so the LINQ for getting row data will work properly. string strTempColName = colToJoinOn + "_2"; if (dtblRight.Columns.Contains(colToJoinOn)) dtblRight.Columns[colToJoinOn].ColumnName = strTempColName; //Get columns from dtblLeft DataTable dtblResult = dtblLeft.Clone(); //Get columns from dtblRight var dt2Columns = dtblRight.Columns.OfType().Select(dc => new DataColumn(dc.ColumnName, dc.DataType, dc.Expression, dc.ColumnMapping)); //Get columns from dtblRight that are not in dtblLeft var dt2FinalColumns = from dc in dt2Columns.AsEnumerable() where !dtblResult.Columns.Contains(dc.ColumnName) select dc; //Add the rest of the columns to dtblResult dtblResult.Columns.AddRange(dt2FinalColumns.ToArray()); //No reason to continue if the colToJoinOn does not exist in both DataTables. if (!dtblLeft.Columns.Contains(colToJoinOn) || (!dtblRight.Columns.Contains(colToJoinOn) && !dtblRight.Columns.Contains(strTempColName))) { if (!dtblResult.Columns.Contains(colToJoinOn)) dtblResult.Columns.Add(colToJoinOn); return dtblResult; } switch (joinType) { default: case JoinType.Inner: #region Inner //get row data //To use the DataTable.AsEnumerable() extension method you need to add a reference to the System.Data.DataSetExtension assembly in your project. var rowDataLeftInner = from rowLeft in dtblLeft.AsEnumerable() join rowRight in dtblRight.AsEnumerable() on rowLeft[colToJoinOn] equals rowRight[strTempColName] select rowLeft.ItemArray.Concat(rowRight.ItemArray).ToArray(); //Add row data to dtblResult foreach (object[] values in rowDataLeftInner) dtblResult.Rows.Add(values); #endregion break; case JoinType.Left: #region Left var rowDataLeftOuter = from rowLeft in dtblLeft.AsEnumerable() join rowRight in dtblRight.AsEnumerable() on rowLeft[colToJoinOn] equals rowRight[strTempColName] into gj from subRight in gj.DefaultIfEmpty() select rowLeft.ItemArray.Concat((subRight== null) ? (dtblRight.NewRow().ItemArray) :subRight.ItemArray).ToArray(); //Add row data to dtblResult foreach (object[] values in rowDataLeftOuter) dtblResult.Rows.Add(values); #endregion break; } //Change column name back to original dtblRight.Columns[strTempColName].ColumnName = colToJoinOn; //Remove extra column from result dtblResult.Columns.Remove(strTempColName); return dtblResult; } } 

编辑3:

此方法现在可以正常工作,当表格有2000多行时,它仍然很快。 任何建议/建议/改进将不胜感激。

编辑4:

我有一个特定的场景让我意识到以前的版本真的在进行内部联接。 该function已被修改以解决该问题。 我在这个链接上使用了信息来弄明白。

这只是两个表之间的内部联接:

 var query = (from x in a.AsEnumerable() join y in b.AsEnumerable() on x.Field("col1") equals y.Field("col1") select new { col1= y.Field("col1"), col2=x.Field("col2") }).ToList(); 

生产:

 col1 col2 1 Hi 1 Hi 2 Bye 3 Later 3 Later 3 Later 

您可以使用LINQ并执行以下操作:

 var dtblJoined = from dB in dtblB.AsEnumerable() join dA in dtblA.AsEnumerable() on dA.col1 equals dB.col1 into dAB from d in dAB.DefaultIfEmpty() select new (col1 = dB.col1, ; col2 = (dB.col1 == dA.col1) ? dA.col2 : null); 

这将返回一个IEnumerable,因为结果不是DataTable,但它应该让你更接近你想要的东西。 可能需要稍微调整一下。