zoukankan html css js c++ java

csla框架__使用Factory方式实现Csla.BusinessBase对象数据处理

环境：.net4.6+csla4.6

实现：对象的数据库访问及数据库执行使用Factory方式进行封闭。

正文：

以前在使用csla框架完成业务对象的定义时所有的数据处理都在对象内部实现，也不能说不好，对象很大。作者给了通过Factory的方式将对象的数据访问层进行分离，代码更容易维护。以下是我通过Factory的方式实现对象数据访问。

首先是通过csla的约定定义业务对象，其中包含了属性验证：

  1     [Serializable]
  2     [Csla.Server.ObjectFactory("HFunM.Business.Service.CustomDevelop.AssetManage.CategoriesService, HFunM.Business.Service", "CreateCategory", "FetchCategory", "UpdateCategory", "DeleteCategory")]
  3     public class Asset_CategoryER : Csla.BusinessBase<Asset_CategoryER>
  4     {
  5         #region Contructor
  6 
  7         public Asset_CategoryER()
  8         { /* Require use of factory methods */ }
  9 
 10         #endregion
 11 
 12         #region Properties
 13 
 14         public static readonly PropertyInfo<System.String> _actIdProperty
 15             = RegisterProperty<System.String>(p => p.ActId, "主键ID");
 16         /// <summary>
 17         /// 主键ID
 18         /// </summary>
 19         [System.ComponentModel.DataObjectField(true, false)]
 20         public System.String ActId
 21         {
 22             get { return GetProperty(_actIdProperty); }
 23             set { SetProperty(_actIdProperty, value); }
 24         }
 25 
 26         public static readonly PropertyInfo<System.String> _aCTParentIDProperty
 27             = RegisterProperty<System.String>(p => p.ACTParentID, "上级分类ID", (System.String)null);
 28         /// <summary>
 29         /// 上级分类ID
 30         /// </summary>
 31         public System.String ACTParentID
 32         {
 33             get { return GetProperty(_aCTParentIDProperty); }
 34             set { SetProperty(_aCTParentIDProperty, value); }
 35         }
 36 
 37         public static readonly PropertyInfo<System.String> _aCTSysCodeProperty
 38             = RegisterProperty<System.String>(p => p.ACTSysCode, "系统分类编号", (System.String)null);
 39         /// <summary>
 40         /// 系统分类编号
 41         /// </summary>
 42         public System.String ACTSysCode
 43         {
 44             get { return GetProperty(_aCTSysCodeProperty); }
 45             set { SetProperty(_aCTSysCodeProperty, value); }
 46         }
 47 
 48         public static readonly PropertyInfo<System.String> _aCTNameProperty
 49             = RegisterProperty<System.String>(p => p.ACTName, "分类名称", (System.String)null);
 50         /// <summary>
 51         /// 分类名称
 52         /// </summary>
 53         public System.String ACTName
 54         {
 55             get { return GetProperty(_aCTNameProperty); }
 56             set { SetProperty(_aCTNameProperty, value); }
 57         }
 58 
 59         public static readonly PropertyInfo<System.String> _aCTShortNameProperty
 60             = RegisterProperty<System.String>(p => p.ACTShortName, "名称缩写", (System.String)null);
 61         /// <summary>
 62         /// 名称缩写
 63         /// </summary>
 64         public System.String ACTShortName
 65         {
 66             get { return GetProperty(_aCTShortNameProperty); }
 67             set { SetProperty(_aCTShortNameProperty, value); }
 68         }
 69 
 70         public static readonly PropertyInfo<System.String> _aCTStateProperty
 71             = RegisterProperty<System.String>(p => p.ACTState, "分类状态", (System.String)null);
 72         /// <summary>
 73         /// 分类状态
 74         /// </summary>
 75         public System.String ACTState
 76         {
 77             get { return GetProperty(_aCTStateProperty); }
 78             set { SetProperty(_aCTStateProperty, value); }
 79         }
 80 
 81         public static readonly PropertyInfo<System.Int32?> _aCTServiceLifeProperty
 82             = RegisterProperty<System.Int32?>(p => p.ACTServiceLife, "使用年限", (System.Int32?)null);
 83         /// <summary>
 84         /// 使用年限
 85         /// </summary>
 86         public System.Int32? ACTServiceLife
 87         {
 88             get { return GetProperty(_aCTServiceLifeProperty); }
 89             set { SetProperty(_aCTServiceLifeProperty, value); }
 90         }
 91 
 92         public static readonly PropertyInfo<System.Double?> _aCTSalvageRateProperty
 93             = RegisterProperty<System.Double?>(p => p.ACTSalvageRate, "残值率(%)", (System.Double?)null);
 94         /// <summary>
 95         /// 残值率(%)
 96         /// </summary>
 97         public System.Double? ACTSalvageRate
 98         {
 99             get { return GetProperty(_aCTSalvageRateProperty); }
100             set { SetProperty(_aCTSalvageRateProperty, value); }
101         }
102 
103         public static readonly PropertyInfo<System.String> _aCTUnitProperty
104             = RegisterProperty<System.String>(p => p.ACTUnit, "计算单位", (System.String)null);
105         /// <summary>
106         /// 计算单位
107         /// </summary>
108         public System.String ACTUnit
109         {
110             get { return GetProperty(_aCTUnitProperty); }
111             set { SetProperty(_aCTUnitProperty, value); }
112         }
113 
114         public static readonly PropertyInfo<System.String> _aCTRemarkProperty
115             = RegisterProperty<System.String>(p => p.ACTRemark, "备注", (System.String)null);
116         /// <summary>
117         /// 备注
118         /// </summary>
119         public System.String ACTRemark
120         {
121             get { return GetProperty(_aCTRemarkProperty); }
122             set { SetProperty(_aCTRemarkProperty, value); }
123         }
124 
125         public static readonly PropertyInfo<System.String> _aCTVoucherProperty
126             = RegisterProperty<System.String>(p => p.ACTVoucher, "会计凭证号", (System.String)null);
127         /// <summary>
128         /// 会计凭证号
129         /// </summary>
130         public System.String ACTVoucher
131         {
132             get { return GetProperty(_aCTVoucherProperty); }
133             set { SetProperty(_aCTVoucherProperty, value); }
134         }
135 
136         #endregion
137 
138         #region Business Rules
139 
140         /// <summary>
141         /// Contains the CodeSmith generated validation rules.
142         /// </summary>
143         protected override void AddBusinessRules()
144         {
145             // Call the base class, if this call isn't made than any declared System.ComponentModel.DataAnnotations rules will not work.
146             base.AddBusinessRules();
147 
148             BusinessRules.AddRule(new Csla.Rules.CommonRules.Required(_actIdProperty));
149             BusinessRules.AddRule(new Csla.Rules.CommonRules.Required(_aCTNameProperty));
150             BusinessRules.AddRule(new Csla.Rules.CommonRules.Required(_aCTParentIDProperty));
151             BusinessRules.AddRule(new Csla.Rules.CommonRules.Required(_aCTSysCodeProperty));
152             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_actIdProperty, 36));
153             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTParentIDProperty, 36));
154             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTSysCodeProperty, 50));
155             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTNameProperty, 50));
156             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTShortNameProperty, 50));
157             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTStateProperty, 20));
158             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTUnitProperty, 20));
159             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTRemarkProperty, 200));
160             BusinessRules.AddRule(new Csla.Rules.CommonRules.MaxLength(_aCTVoucherProperty, 50));
161         }
162 
163         #endregion
164 
165         #region Factory
166 
167         public static Asset_CategoryER NewCategory(string parentID)
168         {
169             return DataPortal.Create<Asset_CategoryER>(parentID);
170         }
171 
172         public static Asset_CategoryER GetCategory(string id)
173         {
174             return DataPortal.Fetch<Asset_CategoryER>(id);
175         }
176 
177         public static void DeleteCategory(string id)
178         {
179             DataPortal.Delete<Asset_CategoryER>(id);
180         }
181 
182         #endregion
183     }

