歡迎您光臨本站 註冊首頁

馬上學會Linq To Sql,用object的動態查詢與保存log篇(1)

←手機掃碼閱讀     火星人 @ 2014-03-09 , reply:0
      OtmngDataContext db = new OtmngDataContext();
      db.Log = new Vandermotten.Diagnostics.DebuggerWriter();
      System.Linq.IQueryable <int> rolls = getUserRoll().AsQueryable <int>();
  動態的生成sql語句,根據不同的條件構造不同的where字句,是拼接sql 字元串的好處.而Linq的推出,是為了彌補編程中的 Data != Object 的問題.我們又該如何實現用object的動態查詢呢?

  1,用object的查詢是什麼?
  我們可以簡單的舉這麼一個例子.我們到公安局查找一個人.首先,我們會給出他的一些特徵,比如,身高多少,年齡多少,性別,民族等.那麼,我們把這個人的一些特徵輸入電腦.我們希望,電腦能給我們返回這個人的信息.而實際上,有相同特徵的人太多了,常常返回一個集合.那讓我們把這個過程抽象到程式里.我們需要new出來一個對象.這個對象包含了我們能知道的基本信息.而後,把這個對象傳給Linq To Sql,等待返回結果.

  根據這些基本的需求,我們來定義下面的函數,為了實現這個函數對任何實體都是有用的,我們把它定義為generic的.為了不破壞Linq To Sql延遲載入的規矩,我們把它的返回類型定義為IQueryable.如下:
public IQueryable<TEntity> Find<TEntity>(TEntity obj) where TEntity : class
  思路出來了,先new出來一個對象,然後把對象傳給這個函數,我們渴望它能返回與這個對象匹配的結果集.為了讓它和DataContext有關係,我們把這個函數放到DataContext的partial類里.滑鼠右擊Linq To Sql文件,選擇view code,這個時候,vs會為你創造一個DataContext的partial類,其擴展名比影射文件少了中間的desiger.大家要注意,你如果想自己修改影射文件,請放到這個文件里.這樣當影射code被刷新時,才不會衝掉你自己的修改.先大體描述下我們的思路.
NorthwindDataContext db = new NorthwindDataContext();
//先new出一個對象
Customer c = new Customer();
//添入我們知道的最基本的信息,可以從ui獲得
c.City = "London";
c.Phone = "23236133";
//call函數find返回結果
var q = db.Find<Customer>(c);
  2,原理
  Linq To Sql支持用戶動態生成lambda表達式.本文中所實現的方法,正是反射加lambda動態表達式.我們先來看如何動態生成lambda表達式.在Linq 中,lambda表達式會首先轉化為Expression Tree,本文並不詳解Expression Tree.    Expression Tree是lambda表達式從code的形式轉化為data的結果,是一種更高效的在內存中的數據結構.比如:
Func<int,int> f = x => x 1; // Code
Expression<Func<int,int>> e = x => x 1; // Data
  第二個,其實也就是第一個轉化后的形式.那好了,有了這個前提,我們就可以動態構造這個Expression Tree了.
// 先構造了一個ParameterExpression對象,這裡的c,就是Lambda表達中的參數.(c=>)
ParameterExpression param = Expression.Parameter(typeof(TEntity), "c");
//構造表達式的右邊,值的一邊
Expression right = Expression.Constant(p.GetValue(obj, null));
//構造表達式的左邊,property一端.
Expression left = Expression.Property(param, p.Name);
//生成篩選表達式.即c.CustomerID == "Tom"
Expression filter = Expression.Equal(left, right);
//生成完整的Lambda表達式.
Expression<Func<TEntity, bool>> pred = Expression.Lambda<Func<TEntity, bool>>(filter, param);
//在這裡,我們使用的是and條件.
query = query.Where(pred);
  3,反射在本方法中的作用
  我們採用了模板,也就是說,我們並不知道傳進來的對象會有那些property,那反射在這裡就提供一個很好的方法.我們可以通過反射去遍歷每一個property,只有判斷出該property的值不為null時,才將其視為條件.該函數完整的代碼如下:



public IQueryable<TEntity>Find<TEntity>(TEntity obj) where TEntity : class
{
//獲得所有property的信息
PropertyInfo[] properties = obj.GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance);
//構造初始的query
IQueryable<TEntity> query = this.GetTable<TEntity>().AsQueryable<TEntity>();
//遍歷每個property
foreach (PropertyInfo p in properties)
{
if (p != null)
{
Type t = p.PropertyType;
//加入object,Binary,和XDocument, 支持sql_variant,imager 和xml等的影射.
if (t.IsValueType || t == typeof(string) || t == typeof(System.Byte[])
  || t == typeof(object) || t == typeof(System.Xml.Linq.XDocument)
  || t == typeof(System.Data.Linq.Binary))
  {
  //如果不為null才算做條件
  if ( p.GetValue(obj, null) != null)
  {
  ParameterExpression param = Expression.Parameter(typeof(TEntity), "c");
  Expression right = Expression.Constant(p.GetValue(obj, null));
  Expression left = Expression.Property(param, p.Name);
  Expression filter = Expression.Equal(left,right);
  Expression<Func<TEntity, bool>> pred = Expression.Lambda<Func<TEntity, bool>>(filter, param);
  query = query.Where(pred);
  }
  }
  }
  }
  return query;
  }

  4,測試用例及反思
  我們用下面的例子來測試下這個函數
  Customer c = new Customer();
  c.City = "London";
  c.Phone = "23236133";
  var q = db.Find<Customer>(c).ToList();
  其生成的sql語句為:

SELECT [t0].[CustomerID], [t0].[CompanyName], [t0].[ContactName], [t0].[ContactTitle], [t0].[Address], [t0].[City], [t0].[Region], [t0].[PostalCode], [t0].[Country], [t0].[Phone], [t0].[Fax]
FROM [dbo].[Customers] AS [t0]
WHERE ([t0].[Phone] = @p0) AND ([t0].[City] = @p1)
-- @p0: Input NVarChar (Size = 8; Prec = 0; Scale = 0) [23236133]
-- @p1: Input NVarChar (Size = 6; Prec = 0; Scale = 0) [London]
  我們可以看到,其sql語句中,只有city和phone兩個條件.並且他們之間是and的關係.我們最開始的設想實現了,但是,它是完美的嗎?如果是or條件該怎麼辦呢?更多的時候,我們是在用模糊查詢,那又該怎麼辦呢?這個問題,就留於下篇.
  ,介紹一種寫log的方法.stream流使用static為避免多個datacontext的同時在使用log.txt文件.
partial class DataMappingDataContext
{
  private static StreamWriter sw = new StreamWriter(Path.Combine(Directory.GetCurrentDirectory(), "log.txt"),true);
  /**//// <summary>
  /// Try to create DataContext with log.
  /// </summary>
  /// <param name="withLog"></param>
  public DataMappingDataContext(bool withLog): this()
  {
  OnCreated();
  if (withLog)
  {
  if (sw == null)
  {
  sw = new StreamWriter(Path.Combine(Directory.GetCurrentDirectory(), "log.txt"), true);
  }
  this.Log = sw;
  }
  }
  /**//// <summary>
  /// try to close streamwriter
  /// </summary>
  /// <param name="disposing"></param>
  protected override void Dispose(bool disposing)
  {
  base.Dispose(disposing);
  sw.Flush();
  }
}
  在dispose函數里,把輸出流flush.使用時,如下
using(northwind db = new norhwind(true))
{
//do something......
}
好,就先講到這裡.


[火星人 ] 馬上學會Linq To Sql,用object的動態查詢與保存log篇(1)已經有451次圍觀

http://coctec.com/docs/linux/show-post-58693.html