linq中的連接操作符
linq中的連接操作符主要包括Join()和GroupJoin()兩個(gè)。
一、Join()操作符
Join()操作符非常類(lèi)似于T-SQL中的inner join，它將兩個(gè)數(shù)據(jù)源進(jìn)行連接，根據(jù)兩個(gè)數(shù)據(jù)源中相等的值進(jìn)行匹配。例如：可以將產(chǎn)品表和產(chǎn)品類(lèi)別表進(jìn)行連接，得到產(chǎn)品名稱(chēng)和與其對(duì)應(yīng)的類(lèi)型名稱(chēng)。下面看看Join()方法的定義：
public static IEnumerable<TResult> Join<TOuter, TInner, TKey, TResult>(this IEnumerable<TOuter> outer, IEnumerable<TInner> inner, Func<TOuter, TKey> outerKeySelector, Func<TInner, TKey> innerKeySelector, Func<TOuter, TInner, TResult> resultSelector); public static IEnumerable<TResult> Join<TOuter, TInner, TKey, TResult>(this IEnumerable<TOuter> outer, IEnumerable<TInner> inner, Func<TOuter, TKey> outerKeySelector, Func<TInner, TKey> innerKeySelector, Func<TOuter, TInner, TResult> resultSelector, IEqualityComparer<TKey> comparer);
從Join()方法的定義中可以看到：Join操作符的方法原型非常復(fù)雜，從方法原型可以看到，參數(shù)outer和inner是需要連接的兩個(gè)輸入集合。其中outer代表的是調(diào)用的集合。當(dāng)Join操作符被調(diào)用時(shí)，首先列舉inner序列中的所有元素，為序列中每一個(gè)類(lèi)型為U的元素調(diào)用委托InnerKeySelector，生成一個(gè)類(lèi)型為K的的對(duì)象innerKey作為連接關(guān)鍵字。(相當(dāng)于數(shù)據(jù)庫(kù)中的外鍵)，將inner序列中的每一個(gè)元素和其對(duì)應(yīng)的連接關(guān)鍵字innerKey存儲(chǔ)在一個(gè)臨時(shí)哈希表中；其次列舉outer序列中的所有元素，為每一個(gè)類(lèi)型為T(mén)的元素調(diào)用委托outerKeySelector，生成一個(gè)類(lèi)型為K的對(duì)象outKey用作連接關(guān)鍵字，在第一步生成的臨時(shí)哈希表中查找與outKey相等的對(duì)應(yīng)的innerKey對(duì)象，如果找到對(duì)應(yīng)的記錄，會(huì)將當(dāng)前outer序列中的類(lèi)型為T(mén)的元素和對(duì)應(yīng)的inner序列中類(lèi)型為U的元素作為一組參數(shù)傳遞給委托resultSelector，resultSelector會(huì)根據(jù)這兩個(gè)參數(shù)返回一個(gè)類(lèi)型為V的對(duì)象，此類(lèi)型為V的對(duì)象會(huì)被添加到Join操作符的輸出結(jié)果序列中去。Join操作符返回一個(gè)類(lèi)型為IEnumerable<T>的序列。來(lái)看下面的例子：
1、新建Category和Product兩個(gè)類(lèi)，其類(lèi)定義分別如下：
Category：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
public class Category
{
public int Id { get; set; }
public string CategoryName { get; set; }
public DateTime CreateTime { get; set; }
}
}Product：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
public class Product
{
public int Id { get; set; }
public int CategoryId { get; set; }
public string Name { get; set; }
public double Price { get; set; }
public DateTime CreateTime { get; set; }
}
}2、在Main()方法中調(diào)用：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
class Program
{
static void Main(string[] args)
{
// 初始化數(shù)據(jù)
List<Category> listCategory = new List<Category>()
{
new Category(){ Id=1,CategoryName="計(jì)算機(jī)",CreateTime=DateTime.Now.AddYears(-1)},
new Category(){ Id=2,CategoryName="文學(xué)",CreateTime=DateTime.Now.AddYears(-2)},
new Category(){ Id=3,CategoryName="高校教材",CreateTime=DateTime.Now.AddMonths(-34)},
new Category(){ Id=4,CategoryName="心理學(xué)",CreateTime=DateTime.Now.AddMonths(-34)}
};
List<Product> listProduct = new List<Product>()
{
new Product(){Id=1,CategoryId=1, Name="C#高級(jí)編程第10版", Price=100.67,CreateTime=DateTime.Now},
new Product(){Id=2,CategoryId=1, Name="Redis開(kāi)發(fā)和運(yùn)維", Price=69.9,CreateTime=DateTime.Now.AddDays(-19)},
new Product(){Id=3,CategoryId=2, Name="活著", Price=57,CreateTime=DateTime.Now.AddMonths(-3)},
new Product(){Id=4,CategoryId=3, Name="高等數(shù)學(xué)", Price=97,CreateTime=DateTime.Now.AddMonths(-1)},
new Product(){Id=5,CategoryId=6, Name="國(guó)家寶藏", Price=52.8,CreateTime=DateTime.Now.AddMonths(-1)}
};
// 1、查詢表達(dá)式
var queryExpress = from c in listCategory
join p in listProduct on c.Id equals p.CategoryId
select new { Id = c.Id, CategoryName = c.CategoryName, ProductName = p.Name, PublishTime = p.CreateTime };
Console.WriteLine("查詢表達(dá)式輸出:");
foreach (var item in queryExpress)
{
Console.WriteLine($"id:{item.Id},CategoryName:{item.CategoryName},ProductName:{item.ProductName},PublishTime:{item.PublishTime}");
}
Console.WriteLine("方法語(yǔ)法輸出:");
// 方法語(yǔ)法
var queryFun = listCategory.Join(listProduct, c => c.Id, p => p.CategoryId, (c, p) => new { Id = c.Id, CategoryName = c.CategoryName, ProductName = p.Name, PublishTime = p.CreateTime });
foreach (var item in queryFun)
{
Console.WriteLine($"id:{item.Id},CategoryName:{item.CategoryName},ProductName:{item.ProductName},PublishTime:{item.PublishTime}");
}
Console.ReadKey();
}
}
}結(jié)果：
從結(jié)果中可以看出：Join()操作符只會(huì)輸出兩個(gè)結(jié)合中相同的元素，和T-SQL中的inner join類(lèi)似。
在T-SQL中除了內(nèi)連接以外，還有左連接和右連接，那么使用Join()是不是也可以實(shí)現(xiàn)左連接和右連接呢？請(qǐng)看下面的例子。
使用Join()實(shí)現(xiàn)左連接。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
class Program
{
static void Main(string[] args)
{
// 初始化數(shù)據(jù)
List<Category> listCategory = new List<Category>()
{
new Category(){ Id=1,CategoryName="計(jì)算機(jī)",CreateTime=DateTime.Now.AddYears(-1)},
new Category(){ Id=2,CategoryName="文學(xué)",CreateTime=DateTime.Now.AddYears(-2)},
new Category(){ Id=3,CategoryName="高校教材",CreateTime=DateTime.Now.AddMonths(-34)},
new Category(){ Id=4,CategoryName="心理學(xué)",CreateTime=DateTime.Now.AddMonths(-34)}
};
List<Product> listProduct = new List<Product>()
{
new Product(){Id=1,CategoryId=1, Name="C#高級(jí)編程第10版", Price=100.67,CreateTime=DateTime.Now},
new Product(){Id=2,CategoryId=1, Name="Redis開(kāi)發(fā)和運(yùn)維", Price=69.9,CreateTime=DateTime.Now.AddDays(-19)},
new Product(){Id=3,CategoryId=2, Name="活著", Price=57,CreateTime=DateTime.Now.AddMonths(-3)},
new Product(){Id=4,CategoryId=3, Name="高等數(shù)學(xué)", Price=97,CreateTime=DateTime.Now.AddMonths(-1)},
new Product(){Id=5,CategoryId=6, Name="國(guó)家寶藏", Price=52.8,CreateTime=DateTime.Now.AddMonths(-1)}
};
// 1、使用查詢表達(dá)式實(shí)現(xiàn)左連接
var listLeft = from c in listCategory
join p in listProduct on c.Id equals p.CategoryId
into cpList
from cp in cpList.DefaultIfEmpty()
select new
{
Id = c.Id,
CategoryName = c.CategoryName,
ProductName = cp == null ? "無(wú)產(chǎn)品名稱(chēng)" : cp.Name,
PublishTime = cp == null ? "無(wú)創(chuàng)建時(shí)間" : cp.CreateTime.ToString()
};
foreach (var item in listLeft)
{
Console.WriteLine($"id:{item.Id},CategoryName:{item.CategoryName},ProductName:{item.ProductName},PublishTime:{item.PublishTime}");
}
Console.ReadKey();
}
}
}結(jié)果：
從結(jié)果中可以看出：左表listCategory中的數(shù)據(jù)全部輸出了，listCategory中分類(lèi)為4的在listProduct中沒(méi)有對(duì)應(yīng)的產(chǎn)品記錄，所以該項(xiàng)的ProductName和PublishTime輸出為空。
注意：
在左連接中，有可能右表中沒(méi)有對(duì)應(yīng)的記錄，所以使用Select投影操作符的時(shí)候要注意判斷是否為null，否則程序會(huì)報(bào)錯(cuò)，看下面的例子：
使用方法語(yǔ)法實(shí)現(xiàn)左連接要使用下面要講的GroupJoin()，所以使用方法語(yǔ)法實(shí)現(xiàn)左連接放到GroupJoin()中進(jìn)行講解。
右連接
其實(shí)實(shí)現(xiàn)右連接只需要將上面例子中的左表和右邊換一下順序即可?？聪旅娴睦樱?/p>
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
class Program
{
static void Main(string[] args)
{
// 初始化數(shù)據(jù)
List<Category> listCategory = new List<Category>()
{
new Category(){ Id=1,CategoryName="計(jì)算機(jī)",CreateTime=DateTime.Now.AddYears(-1)},
new Category(){ Id=2,CategoryName="文學(xué)",CreateTime=DateTime.Now.AddYears(-2)},
new Category(){ Id=3,CategoryName="高校教材",CreateTime=DateTime.Now.AddMonths(-34)},
new Category(){ Id=4,CategoryName="心理學(xué)",CreateTime=DateTime.Now.AddMonths(-34)}
};
List<Product> listProduct = new List<Product>()
{
new Product(){Id=1,CategoryId=1, Name="C#高級(jí)編程第10版", Price=100.67,CreateTime=DateTime.Now},
new Product(){Id=2,CategoryId=1, Name="Redis開(kāi)發(fā)和運(yùn)維", Price=69.9,CreateTime=DateTime.Now.AddDays(-19)},
new Product(){Id=3,CategoryId=2, Name="活著", Price=57,CreateTime=DateTime.Now.AddMonths(-3)},
new Product(){Id=4,CategoryId=3, Name="高等數(shù)學(xué)", Price=97,CreateTime=DateTime.Now.AddMonths(-1)},
new Product(){Id=5,CategoryId=6, Name="國(guó)家寶藏", Price=52.8,CreateTime=DateTime.Now.AddMonths(-1)}
};
// 使用查詢表達(dá)式實(shí)現(xiàn)右連接
var listRight = from p in listProduct
join c in listCategory on p.CategoryId equals c.Id
into pcList
from pc in pcList.DefaultIfEmpty()
select new
{
Id = p.Id,
CategoryName = pc == null ? "無(wú)分類(lèi)名稱(chēng)" : pc.CategoryName,
ProductName = p.Name,
PublishTime = p.CreateTime
};
foreach (var item in listRight)
{
Console.WriteLine($"id:{item.Id},CategoryName:{item.CategoryName},ProductName:{item.ProductName},PublishTime:{item.PublishTime}");
}
Console.ReadKey();
}
}
}結(jié)果：
從結(jié)果中可以看出：listProduct中的數(shù)據(jù)全部輸出了，listCategory中如果沒(méi)有相應(yīng)的記錄就輸出空值。
注意：
在右連接中也需要和左連接一樣進(jìn)行null值的判斷。
二、GroupJoin()操作符
GroupJoin()操作符常用于返回“主鍵對(duì)象-外鍵對(duì)象集合”形式的查詢，例如“產(chǎn)品類(lèi)別-此類(lèi)別下的所有產(chǎn)品”。
GroupJoin操作符也用于連接兩個(gè)輸入序列，但與Join操作符不同稍有不同，Join操作符在列舉outer序列元素時(shí)，會(huì)將一個(gè)outer序列元素和其對(duì)應(yīng)的inner序列元素作為一組參數(shù)傳遞給委托resultSelector委托，這就意味著如果某一個(gè)outer序列元素有多個(gè)對(duì)應(yīng)的inner序列元素，Join操作符將會(huì)分多次將outer序列元素和每一個(gè)對(duì)應(yīng)的inner序列元素傳遞給委托resultSelector。使用GroupJoin操作符時(shí)，如果某一個(gè)outer序列元素有多個(gè)對(duì)應(yīng)的inner序列元素，那么這多個(gè)對(duì)應(yīng)的inner序列元素會(huì)作用一個(gè)序列一次性傳遞給委托resultSelecotr，可以針對(duì)此序列添加一些處理邏輯。下面看看GroupJoin()操作符的定義：
public static IEnumerable<TResult> GroupJoin<TOuter, TInner, TKey, TResult>(this IEnumerable<TOuter> outer, IEnumerable<TInner> inner, Func<TOuter, TKey> outerKeySelector, Func<TInner, TKey> innerKeySelector, Func<TOuter, IEnumerable<TInner>, TResult> resultSelector); public static IEnumerable<TResult> GroupJoin<TOuter, TInner, TKey, TResult>(this IEnumerable<TOuter> outer, IEnumerable<TInner> inner, Func<TOuter, TKey> outerKeySelector, Func<TInner, TKey> innerKeySelector, Func<TOuter, IEnumerable<TInner>, TResult> resultSelector, IEqualityComparer<TKey> comparer);
留意變紅的那個(gè)委托，注意，與Join操作符的不同點(diǎn)就是一個(gè)outer序列中如果有多個(gè)對(duì)應(yīng)的inner序列元素，會(huì)作為一個(gè)集合IEnumerable<TInner>傳遞到此委托。來(lái)看下面的例子：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
class Program
{
static void Main(string[] args)
{
// 初始化數(shù)據(jù)
List<Category> listCategory = new List<Category>()
{
new Category(){ Id=1,CategoryName="計(jì)算機(jī)",CreateTime=DateTime.Now.AddYears(-1)},
new Category(){ Id=2,CategoryName="文學(xué)",CreateTime=DateTime.Now.AddYears(-2)},
new Category(){ Id=3,CategoryName="高校教材",CreateTime=DateTime.Now.AddMonths(-34)},
new Category(){ Id=4,CategoryName="心理學(xué)",CreateTime=DateTime.Now.AddMonths(-34)}
};
List<Product> listProduct = new List<Product>()
{
new Product(){Id=1,CategoryId=1, Name="C#高級(jí)編程第10版", Price=100.67,CreateTime=DateTime.Now},
new Product(){Id=2,CategoryId=1, Name="Redis開(kāi)發(fā)和運(yùn)維", Price=69.9,CreateTime=DateTime.Now.AddDays(-19)},
new Product(){Id=3,CategoryId=2, Name="活著", Price=57,CreateTime=DateTime.Now.AddMonths(-3)},
new Product(){Id=4,CategoryId=3, Name="高等數(shù)學(xué)", Price=97,CreateTime=DateTime.Now.AddMonths(-1)},
new Product(){Id=5,CategoryId=6, Name="國(guó)家寶藏", Price=52.8,CreateTime=DateTime.Now.AddMonths(-1)}
};
// 使用GroupJoin()實(shí)現(xiàn)左連接
var listLeftFun = listCategory.GroupJoin(listProduct, c => c.Id, p => p.CategoryId, (c, listp) => listp.DefaultIfEmpty(new Product()).Select(z =>
new
{
Id = c.Id,
CategoryName = c.CategoryName,
ProduceName = z.Name,
ProductPrice = z.Price
})).ToList();
foreach (var item in listLeftFun)
{
foreach (var p in item)
{
Console.WriteLine($"CategoryId:{p.Id},CategoryName:{p.CategoryName},ProduceName:{p.ProduceName},ProductPrice:{p.ProductPrice}");
}
}
Console.ReadKey();
}
}
}結(jié)果：
結(jié)果可以看出：使用GroupJoin()操作符可以用Lambda表達(dá)式實(shí)現(xiàn)左連接。
右連接
只需要調(diào)整上面例子中兩張表的順序即可。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConnectOperation
{
class Program
{
static void Main(string[] args)
{
// 初始化數(shù)據(jù)
List<Category> listCategory = new List<Category>()
{
new Category(){ Id=1,CategoryName="計(jì)算機(jī)",CreateTime=DateTime.Now.AddYears(-1)},
new Category(){ Id=2,CategoryName="文學(xué)",CreateTime=DateTime.Now.AddYears(-2)},
new Category(){ Id=3,CategoryName="高校教材",CreateTime=DateTime.Now.AddMonths(-34)},
new Category(){ Id=4,CategoryName="心理學(xué)",CreateTime=DateTime.Now.AddMonths(-34)}
};
List<Product> listProduct = new List<Product>()
{
new Product(){Id=1,CategoryId=1, Name="C#高級(jí)編程第10版", Price=100.67,CreateTime=DateTime.Now},
new Product(){Id=2,CategoryId=1, Name="Redis開(kāi)發(fā)和運(yùn)維", Price=69.9,CreateTime=DateTime.Now.AddDays(-19)},
new Product(){Id=3,CategoryId=2, Name="活著", Price=57,CreateTime=DateTime.Now.AddMonths(-3)},
new Product(){Id=4,CategoryId=3, Name="高等數(shù)學(xué)", Price=97,CreateTime=DateTime.Now.AddMonths(-1)},
new Product(){Id=5,CategoryId=6, Name="國(guó)家寶藏", Price=52.8,CreateTime=DateTime.Now.AddMonths(-1)}
};
var listRightFun = listProduct.GroupJoin(listCategory, p => p.CategoryId, c => c.Id, (p, listc) => listc.DefaultIfEmpty(new Category()).Select(z =>
new
{
id = p.Id,
ProductName = p.Name,
ProductPrice = p.Price,
CategoreName = z.CategoryName
}));
foreach (var item in listRightFun)
{
foreach (var p in item)
{
Console.WriteLine($"id:{p.id},ProduceName:{p.ProductName},ProductPrice:{p.ProductPrice},CategoryName:{p.CategoreName}");
}
}
}
}
}結(jié)果：
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
asp.net基于替換模版頁(yè)的形式生成靜態(tài)頁(yè)的方法
這篇文章主要介紹了asp.net基于替換模版頁(yè)的形式生成靜態(tài)頁(yè)的方法,涉及asp.net模板的設(shè)置、變量替換、配置文件設(shè)置與讀取、以及文件夾與靜態(tài)文件的創(chuàng)建等技巧,需要的朋友可以參考下2016-07-07
Asp.net生成Excel文件并下載（更新：解決使用迅雷下載頁(yè)面而不是文件的問(wèn)題）
Asp.net生成Excel文件并下載（更新：解決使用迅雷下載頁(yè)面而不是文件的問(wèn)題）2012-01-01
獲取客戶端IP地址c#/vb.net各自實(shí)現(xiàn)代碼
項(xiàng)目要求獲取客戶端的IP地址，分析并且用c#與vb各自實(shí)現(xiàn)了此要求，有需要的朋友可以了解下啊，希望本文對(duì)你們有所幫助2013-01-01
.NET Core跨平臺(tái)串口通訊使用SerialPortStream基礎(chǔ)類(lèi)庫(kù)問(wèn)題解決
這篇文章介紹了.NET Core跨平臺(tái)串口通訊使用SerialPortStream基礎(chǔ)類(lèi)庫(kù)問(wèn)題解決，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-01-01
實(shí)質(zhì)上序列化機(jī)制是將類(lèi)的值轉(zhuǎn)化為一個(gè)一般的（即連續(xù)的）字節(jié)流，然后就可以將該流寫(xiě)到磁盤(pán)文件或任何其他流化目標(biāo)上。而要想實(shí)際的寫(xiě)出這個(gè)流，就要使用那些實(shí)現(xiàn)了IFormatter接口的類(lèi)里的Serialize和Deserialize方法。2008-10-10
這篇文章介紹了正確使用dotnet-*工具的方法，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-12-12
很奇怪的,c#中的Split居然只能根據(jù)字符數(shù)組分割的，而沒(méi)有根據(jù)字符串分割的.2009-04-04
CentOS上運(yùn)行ZKEACMS的詳細(xì)過(guò)程
這篇文章主要為大家介紹了CentOS上運(yùn)行ZKEACMS的詳細(xì)過(guò)程，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-05-05
SQL為查詢的結(jié)果加上序號(hào)(ROW_NUMBER) 合并多個(gè)查詢結(jié)果
SQL為查詢的結(jié)果加上序號(hào)(ROW_NUMBER) 合并多個(gè)查詢結(jié)果2010-03-03
小心！ASP.NET網(wǎng)站發(fā)布時(shí)的那些坑
ASP.NET網(wǎng)站發(fā)布時(shí)的那些坑，要小心了，為什么網(wǎng)站發(fā)布后，每個(gè)頁(yè)面第一次打開(kāi)都很卡？ASP.NET session 頻繁丟失如何解決？具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-04-04