Linq To Entities 及其相关(进阶)

时间：2021-06-11 06:16:25

上篇我们讲解了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("=============================================");
推荐看以下文章：
 

带参动态查询

最后说到的是带参的动态查询：
  //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属性动态添加参数。

相关文章