using System; using System.Collections.Generic; using System.Text; using SW.Henu.DAO; using System.Data; namespace LogisManageLibrary { /// <summary> /// 所有操作表類的抽象基類 /// </summary> public abstract class AManage { /// <summary> /// 對應表的字段名稱列表 /// </summary> public List<string> attributeList { set; get; } /// <summary> /// 對應表的字段名稱列表 /// </summary> public List<string> valueList { set; get; } /// <summary> /// 對應的表名 /// </summary> public string tableName { set; get; } // 聲明委托 public delegate StringBuilder SetSQLBySelf(); /// <summary> /// 初始化字段列表 /// </summary> public AManage() { attributeList = new List<string>(); valueList = new List<string>(); } /// <summary> /// 初始化表和字段的信息,綁定數據表的定義結構 /// </summary> /// <example>tableName="Table";attributeList.Add("Field");</example> public abstract void Initialize(); /// <summary> /// 求解查詢語句 /// </summary> /// <returns>返回查詢表</returns> /// <example>string ps_Sql = "select Guid,SimpName as 客戶簡稱,[Name] as 客戶名稱,LinkMan as 聯系人,Telephone as 電話,Fax as 傳真,Address as 地址,Zip as 郵編,SellType as 銷售類別,ProductName as 產品名稱,Remark as 備注,Case when IsEnable=1 then '停用' when IsEnable=0 then '可用' end as 是否可用 from Client ";</example> public abstract StringBuilder SetSelectSQL(); /// <summary> /// 求解插入的SQL語句 /// </summary> /// <returns></returns> /// <example>strSql.Append("insert into [Client](");</example> public abstract StringBuilder SetInsertSQL(); /// <summary> /// 求解更新的SQL語句 /// </summary> /// <returns></returns> /// <example>strSql.Append("update Client set ");</example> public abstract StringBuilder SetUpdateSQL(); /// <summary> /// 求解刪除的SQL語句 /// </summary> /// <returns></returns> /// <example>string ps_Sql = "delete from Client where Guid='" + ClientGuid + "'";</example> public abstract StringBuilder SetDeleteSQL(); /// <summary> /// 通過pSql得到當前是新增狀態還是修改狀態 /// </summary> /// <param name="pObj">信息集實例</param> /// <param name="pSql">string pSql = "";pSql = "SELECT Guid FROM Client " +"where Guid ='" + pObj.Guid + "'";</param> /// <returns>返回True或False</returns> private bool SaveStatus(string pSql) { CommonInterface pComm = CommonFactory.CreateInstance(CommonData.sql); try { DataTable pDT = pComm.ExeForDtl(pSql); pComm.Close(); if (pDT.Rows.Count > 0) { return true; } else { return false; } } catch (Exception e) { pComm.Close(); throw e; } } /// <summary> /// 保存數據 /// </summary> /// <param name="pObj">信息集實體類</param> /// <param name="pSql">string pSql = "";pSql = "SELECT Guid FROM Client " +"where Guid ='" + pObj.Guid + "'";</param> /// <returns>返回保存成功(true)或失敗(false)</returns> public bool Save(string pSql) { try { if (SaveStatus(pSql) == false) { return Insert(); } else { return Update(); } } catch (Exception e) { throw e; } } /// <summary> /// 得到數據 /// </summary> /// <returns></returns> public DataTable Select() { CommonInterface pObj_Comm = CommonFactory.CreateInstance(CommonData.sql); try { DataTable pDTMain = pObj_Comm.ExeForDtl(SetSelectSQL().ToString()); pObj_Comm.Close(); return pDTMain; } catch (Exception e) { pObj_Comm.Close(); throw e; } } /// <summary> /// 增加一條數據 /// </summary> public bool Insert() { CommonInterface pComm = CommonFactory.CreateInstance(CommonData.sql); try { pComm.Execute(SetInsertSQL().ToString());//執行Sql語句無返回值 pComm.Close(); return true; } catch (System.Exception e) { pComm.Close(); throw e; } } /// <summary> /// 更新一條數據 /// </summary> public bool Update() { CommonInterface pComm = CommonFactory.CreateInstance(CommonData.sql); try { pComm.Execute(SetUpdateSQL().ToString());//執行Sql語句無返回值 pComm.Close(); return true; } catch (System.Exception e) { pComm.Close(); throw e; } } /// <summary> /// 刪除 /// </summary> /// <returns></returns> public void Delete() { CommonInterface pObj_Comm = CommonFactory.CreateInstance(CommonData.sql); try { pObj_Comm.Execute(SetDeleteSQL().ToString()); pObj_Comm.Close(); } catch (Exception e) { pObj_Comm.Close(); throw e; } } /// <summary> /// 由參數的SQL語句增刪改數據庫 /// </summary> public void NotSelect(string pSql) { CommonInterface pObj_Comm = CommonFactory.CreateInstance(CommonData.sql); try { pObj_Comm.Execute(pSql); pObj_Comm.Close(); } catch (Exception e) { pObj_Comm.Close(); throw e; } } /// <summary> /// 得到數據 /// </summary> /// <returns></returns> public DataTable Select(string pSql) { CommonInterface pObj_Comm = CommonFactory.CreateInstance(CommonData.sql); try { DataTable pDTMain = pObj_Comm.ExeForDtl(pSql); pObj_Comm.Close(); return pDTMain; } catch (Exception e) { pObj_Comm.Close(); throw e; } } /// <summary> /// 通過委托得到數據 /// </summary> /// <returns></returns> public DataTable SelectBySelf(SetSQLBySelf sql) { CommonInterface pObj_Comm = CommonFactory.CreateInstance(CommonData.sql); try { DataTable pDTMain = pObj_Comm.ExeForDtl(sql().ToString()); pObj_Comm.Close(); return pDTMain; } catch (Exception e) { pObj_Comm.Close(); throw e; } } /// <summary> /// 由委托增刪改數據庫 /// </summary> public void NotSelect(SetSQLBySelf sql) { CommonInterface pObj_Comm = CommonFactory.CreateInstance(CommonData.sql); try { pObj_Comm.Execute(sql().ToString()); pObj_Comm.Close(); } catch (Exception e) { pObj_Comm.Close(); throw e; } } } }
這寫代碼定義了所有的增刪改查功能,只需要重寫方法,或者委托,或者直接調用寫入SQL語句即可。
該代碼寫了三種查詢方式。重寫,委托和直接調用。具體怎么用我還沒有事件,但是經過老師的測試,很好用。
和大家分享下。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
