很多朋友谈了关于重复“造轮子”的看法，大师们的“轮子”为了兼顾框架整体的通用性，不可能针对每个特定项目做处理，个人觉得我们应该从那些作品（诸如nhibernate）领悟他们的设计思想，然后结合工作中的实际情况，先自己动手做一做，从实践中体会，不失为一种好的学习方式。
关于主键是否采用自增方式，这也得看具体应用。毕竟，使用逻辑主键还是业务主键很久以来就存有争议，个人比较倾向于逻辑主键。
最后，自己动手只是学习的手段而不是本文的目的，实现的方法也并不一定适用于所有朋友的实际情况。希望能够”用20%的精力解决80%的问题“，仅此而已
回到正题
在前一节 自己动手写个ORM实现(1) 中,我们定义了实体接口IEntity,实现IEntity的抽象类EntityBase,以及建立实体-表, 属性-字段对应关系的EntityMappingAttribute以及PropertyMappingAttribute. 相应的,我们声明了一个简单的管理IEntity的接口IEntityManage,如下
先声明一个EntityManager吧 , 实现IEntityManager
让我们从最简单的Load<T>(int id)方法开始, 它的作用很简单,就是根据传入的id获取单个实体对象.
1
public T Load<T>(int id) where T : IEntity
2![]()
}
首先,我们根据传入的泛型变量T获取到一个Type对象,调用GetTableName<T>()得到这个实体类型对应的数据表名2
GetTableName<T>的原型如下
1![]()
}
望文生意,由代码可知道我们默认使用实体类名作为对应的数据库表名当EntityMappingAttribute的TableName属性为空的情况下.
在这里我们使用了反射实现其功能,地球人都知道,反射是比较消耗系统资源的,因此我们对上面的这段代码动点小手术.
1//缓存实体类型对应表名
2 private static readonly Dictionary<Type, string> tnCache = new Dictionary<Type, string>();
3 //缓存实体属型对应的字段名
4 private static readonly Dictionary<PropertyInfo, string> fnCache = new Dictionary<PropertyInfo, string>();
5 //缓存实体类型的属性集合
6 private static readonly Dictionary<Type, List<PropertyInfo>> pCache = new Dictionary<Type, List<PropertyInfo>>();
2
3
4
5
6
作用也很简单明了,就是在一个EntityManager实例的作用域内维护对传入需要操作的实体对象的反射信息的缓存
完整的GetTableName<T>方法实现如下
1protected string GetTableName<T>() where T : IEntity
2![]()
}
2
接下来让我们回到Load<T>方法, 7-18行无需赘述,得到sql操作的dataset,在这里我们使用了企业库.
来到第20行
t = GetByDataRow<T>(row);
根据参数的上下文我们可知, 这个方法的作用是根据sql查询得到的一行数据,转换成相应的实体对象实例
GetByDataRow<T>实现如下
1protected T GetByDataRow<T>(DataRow data) where T : IEntity
2![]()
}
2
首先我们动态创建一个T实例, 然后调用GetMappedProperties<T>()方法获取, 该实体所有标记了PropertyMappingAttribute的Property集合
然后根据sql查询出来结果,对t实例对象赋值返回,GetMappedProperties<T>,GetFieldName方法实现如下
1protected IEnumerable<PropertyInfo> GetMappedProperties<T>() where T : IEntity
2![]()
}
2
1protected string GetFieldName(PropertyInfo property)
2![]()
}
2
再来到Load<T>方法的第25行
实现如下
1private void SetPersistedStatus<T>(T t, bool persisted) where T : IEntity
2![]()
}
2
第9行, 如果我们设置传入的实体对象状态为已持久化,则把该对象的Raw属性(IEntity类型)设置为初始状态,为了我们后面所要讲的Update方法等操作
至此, 尽管代码比较quick and dirty, 但我们的工作确实起效了, 它可以帮我们查询出想要的东东了.
-------------------------------------------------------------------------------------------------------------------------------------------
完成了单个实体的查询操作, 接下来我们实现集合查询就比较好办了
1public List<T> LoadAll<T>() where T : IEntity
2![]()
}
2
实现方法和单体查询大同小异, 根据查询出的DataSet 结果集,我们把dataSet变量转换成对应的实体集合, GetByDataSet<T>实现如下
1protected List<T> GetByDataSet<T>(DataSet data) where T : IEntity
2![]()
}
2
到这里,我们EntityManager非常初步的查询功能(不涉及到条件查询,分页操作)就已经实现了,在后面的章节中我们将逐步实现其他功能.