当前位置:首页 > LINQ体验(17)——LINQ to SQL语句之动态查询

LINQ体验(17)——LINQ to SQL语句之动态查询

点击次数:1104  更新日期:2010-12-30
\n

高级特性


\n

本文介绍LINQ的高级特性,其包括大家都关心的动态查询的用法,另外简单提下ID标识这个知识。


\n

动态查询


\n

有这样一个场景:应用程序可能会提供一个用户界面,用户可以使用该用户界面指定一个或多个谓词来筛选数据。这种情况在编译时不知道查询的细节,动态查询将十分有用。


\n

在LINQ中,Lambda表达式是许多标准查询运算符的基础,编译器创建lambda表达式以捕获基础查询方法(例如 Where、Select、Order By、Take While 以及其他方法)中定义的计算。表达式目录树用于针对数据源的结构化查询,这些数据源实现IQueryable<T>。例如,LINQ to SQL 提供程序实现 IQueryable<T>接口,用于查询关系数据存储。C#和Visual Basic编译器会针对此类数据源的查询编译为代码,该代码在运行时将生成一个表达式目录树。然后,查询提供程序可以遍历表达式目录树数据结构,并将其转换为适合于数据源的查询语言。


\n

表达式目录树在LINQ中用于表示分配给类型为Expression<TDelegate>的变量的Lambda表达式。还可用于创建动态LINQ查询。


\n

System.Linq.Expressions命名空间提供用于手动生成表达式目录树的API。Expression类包含创建特定类型的表达式目录树节点的静态工厂方法,例如,ParameterExpression(表示一个已命名的参数表达式)或 MethodCallExpression(表示一个方法调用)。编译器生成的表达式目录树的根始终在类型Expression<TDelegate>的节点中,其中TDelegate是包含至多五个输入参数的任何TDelegate委托;也就是说,其根节点是表示一个lambda表达式。


\n

下面几个例子描述如何使用表达式目录树来创建动态LINQ查询。


\n

1.Select


\n

下面例子说明如何使用表达式树依据 IQueryable 数据源构造一个动态查询,查询出每个顾客的ContactName,并用GetCommand方法获取其生成SQL语句。

//依据IQueryable数据源构造一个查询
\nIQueryable<Customer> custs = db.Customers;
\n//组建一个表达式树来创建一个参数
\nParameterExpression param = Expression.Parameter(typeof(Customer), “c”);
\n//组建表达式树:c.ContactName
\nExpression selector = Expression.Property(param,
\n typeof(Customer).GetProperty(“ContactName”));
\nExpression pred = Expression.Lambda(selector, param);
\n//组建表达式树:Select(c=>c.ContactName)
\nExpression expr = Expression.Call(typeof(Queryable), “Select”,
\n new Type[] { typeof(Customer), typeof(string) },
\n Expression.Constant(custs), pred);
\n//使用表达式树来生成动态查询
\nIQueryable<string> query = db.Customers.AsQueryable()
\n .Provider.CreateQuery<string>(expr);
\n//使用GetCommand方法获取SQL语句
\nSystem.Data.Common.DbCommand cmd = db.GetCommand(query);
\nConsole.WriteLine(cmd.CommandText);

\n

生成的SQL语句为:

SELECT [t0].[ContactName] FROM [dbo].[Customers] AS [t0]

\n

2.Where


\n

下面一个例子是“搭建”Where用法来动态查询城市在伦敦的顾客。

IQueryable<Customer> custs = db.Customers;
\n//创建一个参数c
\nParameterExpression param = Expression.Parameter(typeof(Customer), “c”);
\n//c.City==”London”
\nExpression left = Expression.Property(param,
\n typeof(Customer).GetProperty(“City”));
\nExpression right = Expression.Constant(“London”);
\nExpression filter = Expression.Equal(left, right);

\n

Expression pred = Expression.Lambda(filter, param);
\n//Where(c=>c.City==”London”)
\nExpression expr = Expression.Call(typeof(Queryable), “Where”,
\n new Type[] { typeof(Customer) }, Expression.Constant(custs), pred);
\n//生成动态查询
\nIQueryable<Customer> query = db.Customers.AsQueryable()
\n .Provider.CreateQuery<Customer>(expr);


\n

生成的SQL语句为:

SELECT [t0].[CustomerID], [t0].[CompanyName], [t0].[ContactName],
\n[t0].[ContactTitle], [t0].[Address], [t0].[City], [t0].[Region],
\n[t0].[PostalCode], [t0].[Country], [t0].[Phone], [t0].[Fax]
\nFROM [dbo].[Customers] AS [t0] WHERE [t0].[City] = @p0
\n– @p0: Input NVarChar (Size = 6; Prec = 0; Scale = 0) [London]