View Code

可能已经发现了属性Csla.Server.ObjectFactoryAttribute，它就是定义Factory的，其中提供了多种构造方式，如下：

 1 namespace Csla.Server
 2 {
 3     [AttributeUsage(AttributeTargets.Class | AttributeTargets.Interface, AllowMultiple = false)]
 4     public class ObjectFactoryAttribute : Attribute
 5     {
 6         public ObjectFactoryAttribute(string factoryType);
 7         public ObjectFactoryAttribute(Type factoryType);
 8         public ObjectFactoryAttribute(string factoryType, string fetchMethod);
 9         public ObjectFactoryAttribute(Type factoryType, string fetchMethod);
10         public ObjectFactoryAttribute(string factoryType, string createMethod, string fetchMethod);
11         public ObjectFactoryAttribute(Type factoryType, string createMethod, string fetchMethod);
12         public ObjectFactoryAttribute(string factoryType, string createMethod, string fetchMethod, string updateMethod, string deleteMethod);
13         public ObjectFactoryAttribute(Type factoryType, string createMethod, string fetchMethod, string updateMethod, string deleteMethod);
14         public ObjectFactoryAttribute(string factoryType, string createMethod, string fetchMethod, string updateMethod, string deleteMethod, string executeMethod);
15         public ObjectFactoryAttribute(Type factoryType, string createMethod, string fetchMethod, string updateMethod, string deleteMethod, string executeMethod);
16 
17         public string FactoryTypeName { get; }
18         public string CreateMethodName { get; }
19         public string FetchMethodName { get; }
20         public string UpdateMethodName { get; }
21         public string DeleteMethodName { get; }
22         public string ExecuteMethodName { get; }
23     }
24 }

