LINQ驱动数据的查询功能
阅读原文时间:2020年09月20日阅读:1

一、LINQ概念

LINQ是微软在.NetFramework3.5中新加入的语言功能,在语言中以程序代码方式处理集合的能力。

在我刚工作时候,对于集合对象的处理一般是采用循环这个集合处理,在处理实值类型上这样做效率还行,但是如果集合内是引用类型,使用LINQ就方便的多,例如一个程序要计算课程的总分和平均分,实体分别是Student和StudentScore

类的申明如下:

///

/// 学生实体 ///
public class Student
{
/// /// 学生主键 ///
public string StudentID { get; set; }

   /// <summary>  
   /// 学生名称  
   /// </summary>  
   public string StudentName { get; set;}

}

/// <summary>  
/// 学生分数实体  
/// </summary>  

public class StudentScore
{
///

/// 学生分数主键 ///
public string ScoreId { get; set; }

   /// <summary>  
   ///学生分数  
   /// </summary>  
   public int Score { get; set; }  
}

使用循环方式实现统计本班总分和平均分代码如下:

        List<Student> students = GetStudents();  
        List<StudentScore> CSScoreList = GetCSScores();  
        List<StudentScore> DBScoreList = GetDBScores();

        double CSSum = 0.0, DBSum = 0.0;  
        //循环C#集合  
        foreach (StudentScore csScore in CSScoreList)  
        {  
            CSSum = CSSum + csScore.Score;  
        }  
        //循环DB集合  
        foreach (StudentScore dbScore in DBScoreList)  
        {  
            DBSum += dbScore.Score;  
        }  
        Console.WriteLine("本班的C#总分是:{0},平均分是:{1}", CSSum, CSSum/students.Count);  
        Console.WriteLine("本班的SQL总分是:{0},平均分是:{1}", DBSum, DBSum / students.Count);  
        Console.ReadKey();

使用Linq的代码处理如下

Console.WriteLine("本班的C#总分是:{0},平均分是:{1}", CSScoreList.Sum(t=>t.Score),CSScoreList.Average(t=>t.Score));
Console.WriteLine("本班的SQL总分是:{0},平均分是:{1}", DBScoreList.Sum(t => t.Score), DBScoreList.Average(t => t.Score));

使用LINQ中最简单的例子,说明LINQ给我们带来的便利。

二、LINQ的基础

LINQ本身以IEnumerable两个接口为基础,IEnumerable则负责泛型的集合,目前.NET Framework内的泛型集合类 System.Collection.Generic 命名空间都已实现 IEnumerable,一般来说在.NET内的所有集合对象都能使用LINQ进行处理,如果不引用System.Linq命名空间,所有Linq功能都无法使用。

扩展方法赋予了程序设计语言可在现有类下扩展类的功能,且不需要修改原本程序代码。实现扩展方法十分简单,只需要建立一个静态类,名称建议用 "要扩展的类名称"+Extension字样,例如扩展Int的方法,就将类名命名为Int32Extension,接下来在类内加入要扩展的方法,但是要注意两件事:

1.必须是静态方法,且名称不能和现有的方法冲突

2.参数至少有一个,且类型为扩展类型,格式是"this[要扩展的类名称][参数名称]",若有两个以上的参数,则扩展类型放在第一个不能设置默认值。

///

/// 定义INT32扩展类 ///
public static class Int32Extension
{
public static string FormartForMoney(this Int32 value)
{
return value.ToString("$###,###,###,##0");
}
}

/// <summary>  
/// 定义Double类型的拓展类  
/// </summary>  
public static class DoubleExtension  
{  
    public static string FormartPercent(this double value)  
    {  
        return value.ToString("0.00%");  
    }  
}

int money = ;
double d = 0.12345;
Console.WriteLine("{0}", money.FormartForMoney());
Console.WriteLine("{0}", d.FormartPercent());
Console.ReadKey();

语法中有一个select new ,可以按所设置的属性自动产生类对象,并且自动赋予数值,这个语法包含了两个语言功能:对象初始化器与匿名类型。

对象初始化器:允许程序中通过声明方式直接给对象属性进行数值的初始化,而不必建立有参数的构造函数。(字典类型必须按照特定格式初始化)

匿名类型:不定义类的情况下生成新的类,Linq中常用。其中有几点限制:

(1)  匿名类型只在同一个函数内,如果要在其他函数共享必须动用Reflection或者是利用.NET4.0提供的动态类型机制。

(2)  匿名类型只能有属性,不可以有方法、事件、或字段等。

(3)  两个匿名类型对象的相等,必须要两个对象的属性值都相等才行。

(4) 匿名类型的初始化只能利用对象初始化器来进行,其属性生成后会变成只读。

