正文
Linq To Entities 及其相关(进阶)
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
上篇我们讲解了Linq To Entities的一些基本操作，这篇我们主要是讲解一些比较高级的东西：存储过程查询，SQL语句查询以及表达式树。
存储过程
首先来讲解存储过程查询。
//Query a stored procedure.(查询存储过程)
var tenExpensiveP = from p in nWEntities.Ten_Most_Expensive_Products()
select p;
foreach (var product in tenExpensiveP)
{
Console.WriteLine("Stored Procedure scenario: ProductName:{0},Price:{1}", product.TenMostExpensiveProducts, product.UnitPrice);
}
Console.WriteLine("=============================================");
在存储过程这块，我们首先需要做的是导入数据库中的存储过程对象。步骤如下：
1.双击Northwind.edmx，在左边的空白处右击，选择“从数据库更新模型”。
2.在弹出的“更新向导”窗口中，选中自己需要添加的存储过程：Ten_Most_Expensive_Products，之后点击完成按钮。
3.在左边的空白处右击，选择”添加“->”函数导入”，在弹出的”添加函数导入“对话框中，”函数导入名称“填写Ten_Most_Expensive_Products，然后在下面的”存储过程名称”中，下拉选择“Ten_Most_Expensive_Products”。之后点击“获取列信息”，可以看到返回的列已经显示在了下面的列表中。然后单击“创建新的复杂类型”按钮，则“复杂”单选框被激活，并且其后的文本框中自动会填充“Ten_Most_Expensive_Products”文本。做好这一切之后，点击“确定”按钮即可。
4.步骤3操作完毕后，Ten_Most_Expensive_Products实体类就被添加到了项目中，我们可以像操作其他实体类一样操作这个存储过程。
预编译查询
之后我们需要提到的是预编译查询。预编译查询主要是用于多个相似的查询存在的情况下，比如我在同一张表中第一次查询张三，第二次查询李四，那么我不必分两次去数据库拿数据，只要通过预编译查询，一次把所有需要的数据提取出来即可。
//Compiled Query
//如果相同的查询操作在许多地方被使用，那么可以提前编译好需要执行的查询操作，然后在多个地方使用，可以提高Performance
Func<NorthWindEntities, string, IQueryable<Product>> func =
CompiledQuery.Compile((NorthWindEntities NW, string category) =>from p in NW.Products where p.Category.CategoryName == category select p);
var product1 = func(nWEntities, "Beverages");
Console.WriteLine("Compiled query scenario: Total Products in category Beverages:{0}", product1.Count());
var product2 = func(nWEntities, "Seafood");
Console.WriteLine("Compiled query scenario: Total Products in category Seafood: {0}",product2.Count());
Console.WriteLine("=============================================");
其实上面你的代码只查询了数据库一次，但是可以在两个地方使用。
直接执行SQL语句
这里我们需要说到的是怎么在Linq to entities中执行sql语句。有时候当sql过于复杂的时候，我们完全可以利用原生的sql语句来查询。
//Direct SQL(直接是用SQL语句)
var products = nWEntities.ExecuteStoreQuery<Product>("SELECT * FROM Products WHERE Discontinued = 0 ORDER BY ProductName;");
Console.WriteLine("Direct SQL: Total discontinued products :{0}", products.Count());int rowCount = nWEntities.ExecuteStoreCommand(" update products set UnitPrice=UnitPrice+1 where productID=35 ");
if (rowCount < 1) Console.WriteLine("Direct SQL: No product is updated.");
if (rowCount >= 1) Console.WriteLine("Direct SQL: Product is updated.");
Console.WriteLine("=============================================");
这里有两个方法：ExecuteStoreQuery用于提供查询操作；ExecuteStoreCommand用于提供执行操作。
表达式树
接下来是表达式树的说明，由于这个涉及的范围比较广，暂时先略过讲解，待之后慢慢研究：
//Expression Tree(表达式树)
ParameterExpression param = Expression.Parameter(typeof(Product),"p");
Expression left = Expression.Property(param,typeof(Product).GetProperty("UnitPrice"));
Expression right = Expression.Constant((decimal)100, typeof(Nullable<decimal>));
Expression filter = Expression.GreaterThanOrEqual(left,right);
Expression pred = Expression.Lambda(filter,param);
Console.WriteLine(pred.ToString()); //输出 p=>(p.UnitPrice>=100)IQueryable productList = nWEntities.Products;
Expression expr = Expression.Call(typeof(Queryable)
, "Where"
, new Type[] { typeof(Product)}
, Expression.Constant(productList)
, pred);
expr = Expression.Call(typeof(Queryable)
, "OrderBy"
, new Type[] { typeof(Product), typeof(string) }
, expr
, Expression.Lambda(Expression.Property(param, "ProductName"), param));
Console.WriteLine(expr.ToString());IQueryable<Product> query = nWEntities.Products.AsQueryable().Provider.CreateQuery<Product>(expr);
foreach (var p in query)
{
Console.WriteLine("Expression Tree scenario: Product name: {0}",p.ProductName);
}
Console.WriteLine("=============================================");
推荐看以下文章：
打造自己的LINQ Provider（上）：Expression Tree揭秘
打造自己的LINQ Provider（中）：IQueryable和IQueryProvider
深度训练Linq系列
带参动态查询
最后说到的是带参的动态查询：
//Dynamic Query with parameters(带参的动态查询)
string querystring = "select value product from NorthwindEntities.Products as Product where Product.ProductID = @id";
ObjectQuery<Product> productQuery = new ObjectQuery<Product>(querystring, nWEntities);
productQuery.Parameters.Add(new ObjectParameter("id", 1));
foreach (var p in productQuery)
{
Console.WriteLine("Dynamic query with parameters: ProductName {0}",p.ProductName);
}
这里我们可以利用ObjectQuery的Parameters属性动态添加参数。
