程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> C語言 >> 關於C語言 >> SQL查詢語句對象化的實現(C#)

SQL查詢語句對象化的實現(C#)

編輯:關於C語言

在開發數據庫應用的過程難免會編寫大量的SQL(SQL Server培訓 MySQL培訓 )語句,其中大部份是查詢語句;為不同情況編寫查詢語句是一件很煩瑣的事件。用過hibernate或Nhibernate會了解到把SQL查詢語句對象化後使用起非常方便和快捷;也大大減少在編寫查詢SQL語句所帶來的錯誤等問題。

前段時間在編寫一個數據處理類的時候同樣遇到這個問題,經過一段時間思考和設計現實現了SQL查詢語句對象化的功能;在這裡我把自己小小的成果共享一下。

在講解前先看幾個例子(數據是SQLServer的Northwind)注意:例子中所涉及的除查詢對象化外還包含整個數據處理類的使用,那部分還在設計和完善當中。 http://www.mscto.com

1)以上語句是查詢訂單ID為10264的訂單信息

using(HFSoft.Data.IDataSession session = HFSoft.Data.DataSessionFactory.OpenSession())

{

session.Open();

HFSoft.Data.QueryCmd query = new QueryCmd("Orders");

query.Expreesion.Add(new HFSoft.Data.EqExpression("OrderID",10264));

System.Data.DataSet myDS = session.ExecuteDataSet(query.BuilderCmd(session));

}

對象生成的SQL語句:

SELECT * FROM Orders where 1=1 And (OrderID = @OrderID0)

2)以上語句是查詢訂單ID大於10264並且小於10600的訂單信息

using(HFSoft.Data.IDataSession session = HFSoft.Data.DataSessionFactory.OpenSession())

{

session.Open();

HFSoft.Data.QueryCmd query = new QueryCmd("Orders");

query.Expreesion.Add( new HFSoft.Data.LeExpression("OrderID",10264),

new HFSoft.Data.RtExpression("OrderID",10600));

System.Data.DataSet myDS = session.ExecuteDataSet(query.BuilderCmd(session));

} http://www.mscto.com

對象生成的SQL語句:

SELECT * FROM Orders where 1=1 And (OrderID > @OrderID0) And (OrderID < @OrderID1)

4)以上語句是查詢訂單ID大於10264並且小於10600或編號是10601,10602,10605的訂單信息

using(HFSoft.Data.IDataSession session = HFSoft.Data.DataSessionFactory.OpenSession()) http://www.mscto.com

{

session.Open();

HFSoft.Data.QueryCmd query = new QueryCmd("Orders");

query.Expreesion.Add( new HFSoft.Data.LeExpression("OrderID",10264),

http://www.mscto.com

new HFSoft.Data.RtExpression("OrderID",10600));

query.Expreesion.Add(HFSoft.Data.UintType.Or,new HFSoft.Data.InExpression("OrderID",new int[]{10601,10602,10605}));

System.Data.DataSet myDS = session.ExecuteDataSet(query.BuilderCmd(session)); }

對象生成的SQL語句:

SELECT * FROM Orders where 1=1 And (OrderID > @OrderID0) And (OrderID < @OrderID1) Or (OrderID in (@OrderID20,@OrderID21,@OrderID22))

從上面的例子我們可以看到對不同的條件進行數據查詢只是一件很簡單的事情,你並不用為不同的查詢情況寫相應SQL語句。

接下來講術這個查詢對象實現,對象的最終就是把不同字符串並起來生成相應的SQL語句;SQL語句查詢語句主要分為以下幾大部份:獲取的字段,表名稱,條件,排序,分組;了解SELECT語句的對查詢語句的組成部分比較了解。

其中比較難的就是條件部分處理,因為條件的組合是情況是比較多;所以設計起來相對比較復雜。在設計的過程中把條件單獨抽取出來,並生成接口對條件的表達式進行描述:

///

/// 表達式描述接口 http://www.mscto.com

/// 用於SQL(SQL Server培訓 MySQL培訓 )語句條件表達式的描述

///

http://www.mscto.com

public interface IExpression

