C#3.0 修正微調 DAL

2008-09-21 置頂文章

2499
0
.NET

摘要:C#3.0 修正微調 DAL

一樣是留個紀錄 ...

1.修正(DAL) - 組合SQL片段 (解決與SqlSerVer關鍵字衝突問題將資料表名稱用[ ] 框起來);

2.新增(DAL)-加入InsertWithReturn方法 (取回自動編號的值);

3.修正(DAL)-try...catch 區段重新規劃中

4.修正(DAL)-介面調整

5.新增(BAL)-基底類別GenericBase加入InsertWithReturn方法

6.修正(BAL)-介面調整

MySqlServer

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;

/// /// <summary> /// 資料存取層核心元件 - design By Phoenix 2008 /// </summary> public class MySqlServer : IQuery { //宣告連線字串物件 private ConnectionString ConnStr; #region 組合SQL片段 /// /// <summary> /// 去片段多餘的字元 - design By Phoenix 2008 /// </summary> /// <param name="Part">片段</param> /// <returns>Part.Trim().TrimEnd(char.Parse(","))</returns> private string TrimPart(string Part) { //去掉開頭多餘的空白 //去除結尾多餘的逗號 //回傳結果 return Part.Trim().TrimEnd(char.Parse(",")); } /// /// <summary> /// 產生加入參數的片段 - design By Phoenix 2008 /// </summary> /// <param name="FieldName">要加上參數的強型別物件清單</param> /// <returns>DataField1 = @DataField1, DataField2 = @DataField2, … DataFieldN = @DataFieldN</returns> private string SetParameterPart(List<DataField> FieldName) { //建立回傳暫存 string result = ""; //一一取出清單內的值，並且加上參數 foreach (DataField s in FieldName) result += string.Format(" {0} = @{1},", s.ColumnName.Replace("Original_", ""), s.ColumnName); //呼叫TrimPart //回傳結果 return TrimPart(result); } /// /// <summary> /// 產生Insert參數片段 - design By Phoenix 2008 /// </summary> /// <param name="FieldName">要加入參數的強型別物件清單</param> /// <returns>(DataField1, DataField2, … DataFieldN) VALUES (@DataField1, @DataField2, … @DataFieldN)</returns> private string SetInsertPart(List<DataField> FieldName) { //建立回傳暫存(欄位片段、參數片段) string insertField = ""; string insertParameter = ""; //一一取出清單內的值，並且產生欄位片段以及參數片段 foreach (DataField s in FieldName) { insertField += string.Format(" {0},", s.ColumnName); insertParameter += string.Format(" @{0},", s.ColumnName); } //呼叫TrimPart //將欄位片段以及參數片段組合成Insert片段 //回傳結果 return string.Format("({0}) VALUES ({1})", TrimPart(insertField), TrimPart(insertParameter)); } /// /// <summary> /// 產生 Select 敘述片段 - design By Phoenix 2008 /// </summary> /// <param name="SelectField">Select欄位(*,表示全部)</param> /// <returns>DataField1, DataField2, … DataFieldN</returns> private string SetSelectPart(string[] SelectField) { //建立回傳暫存 string result = ""; //一一取出清單內的值，加上逗號 foreach (string s in SelectField) result += string.Format(" {0},", s); //呼叫TrimPart //回傳結果 return TrimPart(result); } /// /// <summary> /// 產生Select`From 敘述 - design By Phoenix 2008 /// </summary> /// <param name="SelectField">Select欄位(*,表示全部)</param> /// <param name="Name">列舉-資料表名稱</param> /// <returns>SELECT SelectField FORM DbName</returns> private string GetSelectQuery(string[] SelectField, DbName Name) { //將 SelectField 和 DbName 加入到敘述內 //回傳結果。 return string.Format("SELECT {0} FROM [{1}]", SetSelectPart(SelectField), Name.ToString()); } /// /// <summary> /// 產生Select`From`Where 敘述 - design By Phoenix 2008 /// </summary> /// <param name="SelectField">Select欄位(*,表示全部)</param> /// <param name="Name">列舉-資料表名稱</param> /// <param name="Condition">條件清單</param> /// <returns>SELECT SelectField FORM DbName WHERE (DataField1 = @DataField1, DataField2 = @DataField2, … DataFieldN = @DataFieldN)</returns> private string GetSelectWhereQuery(string[] SelectField, DbName Name, List<DataField> Condition) { //呼叫GetSelectQuery，取得敘述片段 //呼叫SetParameterPart，取得參數片段 //組合兩片段 //回傳結果 return string.Format("{0} WHERE ({1})", GetSelectQuery(SelectField, Name), SetParameterPart(Condition)); } /// /// <summary> /// 產生Insert`Into``Values` 敘述 - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="DataField">新增清單</param> /// <returns>INSERT INTO DbName (DataField1,DataField2…DataFieldN) VALUES (@DataField1, @DataField2, … @DataFieldN)</returns> private string GetInsertQuery(DbName Name, List<DataField> DataField) { //呼叫SetInsertPart 取得 Insert片段 //將 DbName 和 Insert片段放入敘述內。 //回傳結果 return string.Format("INSERT INTO [{0}] {1}", Name.ToString(), SetInsertPart(DataField)); } ///  /// <summary> /// 加上回傳自動編號的參數 - design By Phoenix 2008 - /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="DataField">Insert清單</param> /// <returns></returns> private string SerReturn(DbName Name, List<DataField> DataField) { return string.Format("{0} select scope_identity()", GetInsertQuery(Name, DataField)); } /// /// <summary> /// 產生Delete From`Where`敘述 - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="Condition">條件清單</param> /// <returns>DELETE FROM DbName WHERE(Condition1 = @Condition1, Condition2 = @Condition2, … ConditionN = @ConditionN)</returns> private string GetDeleteQuery(DbName Name, List<DataField> Condition) { //呼叫SetParameterPart，取得參數片段 //將 DbName 和參數片段放入敘述內。 //回傳結果 return string.Format("DELETE FROM {0} WHERE ({1})", Name.ToString(), SetParameterPart(Condition)); } /// /// <summary> /// 產生Update`Set`Where`敘述 - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="Data">DataField強行別物件清單</param> /// <returns></returns> private string GetUpdateQuery(DbName Name, List<DataField> Data) { //取得條件式(以Original開頭) List<DataField> Condition = Data.FindAll(c => c.ColumnName.StartsWith("Original")); //取得新的值(除Original以外) List<DataField> UpdateField = Data.FindAll(c => !(c.ColumnName.StartsWith("Original"))); //呼叫SetParameterPart，取得參數片段(新值) //呼叫SetParameterPart，取得參數片段(條件) //組合兩片段 //回傳結果 return string.Format("UPDATE [{0}] SET {1} WHERE ({2})", Name.ToString(), SetParameterPart(UpdateField), SetParameterPart(Condition)); } #endregion /// /// <summary> /// 創造Parameters - design By Phoenix 2008 /// </summary> /// <param name="Data">DataField強行別物件清單</param> /// <returns>Parameters陣列</returns> private SqlParameter[] CreateParameters(List<DataField> Data) { //建立回傳暫存 SqlParameter[] result = new SqlParameter[Data.Count]; //一一取出清單內的名字和值，放入result集合 for (int i = 0; i < Data.Count; i++) result[i] = new SqlParameter("@" + Data[i].ColumnName, Data[i].ColumnValue); //回傳結果 return result; } #region 執行SQL指令 /// /// <summary> /// 執行ExecuteReader - 取得DataTable - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">Sql命令</param> /// <returns>DataTable資料表</returns> private DataTable ExecuteReader(string SqlQuery) { //例外處理 try { //建立回傳暫存 DataTable dt = new DataTable(); //使用 SqlConnection 建立 SqlConnection 執行個體(傳入連線字串) using (SqlConnection SqlConn = new SqlConnection(ConnStr.GetConnStr())) { //宣告 SqlCommand ，建立 SqlCommand 執行個體(傳入Sql命令、SqlConnection) SqlCommand SqlCmd = new SqlCommand(SqlQuery, SqlConn); //開啟連線 SqlConn.Open(); //載入DataTable dt.Load(SqlCmd.ExecuteReader()); } //回傳結果 return dt; } catch (SqlException ex) { throw new InvalidOperationException(string.Format("ExecuteReader區段執行失敗\r\n<{0}>\r\n<{1}>", ex.Message, ex.StackTrace)); } catch { //擲回例外 throw new InvalidOperationException("ExecuteReader區段執行失敗"); } } /// /// <summary> /// 執行ExecuteReader - 取得DataTable - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">Sql命令</param> /// <param name="Parameters">參數</param> /// <returns>DataTable資料表</returns> private DataTable ExecuteReader(string SqlQuery, SqlParameter[] Parameters) { //例外處理 try { //建立回傳暫存 DataTable dt = new DataTable(); //使用 SqlConnection 建立 SqlConnection 執行個體(傳入連線字串) using (SqlConnection SqlConn = new SqlConnection(ConnStr.GetConnStr())) { //宣告 SqlCommand ，建立 SqlCommand 執行個體(傳入Sql命令、SqlConnection) SqlCommand SqlCmd = new SqlCommand(SqlQuery, SqlConn); //將參數加入SqlCommand SqlCmd.Parameters.AddRange(Parameters); //開啟連線 SqlConn.Open(); //載入DataTable dt.Load(SqlCmd.ExecuteReader()); } //回傳結果 return dt; } catch (SqlException ex) { throw new InvalidOperationException(string.Format("ExecuteReader區段執行失敗\r\n<{0}>\r\n<{1}>", ex.Message, ex.StackTrace)); } catch { throw new InvalidOperationException("ExecuteReader區段執行失敗"); } } /// /// <summary> /// 執行ExecuteNonQuery - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">Sql命令</param> /// <returns>受影響的行數</returns> private int ExecuteNonQuery(string SqlQuery) { //例外處理 try { //建立回傳暫存 int result = 0; //使用 SqlConnection 建立 SqlConnection 執行個體(傳入連線字串) using (SqlConnection SqlConn = new SqlConnection(ConnStr.GetConnStr())) { //宣告 SqlCommand ，建立 SqlCommand 執行個體(傳入Sql命令、SqlConnection) SqlCommand SqlCmd = new SqlCommand(SqlQuery, SqlConn); //開啟連線 SqlConn.Open(); //執行ExecuteNonQuery，傳回受影響的行數 result = SqlCmd.ExecuteNonQuery(); } //傳回受影響的行數 return result; } catch (SqlException ex) { throw new InvalidOperationException(string.Format("ExecuteNonQuery區段執行失敗\r\n<{0}>\r\n<{1}>", ex.Message, ex.StackTrace)); } catch { throw new InvalidOperationException("ExecuteNonQuery區段執行失敗"); } } /// /// <summary> /// 執行ExecuteNonQuery - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">Sql命令</param> /// <param name="Parameters">參數陣列</param> /// <returns>受影響的行數</returns> private int ExecuteNonQuery(string SqlQuery, SqlParameter[] Parameters) { //例外處理 try { //建立回傳暫存 int result = 0; //使用 SqlConnection 建立 SqlConnection 執行個體(傳入連線字串) using (SqlConnection SqlConn = new SqlConnection(ConnStr.GetConnStr())) { //宣告 SqlCommand ，建立 SqlCommand 執行個體(傳入Sql命令、SqlConnection) SqlCommand SqlCmd = new SqlCommand(SqlQuery, SqlConn); //將參數加入SqlCommand SqlCmd.Parameters.AddRange(Parameters); //開啟連線 SqlConn.Open(); //執行ExecuteNonQuery，傳回受影響的行數 result = SqlCmd.ExecuteNonQuery(); } //傳回受影響的行數 return result; } catch (SqlException ex) { throw new InvalidOperationException(string.Format("ExecuteNonQuery區段執行失敗\r\n<{0}>\r\n<{1}>", ex.Message, ex.StackTrace)); } catch { throw new InvalidOperationException("ExecuteNonQuery區段執行失敗"); } } #endregion #region IQuery 成員 - 實作介面 /// /// <summary> /// 執行SQL命令 - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">SQL命令</param> /// <returns>受影響的行數</returns> public int RunQuery(string SqlQuery) { //呼叫ExecuteNonQuery(傳入Sql命令)(傳回受影響的行數)。 //傳回受影響的行數 return ExecuteNonQuery(SqlQuery); } /// /// <summary> /// 執行SQL命令 - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">SQL命令</param> /// <param name="Parameters">參數陣列</param> /// <returns>受影響的行數</returns> public int RunQuery(string SqlQuery, SqlParameter[] Parameters) { //呼叫ExecuteNonQuery(傳入Sql命令)(傳回受影響的行數)。 //傳回受影響的行數 return ExecuteNonQuery(SqlQuery, Parameters); } /// /// <summary> /// Select介面 - 取得資料表 - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">Sql命令</param> /// <returns>DataTable資料表</returns> public DataTable GetTable(string SqlQuery) { //呼叫 ExecuteReader(傳入Sql命令)(回傳DataTable資料表) //回傳DataTable資料表。 return ExecuteReader(SqlQuery); } /// /// <summary> /// Select介面 - 取得資料表 - design By Phoenix 2008 /// </summary> /// <param name="SqlQuery">Sql命令</param> /// <param name="Parameters">參數陣列</param> /// <returns>DataTable資料表</returns> public DataTable GetTable(string SqlQuery, SqlParameter[] Parameters) { //呼叫 ExecuteReader(傳入Sql命令)(回傳DataTable資料表) //回傳DataTable資料表。 return ExecuteReader(SqlQuery, Parameters); } /// /// <summary> /// Select介面 - 取得資料表 - design By Phoenix 2008 /// </summary> /// <param name="SelectField">Select欄位(*,表示全部)</param> /// <param name="Name">列舉-資料表名稱</param> /// <returns>DataTable資料表</returns> public DataTable GetTable(string[] SelectField, DbName Name) { //呼叫GetSelectQuery(傳入Select欄位、資料表)(傳回Sql命令) //呼叫ExecuteReader(傳入Sql命令)(傳回DataTable資料表) //傳回DataTable資料表 return ExecuteReader(GetSelectQuery(SelectField, Name)); } /// /// <summary> /// Select介面 - 取得資料表 - design By Phoenix 2008 /// </summary> /// <param name="SelectField">Select欄位(*,表示全部)</param> /// <param name="Name">列舉-資料表名稱</param> /// <param name="Condition">條件清單</param> /// <returns>DataTable資料表</returns> public DataTable GetTable(string[] SelectField, DbName Name, List<DataField> Condition) { //呼叫GetSelectWhereQuery(傳入Select欄位、資料表、條件清單)(傳回Sql命令) //呼叫CreateParameters(傳入條件清單)(傳回Parameters陣列) //呼叫ExecuteReader(傳入Sql命令、Parameters陣列)(回傳DataTable資料表) //傳回DataTable資料表 return ExecuteReader(GetSelectWhereQuery(SelectField, Name, Condition), CreateParameters(Condition)); } /// /// <summary> /// Insert介面 - 執行Query - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="InsertList">Insert清單</param> /// <returns>受影響的行數</returns> public int Insert(DbName Name, List<DataField> InsertList) { //呼叫GetInsertQuery(傳入資料表、Insert清單)(傳回Sql命令) //呼叫CreateParameters(傳入Insert清單)(傳回Parameters陣列) //呼叫ExecuteNonQuery(傳入Sql命令、Parameters陣列)(傳回影響的行數) //傳回影響的行數 return ExecuteNonQuery(GetInsertQuery(Name, InsertList), CreateParameters(InsertList)); } /// /// <summary> /// Insert介面 - 執行Query - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="InsertList">Insert清單</param> /// <returns>資料表</returns> public DataTable InsertWithReturn(DbName Name, List<DataField> InsertList) { //呼叫GetUpdateQuery(傳入資料表、更新清單)(傳回Sql命令) //呼叫CreateParameters(傳入更新清單)(傳回Parameters陣列) //呼叫ExecuteNonQuery(傳入Sql命令、Parameters陣列)(傳回受影響的行數) //傳回受影響的行數 return ExecuteReader(SerReturn(Name, InsertList), CreateParameters(InsertList)); } /// /// <summary> /// Delete介面 - 執行Query - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="DeleteList">刪除清單</param> /// <returns>受影響的行數</returns> public int Delete(DbName Name, List<DataField> DeleteList) { //呼叫GetDeleteQuery(傳入資料表、刪除清單)(傳回Sql命令) //呼叫CreateParameters(傳入刪除清單)(傳回Parameters陣列) //呼叫ExecuteNonQuery(傳入Sql命令、Parameters陣列)(傳回受影響的行數) //傳回受影響的行數 return ExecuteNonQuery(GetDeleteQuery(Name, DeleteList), CreateParameters(DeleteList)); } /// /// <summary> /// Update介面 - 執行Query - design By Phoenix 2008 /// </summary> /// <param name="Name">列舉-資料表名稱</param> /// <param name="UpdateList">更新清單</param> /// <returns>受影響的行數</returns> public int Update(DbName Name, List<DataField> UpdateList) { //呼叫GetUpdateQuery(傳入資料表、更新清單)(傳回Sql命令) //呼叫CreateParameters(傳入更新清單)(傳回Parameters陣列) //呼叫ExecuteNonQuery(傳入Sql命令、Parameters陣列)(傳回受影響的行數) //傳回受影響的行數 return ExecuteNonQuery(GetUpdateQuery(Name, UpdateList), CreateParameters(UpdateList)); } #endregion #region IQuery 成員 - 明確實做介面 int IQuery.RunQuery(string SqlQuery) { return this.RunQuery(SqlQuery); } #region iSelect 成員 DataTable ISelect.GetTable(string SqlQuery) { return this.GetTable(SqlQuery); } DataTable ISelect.GetTable(string[] SelectField, DbName Name) { return this.GetTable(SelectField, Name); } DataTable ISelect.GetTable(string[] SelectField, DbName Name, List<DataField> Condition) { return this.GetTable(SelectField, Name, Condition); } #endregion #region iInsert 成員 int IInsert.Insert(DbName Name, List<DataField> InsertList) { return this.Insert(Name, InsertList); } DataTable IInsert.InsertWithReturn(DbName Name, List<DataField> InsertList) { return this.InsertWithReturn(Name, InsertList); } #endregion #region iDelete 成員 int IDelete.Delete(DbName Name, List<DataField> DeleteList) { return this.Delete(Name, DeleteList); } #endregion #region iUpdate 成員 int IUpdate.Update(DbName Name, List<DataField> UpdateList) { return this.Update(Name, UpdateList); } #endregion #endregion /// /// <summary> /// 初始化 DataAccessLayer.DataObject.MySqlServer 類別的新執行個體 - design By Phoenix 2008 /// </summary> public MySqlServer() { //初始化 ConnStr 物件 ConnStr = new ConnectionString(); } }