View Code

以下是Factory的数据访问实现：

  1     public class CategoriesService : Data.Repository.RepositoryFactory<Entity.CustomDevelop.AssetEntity.Asset_CategoryEntity>
  2     {
  3         #region 列表
  4 
  5         /// <summary>
  6         /// 加载所有数据
  7         /// </summary>
  8         /// <returns></returns>
  9         public Asset_CategoryList FetchList()
 10         {
 11             var obj = (Asset_CategoryList)MethodCaller.CreateInstance(typeof(Asset_CategoryList));
 12             var rlce = obj.RaiseListChangedEvents;
 13             obj.RaiseListChangedEvents = false;
 14             base.SetIsReadOnly(obj, false);
 15 
 16             var child = base.BaseRepository().IQueryable(p => p.ACT_State == "1");
 17             foreach (var item in child)
 18             {
 19                 obj.Add(CreateItem(item));
 20             }
 21 
 22             base.SetIsReadOnly(obj, true);
 23             obj.RaiseListChangedEvents = rlce;
 24             return obj;
 25         }
 26 
 27         /// <summary>
 28         /// 创建列表子对象
 29         /// </summary>
 30         /// <returns></returns>
 31         public Asset_CategoryInfo CreateItem()
 32         {
 33             var obj = (Asset_CategoryInfo)MethodCaller.CreateInstance(typeof(Asset_CategoryInfo));
 34             LoadProperty(obj, Asset_CategoryInfo._actIdProperty, Util.CommonHelper.GetGuid);
 35             MarkNew(obj);
 36             CheckRules(obj);
 37             return obj;
 38         }
 39 
 40         /// <summary>
 41         /// 
 42         /// </summary>
 43         /// <param name="et"></param>
 44         /// <returns></returns>
 45         public Asset_CategoryInfo CreateItem(Entity.CustomDevelop.AssetEntity.Asset_CategoryEntity et)
 46         {
 47             var obj = (Asset_CategoryInfo)MethodCaller.CreateInstance(typeof(Asset_CategoryInfo));
 48             MarkAsChild(obj);
 49 
 50             LoadProperty(obj, Asset_CategoryInfo._actIdProperty, et.ACT_ID);
 51             LoadProperty(obj, Asset_CategoryInfo._aCTNameProperty, et.ACT_Name);
 52             LoadProperty(obj, Asset_CategoryInfo._aCTParentIDProperty, et.ACT_ParentID);
 53             LoadProperty(obj, Asset_CategoryInfo._aCTRemarkProperty, et.ACT_Remark);
 54             LoadProperty(obj, Asset_CategoryInfo._aCTSalvageRateProperty, et.ACT_SalvageRate);
 55             LoadProperty(obj, Asset_CategoryInfo._aCTServiceLifeProperty, et.ACT_ServiceLife);
 56             LoadProperty(obj, Asset_CategoryInfo._aCTShortNameProperty, et.ACT_ShortName);
 57             LoadProperty(obj, Asset_CategoryInfo._aCTStateProperty, et.ACT_State);
 58             LoadProperty(obj, Asset_CategoryInfo._aCTSysCodeProperty, et.ACT_SysCode);
 59             LoadProperty(obj, Asset_CategoryInfo._aCTUnitProperty, et.ACT_Unit);
 60             LoadProperty(obj, Asset_CategoryInfo._aCTVoucherProperty, et.ACT_Voucher);
 61 
 62             MarkOld(obj);
 63             return obj;
 64         }
 65 
 66         #endregion
 67 
 68         #region 主对象
 69 
 70         /// <summary>
 71         /// 创建类别
 72         /// </summary>
 73         /// <returns></returns>
 74         public Asset_CategoryER CreateCategory(string parentID)
 75         {
 76             var obj = (Asset_CategoryER)MethodCaller.CreateInstance(typeof(Asset_CategoryER));
 77             LoadProperty(obj, Asset_CategoryER._actIdProperty, Util.CommonHelper.GetGuid);
 78             LoadProperty(obj, Asset_CategoryER._aCTParentIDProperty, parentID);
 79             MarkNew(obj);
 80             CheckRules(obj);
 81             return obj;
 82         }
 83 
 84         /// <summary>
 85         /// 加载类别
 86         /// </summary>
 87         /// <param name="id">类别ID</param>
 88         /// <returns></returns>
 89         public Asset_CategoryER FetchCategory(string id)
 90         {
 91             var et = base.BaseRepository().FindEntity(id);
 92             if (et != null)
 93             {
 94                 var obj = (Asset_CategoryER)MethodCaller.CreateInstance(typeof(Asset_CategoryER));
 95                 LoadProperty(obj, Asset_CategoryER._actIdProperty, et.ACT_ID);
 96                 LoadProperty(obj, Asset_CategoryER._aCTNameProperty, et.ACT_Name);
 97                 LoadProperty(obj, Asset_CategoryER._aCTParentIDProperty, et.ACT_ParentID);
 98                 LoadProperty(obj, Asset_CategoryER._aCTRemarkProperty, et.ACT_Remark);
 99                 LoadProperty(obj, Asset_CategoryER._aCTSalvageRateProperty, et.ACT_SalvageRate);
100                 LoadProperty(obj, Asset_CategoryER._aCTServiceLifeProperty, et.ACT_ServiceLife);
101                 LoadProperty(obj, Asset_CategoryER._aCTShortNameProperty, et.ACT_ShortName);
102                 LoadProperty(obj, Asset_CategoryER._aCTStateProperty, et.ACT_State);
103                 LoadProperty(obj, Asset_CategoryER._aCTSysCodeProperty, et.ACT_SysCode);
104                 LoadProperty(obj, Asset_CategoryER._aCTUnitProperty, et.ACT_Unit);
105                 LoadProperty(obj, Asset_CategoryER._aCTVoucherProperty, et.ACT_Voucher);
106 
107                 MarkOld(obj);
108                 CheckRules(obj);
109                 return obj;
110             }
111             else
112             {
113                 return null;
114             }
115         }
116 
117         /// <summary>
118         /// 更新类别
119         /// </summary>
120         /// <param name="obj">更新对象</param>
121         /// <returns></returns>
122         public Asset_CategoryER UpdateCategory(Asset_CategoryER obj)
123         {
124             if (obj.IsDeleted)
125             {
126                 if (!obj.IsNew)
127                 {
128                     //旧对象，删除
129                     DeleteCategory(obj.ActId);
130                 }
131                 //创建新的
132                 MarkNew(obj);
133             }
134             else
135             {
136                 CheckRules(obj);
137                 if (!obj.IsSavable)
138                 {
139                     throw new Csla.Rules.ValidationException(obj.BrokenRulesCollection.ToString());
140                 }
141                 if (obj.IsNew)
142                 {
143                     //创建
144                     Entity.CustomDevelop.AssetEntity.Asset_CategoryEntity entity = new Entity.CustomDevelop.AssetEntity.Asset_CategoryEntity();
145                     entity.ACT_ID = obj.ActId;
146                     entity.ACT_Name = obj.ACTName;
147                     entity.ACT_ParentID = obj.ACTParentID;
148                     entity.ACT_Remark = obj.ACTRemark;
149                     entity.ACT_SalvageRate = obj.ACTSalvageRate;
150                     entity.ACT_ServiceLife = obj.ACTServiceLife;
151                     entity.ACT_ShortName = obj.ACTShortName;
152                     entity.ACT_State = obj.ACTState;
153                     entity.ACT_SysCode = obj.ACTSysCode;
154                     entity.ACT_Unit = obj.ACTUnit;
155                     entity.ACT_Voucher = obj.ACTVoucher;
156 
157                     base.BaseRepository().Insert(entity);
158                 }
159                 else
160                 {
161                     //更新
162                     var entity = base.BaseRepository().FindEntity(obj.ActId);
163                     entity.ACT_Name = obj.ACTName;
164                     entity.ACT_ParentID = obj.ACTParentID;
165                     entity.ACT_Remark = obj.ACTRemark;
166                     entity.ACT_SalvageRate = obj.ACTSalvageRate;
167                     entity.ACT_ServiceLife = obj.ACTServiceLife;
168                     entity.ACT_ShortName = obj.ACTShortName;
169                     entity.ACT_State = obj.ACTState;
170                     entity.ACT_SysCode = obj.ACTSysCode;
171                     entity.ACT_Unit = obj.ACTUnit;
172                     entity.ACT_Voucher = obj.ACTVoucher;
173 
174                     base.BaseRepository().Update(entity);
175                 }
176                 MarkOld(obj);
177             }
178             return obj;
179         }
180 
181         public void DeleteCategory(string id)
182         {
183             base.BaseRepository().Delete(id);
184         }
185 
186         #endregion
187     }

