网站制作和优化,html个人网站设计,深圳做企业网站多少钱,阿里云万网域名购买大家可能会经常遇到接口需要经常增加新的方法和实现#xff0c;可是我们原则上是不建议平凡的增加修改删除接口方法#xff0c;熟不知这样使用接口是不是正确的接口用法#xff0c;比如我见到很多的项目分层都是IDAL#xff0c;DAL#xff0c;IBLL#xff0c;BLL#xf… 大家可能会经常遇到接口需要经常增加新的方法和实现可是我们原则上是不建议平凡的增加修改删除接口方法熟不知这样使用接口是不是正确的接口用法比如我见到很多的项目分层都是IDALDALIBLLBLL使用了2层接口名义上是数据隔离和业务隔离但是会使代码难调试难维护有可能代码写的不好或者需求变更造成IBLL,BLL,IDAL,DAL的全部修改这真的是代码架构之疡。 基于上述观点我i重构DAL来废除IDALIBLL造成的架构臃肿 使用模板模式创建Get和GetList方法使他具有分页和多表查询事务查询的能力 使用命令模式创建AddWhere方法使他具有Where族的能力能处理复杂SQL查询的能力 通过此模式程序员可以在BLL中自由组合Where,Order,Gounp by不需要写一个方法再也不会在DAL中出现GetByNameGetListByType这样的方法。 如需迁移redis和mongodb建议重新搞一套redis的Base 代码大致如下 AbsSelectBase.cs public class AbsSelectBaseT where T : BaseModel{private ListabsWhere lWhere { get; set; }public PageModel page { get; set; }protected string Table { get; set; }public RBase1(){page new PageModel();lWhere new ListabsWhere();Init();}protected virtual void Init(){}public virtual ListT GetList(MySqlTransaction tran null){string where;var lpar GetWhere(out where);var list new ListT();if (page.Order_field.IsNull()){page.Order_field Id desc;}if (page.Current_Page.HasValue){list GetPageList(, page.Order_field, Table, page, where, , lpar, tran);}else{list Query(select * from Table where where, page.Order_field, lpar, tran);}return list;}public void AddWhere(absWhere where){lWhere.Add(where);}public T Get(MySqlTransaction tran null){page.Current_Page 1;page.Page_Size 1;var entity GetList(tran).FirstOrDefault();return entity;}public virtual DynamicParameters GetWhere(out string where){DynamicParameters lpar new DynamicParameters();where IsValid1 ;foreach (var ewhere in lWhere){where ewhere.CreateWhere(lpar);}lWhere.clear();lWherenull;return lpar;}public object GetCount(MySqlTransaction tran null){string where ;var lpar GetWhere(out where);var res SqlConnections.Sqlconnection.Queryint(select count(1) from Table where where, lpar, tran);return res;}protected virtual ListT GetPageList(string Field, string Order, string Table, PageModel model, string Where, string bigOrderBy null, object param null,MySqlTransaction sqlTransation null){var res SqlConnections.Sqlconnection.GetPageListT(Field, Order, Table, model, Where, bigOrderBy, param, sqlTransation).ToList();return res;}} ConcreteSelectA.cs public class RScoreRecordSelect : RBase1ScoreRecord{public RScoreRecordSelect(){ }} ConcreteSelectB.cs多表 /// summary/// ProductBuy inner join User/// /summarypublic class RProBuyUserSelect : RBase1ProductBuy{public override ListProductBuy GetList(MySql.Data.MySqlClient.MySqlTransaction tran null){string where;var lpar GetWhere(out where);var list new ListProductBuy();string table User inner join ProductBuy on User.IDProductBuy.UserID ;if (page.Order_field.IsNull()){page.Order_field ProductBuy.Id desc;}if (page.Current_Page.HasValue){list GetPageList(, page.Order_field, table, page, where, , lpar, tran);}else{list Query(select ProductBuy.* from table where where, page.Order_field, lpar, tran);}return list;}public override CZCore.Data.DynamicParameters GetWhere(out string where){DynamicParameters lpar new DynamicParameters();where User.IsValid1 and ProductBuy.IsValid1 ;foreach (var ewhere in lWhere){where ewhere.CreateWhere(lpar);}return lpar;}public enum EnumOrder{/// summary/// /// /summary[Category(UserAct.BuyCount)][Description()]_0,/// summary/// /// /summary[Category(UserAct.BuyMoney)][Description()]_1,/// summary/// /// /summary[Category(UserAct.CashScore)][Description()]_2,/// summary/// /// /summary[Category(DBB.Money)][Description()]_3,/// summary/// /// /summary[Category(DBB.Score)][Description()]_4}} absWhere.cs public abstract class absWhere{private string _field;public string field{get{return _field;}set{_field value;}}public object value { get; set; }private string _par;public string par{get{if (_par.IsNull()){_par field.Replace(.,);}return _par;}set{_par value;}}public abstract string CreateWhere(DynamicParameters lpar);} WhereAndIn.cs public class WhereAndIn : absWhere{public override string CreateWhere(CZCore.Data.DynamicParameters lpar){string sql;if (value.IsNull() false){sql and field in par ;lpar.Add(par, value);}return sql;}} WhereAndLike.cs public class WhereAndLike : absWhere{public override string CreateWhere(CZCore.Data.DynamicParameters lpar){string sql;if (value.IsNull() false){sql and field like par ;lpar.Add(par, %value%);}return sql;}} 单表查询 多表查询 简单的处理增删改查主键等于Entity属性的简单查询不分页功能并在上层提供一个总的facade门面 AbsBase.cs public class RBaseT where T : BaseModel{public ListT GetAll(MySqlTransaction tran null){var list SqlConnections.Sqlconnection.GetAllT(tran);return list;}public T GetById(object id, MySqlTransaction tran null){var res SqlConnections.Sqlconnection.GetByIdT(id, tran);return res;}public UInt64 Insert(T T, MySqlTransaction tran null, MySqlConnection _conn null, bool IsAuto true){var res SqlConnections.Sqlconnection.InsertT(T, tran, IsAuto);return res;}public void Insert(ListT list, MySqlTransaction tran null, MySqlConnection _conn null){SqlConnections.Sqlconnection.InsertT(list, tran);}public void Update(T T, MySqlTransaction tran null, MySqlConnection _conn null){SqlConnections.Sqlconnection.UpdateT(T, tran);}public void Update(ListT list, MySqlTransaction tran null, MySqlConnection _conn null){SqlConnections.Sqlconnection.UpdateT(list, tran);}public ListT Search(T t, MySqlTransaction tran null, MySqlConnection _conn null){var res SqlConnections.Sqlconnection.SearchT(t, tran);return res;}public bool Delete(object id, bool isDelete false, MySqlTransaction tran null, MySqlConnection _conn null){var res SqlConnections.Sqlconnection.DeleteT(id, tran, isDelete: isDelete);return res;}public void DeleteBySearch(T t, bool isDelete false, MySqlTransaction tran null, MySqlConnection _conn null){SqlConnections.Sqlconnection.DeleteBySearchT(t, tran, isDelete: isDelete);}public RBase(){Init();}public virtual void Init(){}public void TruncateTable(MySqlTransaction sqlTransation null){bool result Execute(string.Format(Truncate Table {0}, typeof(T).Name.ToLower() ), null, sqlTransation) 0;}} Concrete1.cs public class RScoreRecord:RBaseScoreRecord{} Facade.cs Model层封装Entity层,并懒加载Entity数据只加载关联id一级数据 MUser.cs public class MUser{private User eUser;public MUser(User _eUser){eUser_eUser;}private UserAct eUserAct;public UserAct GetEUserAct(MySql.Data.MySqlClient.MySqlTransaction ts null){if (eUserAct null){eUserAct RCommon.rUserAct.GetById(eUser.Id,ts);}return eUserAct;}private DBB eDBB;public DBB GetDBB(MySql.Data.MySqlClient.MySqlTransaction tsnull){if (eDBB null){eDBB RCommon.rdbb.GetById(eUser.Id,ts);}return eDBB;}} 转载于:https://www.cnblogs.com/alisande/p/5587063.html