使用匿名类型在Linq中变量类型无法确定,如果试用IEnumerable就失去强类型的好处,在.NET3.5中只要使用Linq并且以select new来产生结果的查询,其变量类型声明会使用var类型表示,var类型代表编译器腿短这个变量的类型,在LINQ中复杂查询如果是嵌套的错误率较高,所以用var替代。var的限制如下:

(1)使用var类型赋值语句时右边不能为null,否则编译器无法推断其类型。

(2)var类型只能用于局部变量的声明,不能用于全局变量,类层变量或者是函数的返回值。

(3)var类型不可用在匿名委派或者是方法群组中。

微软提供了一个指令yield,它可以只传回每个元素的方式自动生成IEnumerable对象

private static IEnumerable GetYieldResult(IEnumerable param)
{
foreach (var num in param)
{
if (num > )
{
yield break;
}
else
{
yield return num;
}
}
}

yield指令乍看之下只是精简写法,实际上这个方法的执行推迟到真正查询才触发,例如调用这个方法时候并不会执行,当执行ToList()时候才执行,这个机制称为延迟查询或者延迟执行。

三、Linq语句

Linq语句主要应用于集合的处理上, 这就是Linq的价值所在,而对于外部数据源,只要有相应的LINQ provider就一样享有Linq的完整功能。

通过例子学习LINQ是我的做法,例如以下就是求两个集合中相同存在的数字:

        List<int> list1 = new List<int>() { , , , , , ,  };  
        List<int> list2 = new List<int>() { , , , , ,  };  
        var query = from item1 in list1 join item2 in list2 on item1 equals item2 select item1;  
        foreach (var q in query)  
        {  
            Console.WriteLine("{0}", q);  
        }

或者是查询目前某个订单的销售总数

var query=from o in orderList

        group by o.ProductID into g

         select new{ProductID=g.Key,Qty=g.sum(t=>t.ProductID)}

四、Linq函数

Where():查询结果过滤

  Select():选取数据

SelectMany():相当于数据库的Cross Join,这个的查询结果是笛卡尔积,就是两个表数据的乘积,将表一所有数据和表二连接,通过例子:

IEnumerable selectMany = list1.SelectMany(t=>list2).ToList(); 也可以写成   IEnumerable selectMany = list1.SelectMany((int o) => { return list2; }).ToList();  selectMany()参数是Func>

GroupBy():本身具有延迟查询的特性:

         List<int> groupList = new List<int>() { , , , , , , , , , , , ,  };  
        IEnumerable<IGrouping<int,int>> groupquery = groupList.GroupBy(t => t);  
        foreach (var group in groupquery)  
        {  
            Console.WriteLine("{0}的数量有{1}个", group.Key, group.Count());  
        }

ToLookup():和GroupBy()类似没有延迟加载,但是它会产生一个新的集合对象,这个集合对象由ILookup所组成,允许多个键存在,一个键包含很多关联的实值例如:

var nameGroup = new[]
{
new {name="CallmeYhz",age=,group="A"},
new {name="周公瑾",age=,group="B"},
new {name="孔明",age=,group="A"},
new {name="郭奉孝",age=,group="C"},
new {name="孙仲谋",age=,group="B"},
new {name="子龙",age=,group="A"}
};

        var ToLookUp = nameGroup.ToLookup(t => t.group);  
        foreach (var bigGroup in ToLookUp)  
        {  
            Console.WriteLine("当前是组{0}", bigGroup.Key);  
            foreach (var smallGroup in bigGroup)  
            {  
                Console.Write("名字是:{0},年龄是:{1}", smallGroup.name, smallGroup.age);  
            }  
            Console.WriteLine();  
            Console.WriteLine();  
            Console.WriteLine();  
        }

Join():

在linq语句中使用

List list1 = new List() { , , , , , };
List list2 = new List() { , , , , , };
var query = from item1 in list1
join item2 in list2 on item1 equals item2
select item1;

        query.ToList().ForEach(t => Console.Write("{0} ", t));

由此例子可知,它将原本的集合视为TOuter而将传入的集合视为TInner,而还要决定由哪个属性或者成员当Key。例子中list1为本身,注意顺序。

上面用linq函数实现则为:

List list1 = new List() { , , , , , };
List list2 = new List() { , , , , , };
var query = list1.Join(list2, a=>a, b=>b,(a,b)=>b);
query.ToList().ForEach(t => Console.Write("{0} ", t));

总结:目前常用的联接模式,Inner join由Enumerable.Join()实现,CROSS JOIN 由EnumerableSelectMany实现,还有一种Join模式没有考虑:LEFT OUTER JOIN 模式,要实现这个模式必须借助GroupJoin()。

GroupJoin():

List list1 = new List() { , , , , , };
List list2 = new List() { , , , , , , };
var query = list1.GroupJoin(
list2,
a => a,
b => b,
(a, b) => new { v = a, c = b.Count() });

        query.ToList().ForEach(t => Console.WriteLine("找到list2中有{0}个{1}", t.c, t.v));