View Code

数据的访问是通过EF实现，通过定义数据访问基类，承载了EF的访问接口以及csla框架提供的ObjectFactory：

1 public class RepositoryFactory<T> : Csla.Server.ObjectFactory
2         where T : class, new()

以上即实现的Csla业务对象及其数据访问对象，其他类型的如列表对象等都可以通过该方式实现。

欢迎转载，请留标记《HFun.net快速开发平台》

查看全文

相关阅读:
对MVC模型的自悟，详尽解释，为了更多非计算机人员可以理解
 openSUSE leap 42.3 实现有线无线同时用
 Fedora27 源配置
 Ubuntu16.04添加HP Laserjet Pro M128fn打印机和驱动
 openSUSE leap 42.3 添加HP Laserjet Pro M128fn打印机和驱动
 OpenSUSE Leap 42.3下通过Firefox Opera Chromium浏览器直接执行java应用程序（打开java jnlp文件）实现在服务器远程虚拟控制台完成远程管理的方法
 OpenSUSE Leap 42.3 安装java（Oracle jre）
linux下支持托盘的邮件客户端Sylpheed
Ubuntu下通过Firefox Opera Chromium浏览器直接执行java应用程序（打开java jnlp文件）实现在服务器远程虚拟控制台完成远程管理的方法
 Firefox 浏览器添加Linux jre插件

原文地址：https://www.cnblogs.com/quluqi/p/HFun_Csla_Factory.html