{

///

/// 獲取表達式

///

/// 數據處理設備提供者

/// string

string GetFilter(HFSoft.Data.IDriverType driver);

///

http://www.mscto.com

/// 獲取表達式相關的參數

///

/// 數據處理設備提供者

/// System.Data.IDataParameter[]

System.Data.IDataParameter[] GetDataParams(HFSoft.Data.IDriverType driver);

///

/// 序列標識

/// 本屬性用於內部處理

///

string Sequence

{

get;

set; http://www.mscto.com

}

///

/// 添加表達式

///

/// 合並類型(or|and)

/// 表達式對象

void Add(UintType unittype,params IExpression[] expressions );

///

/// 添加表達式

///

/// 表達式對象

void Add(params IExpression[] expressions );

}

在接口描述中有很多地方離不開HFSoft.Data.IDriverType它是用於描述數據庫類型。根據HFSoft.Data.IDriverType 對應生成SqlServer,MySQL,Oracle等數據庫的條件表達式。

為什麼IExpression具有Add方法,並且添加的對象也是IExpression;因為條件自己可以包含多個子表達式,只有這樣才能夠靈活組合成復雜的條件表達式。

接下來看下基於這個接口的實現

///

/// 表達式基礎類

///

[Serializable]

public class Expression:IExpression

{

private string mName; http://www.mscto.com

///

/// 獲取或設置相關的字段名

///

public string Name

{ http://www.mscto.com

get

{

return mName;

}

set http://www.mscto.com

{

mName = value;

http://www.mscto.com

}

}

private object mValue;

///

/// 獲取或設置相關的字段值

///

public object Value

{

get

{

return mValue;

}

set http://www.mscto.com

{

mValue = value;

}

}

private string mSequence = "";

///

/// 獲取或設置相關標識

http://www.mscto.com

/// 本屬性用於內部處理

http://www.mscto.com

///

public string Sequence

{

get

{

return mSequence;

}

set

{

mSequence = value;

http://www.mscto.com

}

}

#region IExpression 成員

///

/// 獲取表達式

///

http://www.mscto.com

/// 數據處理設備提供者

/// string

public virtual string GetFilter(HFSoft.Data.IDriverType driver)

{

return " 1=1 " GetSubString(driver);

}

///

/// 獲取表達式相關的參數

///

/// 數據處理設備提供者

/// System.Data.IDataParameter[]

public virtual System.Data.IDataParameter[] GetDataParams(HFSoft.Data.IDriverType driver)

{

return GetSubParams(driver);

}

http://www.mscto.com

#endregion

private System.Collections.ArrayList _Expressions = new System.Collections.ArrayList();

private System.Collections.ArrayList _Units = new System.Collections.ArrayList();

///

/// 添加相關表達式

///

/// 表達式對象 http://www.mscto.com

public void Add(params IExpression[] expressions )

{

Add(UintType.And,expressions);

}

///

/// 添加相關表達式

///

/// 表達式合並類型

/// 表達式對象

public void Add(UintType unittype,params IExpression[] expressions )

{

if(expressions != null)

foreach(IExpression exp in expressions)

{

if(exp != null)

{

_Units.Add(unittype.ToString());

http://www.mscto.com

exp.Sequence = this.Sequence _Expressions.Count;

_Expressions.Add(exp);

}

}

}

///

/// 獲取內部表達式

///

/// 數據設備提供者

/// string

protected string GetSubString(HFSoft.Data.IDriverType driver)

{

if(_Units.Count == 0)

return "";

System.Text.StringBuilder sb = new System.Text.StringBuilder();

for(int i =0;i< this._Units.Count;i )

{

sb.Append(" " this._Units[i] " (" ((IExpression)_Expressions[i]).GetFilter(driver) ")"); http://www.mscto.com

}

return sb.ToString();

}

http://www.mscto.com

///

/// 獲以內部表達式的參數值

///

/// 數據設備提供者

/// System.Data.IDataParameter[]

protected System.Data.IDataParameter[] GetSubParams(HFSoft.Data.IDriverType driver)

{

if(_Expressions.Count ==0) http://www.mscto.com

return null;

if(_Expressions.Count ==1) http://www.mscto.com

{

return ((IExpression)_Expressions[0]).GetDataParams(driver);

}

System.Collections.ArrayList lst = new System.Collections.ArrayList();

foreach(IExpression exp in this._Expressions)

{

http://www.mscto.com

System.Data.IDataParameter[] ps = exp.GetDataParams(driver);

if(ps !=null && ps.Length >0)

{

foreach(System.Data.IDataParameter dp in ps)

{

lst.Add(dp);

}

}

}

Array array = Array.CreateInstance(typeof(System.Data.IDataParameter),lst.Count);

lst.CopyTo(array);

return array as System.Data.IDataParameter[];

}

}