\n

3.OrderBy


\n

本例既实现排序功能又实现了过滤功能。

IQueryable<Customer> custs = db.Customers;
\n//创建一个参数c
\nParameterExpression param = Expression.Parameter(typeof(Customer), “c”);
\n//c.City==”London”
\nExpression left = Expression.Property(param,
\n typeof(Customer).GetProperty(“City”));
\nExpression right = Expression.Constant(“London”);
\nExpression filter = Expression.Equal(left, right);
\nExpression pred = Expression.Lambda(filter, param);
\n//Where(c=>c.City==”London”)
\nMethodCallExpression whereCallExpression = Expression.Call(
\n typeof(Queryable), “Where”,
\n new Type[] { typeof(Customer) }, Expression.Constant(custs), pred);
\n//OrderBy(ContactName => ContactName)
\nMethodCallExpression orderByCallExpression = Expression.Call(
\n typeof(Queryable), “OrderBy”,
\n new Type[] { typeof(Customer), typeof(string) },
\n whereCallExpression,
\n Expression.Lambda(Expression.Property(param, “ContactName”), param));
\n//生成动态查询
\nIQueryable<Customer> query = db.Customers.AsQueryable()
\n .Provider.CreateQuery<Customer>(orderByCallExpression);

\n

下面一张截图显示了怎么动态生成动态查询的过程


\n

动态查询实例


\n

生成的SQL语句为:

SELECT [t0].[CustomerID], [t0].[CompanyName], [t0].[ContactName],
\n[t0].[ContactTitle], [t0].[Address], [t0].[City], [t0].[Region],
\n[t0].[PostalCode], [t0].[Country], [t0].[Phone], [t0].[Fax]
\nFROM [dbo].[Customers] AS [t0] WHERE [t0].[City] = @p0
\nORDER BY [t0].[ContactName]
\n– @p0: Input NVarChar (Size = 6; Prec = 0; Scale = 0) [London]

\n

4.Union


\n

下面的例子使用表达式树动态查询顾客和雇员同在的城市。

//e.City
\nIQueryable<Customer> custs = db.Customers;
\nParameterExpression param1 = Expression.Parameter(typeof(Customer), “e”);
\nExpression left1 = Expression.Property(param1,
\n typeof(Customer).GetProperty(“City”));
\nExpression pred1 = Expression.Lambda(left1, param1);
\n//c.City
\nIQueryable<Employee> employees = db.Employees;
\nParameterExpression param2 = Expression.Parameter(typeof(Employee), “c”);
\nExpression left2 = Expression.Property(param2,
\n typeof(Employee).GetProperty(“City”));
\nExpression pred2 = Expression.Lambda(left2, param2);
\n//Select(e=>e.City)
\nExpression expr1 = Expression.Call(typeof(Queryable), “Select”,
\n new Type[] { typeof(Customer), typeof(string) },
\n Expression.Constant(custs), pred1);
\n//Select(c=>c.City)
\nExpression expr2 = Expression.Call(typeof(Queryable), “Select”,
\n new Type[] { typeof(Employee), typeof(string) },
\n Expression.Constant(employees), pred2);
\n//生成动态查询
\nIQueryable<string> q1 = db.Customers.AsQueryable()
\n .Provider.CreateQuery<string>(expr1);
\nIQueryable<string> q2 = db.Employees.AsQueryable()
\n .Provider.CreateQuery<string>(expr2);
\n//并集
\nvar q3 = q1.Union(q2);

\n

生成的SQL语句为:

SELECT [t2].[City]
\nFROM (
\n SELECT [t0].[City] FROM [dbo].[Customers] AS [t0]
\n UNION
\n SELECT [t1].[City] FROM [dbo].[Employees] AS [t1]
\n ) AS [t2]

\n

ID标识


\n

在前面这一点没有说到,在这里作为高级特性单独说下ID标识。


\n

这个例子说明我们存储一条新的记录时候,ContactID作为主键标识,系统自动分配,标识种子为1,所以每次自动加一。

//ContactID是主键ID,插入一条数据,系统自动分配ID
\nContact con = new Contact() { CompanyName = “New Era”, Phone = “(123)-456-7890″ };
\ndb.Contacts.InsertOnSubmit(con);
\ndb.SubmitChanges();

\n

本系列链接:LINQ体验系列文章导航



\n

作者:李永京YJingLee’s Blog
出处:http://lyj.cnblogs.com

\n