GenericBase

using System;
using System.Collections.Generic;
using System.Data;
using Library.Framework.DataAccessLayer;
using Library.Framework.DataAccessLayer.DataObject;

///  /// <summary> /// 基底類別，商業邏輯元件 - design By Phoenix 2008 - /// </summary> /// <typeparam name="T">資料物件模型</typeparam> public abstract class GenericBase<T> : IQuery<T> { #region 必要參數 DataName,DataKeyName /// <summary> /// 資料表名稱 /// </summary> protected DbName _DataBaseName; /// <summary> /// 資料表索引 /// </summary> protected string _DataKeyName; #endregion /// <summary> /// 資料存取元件 /// </summary> protected MySqlServer DataObject { get { return new MySqlServer(); } } #region 抽象方法，由子類別實作(CreateObject,CreateInsertList,CreateDeleteList,CreateUpdateList) ///  /// <summary> /// 建立資料物件 - design By Phoenix 2008 - /// </summary> /// <param name="row">DataRow(資料行)</param> /// <returns>資料物件</returns> protected abstract T CreateObject(DataRow row); ///  /// <summary> /// 建立Insert強型別物件清單 - design By Phoenix 2008 - /// </summary> /// <param name="objT">泛型物件</param> /// <returns>DataField強型別物件清單</returns> protected abstract List<DataField> CreateInsertList(T objT); ///  /// <summary> /// 建立Delete強型別物件清單 - design By Phoenix 2008 - /// </summary> /// <param name="objT">泛型物件</param> /// <returns>DataField強型別物件清單</returns> protected abstract List<DataField> CreateDeleteList(T objT); ///  /// <summary> /// 建立Update強型別物件清單 - design By Phoenix 2008 - /// </summary> /// <param name="objT">泛型物件</param> /// <returns>DataField強型別物件清單</returns> protected abstract List<DataField> CreateUpdateList(T objT); #endregion #region 預設方法(ToList,GetAll,GetBy) /// /// <summary> /// 由DataTable(資料表)轉換成List(強型別物件清單) - design By Phoenix 2008 - /// </summary> /// <param name="dt">要轉換的DataTable(資料表)</param> /// <returns>資料強型別物件清單</returns> protected List<T> ToList(DataTable dt) { //例外處理 try { //建立Board強型別物件清單 List<T> result = new List<T>(); result.Clear(); //將DataTable一一取出，呼叫CreateObject後加入清單。 foreach (DataRow row in dt.Rows) result.Add(CreateObject(row)); //回傳結果 return result; } catch (InvalidCastException) { throw; } catch { //擲回例外 throw new InvalidOperationException("ToList區段執行失敗"); } } /// /// <summary> /// 取得所有資料強型別物件清單 - design By Phoenix 2008 - /// </summary> /// <returns>資料強型別物件清單</returns> public virtual List<T> GetAll() { //例外處理 try { //field(Select欄位集合)，*為取得所有欄位 string[] field = new string[] { "*" }; //執行Select介面，傳入Select欄位集合、資料表名稱，傳回資料表 DataTable dt = DataObject.GetTable(field, _DataBaseName); //將資料表轉換成強型別物件清單再回傳 return ToList(dt); } catch (Exception) { //擲出例外 throw; } } /// /// <summary> /// 取得資料強型別物件清單 - design By Phoenix 2008 - /// </summary> /// <param name="Condition">條件限制清單</param> /// <returns>資料強型別物件清單</returns> public virtual List<T> GetBy(List<DataField> Condition) { //例外處理 try { //field(Select欄位集合)，*為取得所有欄位 string[] field = new string[] { "*" }; //執行Select介面，傳入Select欄位集合、資料表名稱、條件限制清單，傳回資料表 DataTable dt = DataObject.GetTable(field, _DataBaseName, Condition); //將資料表轉換成強型別物件清單再回傳 return ToList(dt); } catch (Exception) { //擲出例外 throw; } } ///  /// <summary> /// 取得資料強型別物件清單(By索引鍵值) - design By Phoenix 2008 - /// </summary> /// <param name="Id">索引鍵值</param> /// <returns>資料強型別物件清單</returns> public virtual List<T> GetBy(int Id) { return GetBy(CreateCondition(Id)); } ///  /// <summary> /// 建立條件限制清單 - design By Phoenix 2008 - /// </summary> /// <param name="id">索引鍵值</param> /// <returns>條件限制清單</returns> protected virtual List<DataField> CreateCondition(int id) { return new List<DataField>() { new DataField(_DataKeyName, id) }; } #endregion #region 實作介面(虛擬) /// /// <summary> /// 新增一筆資料行 - design By Phoenix 2008 - /// </summary> /// <param name="objT">資料物件</param> /// <returns>受影響的行數</returns> public virtual int Insert(T objT) { //執行CreateInsertList(傳入資料清單)(傳回Insert清單) //執行Insert介面(傳入資料表名稱、Insert清單)(傳回影響的行數) //傳回受影響的行數 return DataObject.Insert(_DataBaseName, CreateInsertList(objT)); } /// /// <summary> /// 新增一筆資料行 - design By Phoenix 2008 - /// </summary> /// <param name="objT">資料物件</param> /// <returns>自動編號</returns> public virtual int InsertWithReturn(T objT) { //執行CreateInsertList(傳入資料清單)(傳回Insert清單) //執行Insert介面(傳入資料表名稱、Insert清單)(傳回自動編號) //傳回自動編號 DataTable dt = DataObject.InsertWithReturn(_DataBaseName, CreateInsertList(objT)); return int.Parse(dt.Rows[0][0].ToString()); } /// /// <summary> /// 執行刪除的動作，刪除Del標記為true的項目 - design By Phoenix 2008 - /// </summary> /// <returns>受影響的行數</returns> public virtual int Delete() { //自訂SqlQuery查詢指令 string SqlQuery = string.Format("DELETE FROM {0} WHERE (Del = 1)", _DataBaseName.ToString()); //執行Query，傳回受影響的行數 return DataObject.RunQuery(SqlQuery); } /// /// <summary> /// 設定資料刪除標記 - design By Phoenix 2008 - /// </summary> /// <param name="objT">資料物件</param> /// <returns>this</returns> public virtual GenericBase<T> Delete(T objT) { //呼叫CreateDeleteList(傳入Activity物件)(傳回Delete清單) //執行Update介面(傳入資料表名稱、Delete清單)(傳回受影響的行數) //傳回受影響的行數 DataObject.Update(_DataBaseName, CreateDeleteList(objT)); return this; } /// /// <summary> /// 修改資料行 - design By Phoenix 2008 - /// </summary> /// <param name="objT">資料物件</param> /// <returns>受影響的行數</returns> public virtual int Update(T objT) { //若不為null //呼叫CreateUpdateList(傳入資料物件)(傳回Update清單) //執行Update介面(傳入資料表名稱、Update清單)(傳回影響的行數) //傳回受影響的行數 return DataObject.Update(_DataBaseName, CreateUpdateList(objT)); } #endregion #region 明確實做介面 int IInsert<T>.Insert(T objT) { return this.Insert(objT); } int IInsert<T>.InsertWithReturn(T objT) { return this.InsertWithReturn(objT); } int IDelete<T>.Delete() { return this.Delete(); } GenericBase<T> IDelete<T>.Delete(T objT) { return this.Delete(objT); } int IUpdate<T>.Update(T objT) { return this.Update(objT); } #endregion ///  /// <summary> /// 初始化 BusinessLogicLayer.GenericBase 類別的新執行個體 - design By Phoenix 2008 - /// </summary> /// <param name="DataBase">列舉-資料表名稱</param> /// <param name="DataKey">資料索引鍵值</param> public GenericBase(DbName DataBase, string DataKey) { _DataBaseName = DataBase; _DataKeyName = DataKey; } }

以上

Phoenix 2008/09/21

回首頁