其實Expression只是一個模板類,它自己本生並沒有條件處理的能力只是一個簡單的1=1;下面我們根據這個模板類派生出具體表達式類型。

http://www.mscto.com

///

/// 基礎表達式抽象類

///

[Serializable]

public abstract class BaseExpression:Expression

{

///

/// 獲取表達式參數對象集

///

/// 數據設備提供者

/// System.Data.IDataParameter[]

public override System.Data.IDataParameter[] GetDataParams(HFSoft.Data.IDriverType driver)

{

System.Data.IDataParameter p1 = driver.GetParameter(Name Sequence,Value);

return ParamsConcat(new System.Data.IDataParameter[]{p1},GetSubParams(driver));

}

///

/// 獲取表達式

///

/// 數據設備提供者

/// string

public override string GetFilter(HFSoft.Data.IDriverType driver)

{

System.Text.StringBuilder sb = new System.Text.StringBuilder();

sb.Append(Name);

sb.Append(GetCompareType());

sb.Append(driver.FormatNameForParameter(Name this.Sequence));

return sb.ToString();

}

///

/// 表達式類型

/// =,like等

///

/// string

protected abstract string GetCompareType();

}

///

/// 等於表達式

///

[Serializable]

public class EqExpression:BaseExpression

{

///

/// 構造等於表達式對象

///

public EqExpression()

{

}

///

http://www.mscto.com

/// 構造指定名稱和值的等於表達式對象

///

/// 名稱

///

public EqExpression(string name,object value)

{

Name = name;

Value = value;

}

///

/// 表達式比較符

///

/// string

protected override string GetCompareType()

{ http://www.mscto.com

return " = ";

}

}

整個條件對象的設計就完成了,文章代碼中只有實現了等於的表達式對象;我們可以按自己情況編寫更復雜的表達式。條件表達式對象在整個查詢對象中是比較核心的部心,因為在整個SQL(SQL Server培訓 MySQL培訓 )查詢語句中除了這些條件外其它地方都是固定的,剩下的就是把些不同的字符串合並起來,這些東西就不詳細說了大家比較了解。

其實Expression只是一個模板類,它自己本生並沒有條件處理的能力只是一個簡單的1=1;下面我們根據這個模板類派生出具體表達式類型。

///

/// 基礎表達式抽象類

http://www.mscto.com

///

http://www.mscto.com

[Serializable]

public abstract class BaseExpression:Expression

{

///

/// 獲取表達式參數對象集

///

/// 數據設備提供者

http://www.mscto.com

/// System.Data.IDataParameter[]

public override System.Data.IDataParameter[] GetDataParams(HFSoft.Data.IDriverType driver)

{

System.Data.IDataParameter p1 = driver.GetParameter(Name Sequence,Value);

return ParamsConcat(new System.Data.IDataParameter[]{p1},GetSubParams(driver));

}

///

/// 獲取表達式

///

/// 數據設備提供者

/// string

public override string GetFilter(HFSoft.Data.IDriverType driver)

{

System.Text.StringBuilder sb = new System.Text.StringBuilder();

sb.Append(Name);

sb.Append(GetCompareType());

sb.Append(driver.FormatNameForParameter(Name this.Sequence)); http://www.mscto.com

return sb.ToString();

} http://www.mscto.com

///

/// 表達式類型

/// =,like等

///

/// string

protected abstract string GetCompareType();

}

///

/// 等於表達式

///

[Serializable]

public class EqExpression:BaseExpression

{

///

/// 構造等於表達式對象

///

public EqExpression()

{

}

///

/// 構造指定名稱和值的等於表達式對象

///

/// 名稱

///

public EqExpression(string name,object value)

{

Name = name;

Value = value;

}

///

/// 表達式比較符

///

/// string

protected override string GetCompareType()

{ http://www.mscto.com

return " = ";

}

}

整個條件對象的設計就完成了,文章代碼中只有實現了等於的表達式對象;我們可以按自己情況編寫更復雜的表達式。條件表達式對象在整個查詢對象中是比較核心的部心,因為在整個SQL(SQL Server培訓 MySQL培訓 )查詢語句中除了這些條件外其它地方都是固定的,剩下的就是把些不同的字符串合並起來,這些東西就不詳細說了大家比較了解。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved