如何深入理解手撸ORM框架中的Update操作原理?
摘要:快速传送 手撸ORM浅谈ORM框架之基础篇 手撸ORM浅谈ORM框架之Add篇 手撸ORM浅谈ORM框架之Update篇 手撸ORM浅谈ORM框架之Delete篇 手撸ORM浅谈ORM框架之Query篇 后续待定。。。。。。 前人栽树,后人
快速传送
手撸ORM浅谈ORM框架之基础篇
手撸ORM浅谈ORM框架之Add篇
手撸ORM浅谈ORM框架之Update篇
手撸ORM浅谈ORM框架之Delete篇
手撸ORM浅谈ORM框架之Query篇
后续待定。。。。。。
前人栽树,后人乘凉
BaseRepository-》GetCurrentTableName、GetExcludeKeyAllFields已经在《手撸ORM浅谈ORM框架之Add篇》BaseRepository里面的方法,不重复搬砖了。
承上启下,传递希望
BaseRepository-》GetKey获取表主键,目前自动递增主键使用的KeyAttribute标识自动递增主键,更新不需要区分主键类型获取当前实体所有的主键作为where更新条件;如果项目中需要使用复合主键、指定主键(按照业务单元生成的业务所需主键,例如: SN2020102600001等),获取Key的方法加入自定义的xxxAttribute作为条件之一,来满足当前的业务需要;
1 /// <summary>
2 /// get key-atttribute
3 /// </summary>
4 /// <returns>return key-attribute</returns>
5 private List<PropertyInfo> GetKey()
6 {
7 List<PropertyInfo> list = new List<PropertyInfo>();
8 PropertyInfo[] properties = typeof(T).GetProperties();
9 foreach (var item in properties)
10 {
11 if (item.CustomAttributes.Any(c => c.AttributeType.Name == nameof(KeyAttribute)))
12 {
13 list.Add(item);
14 }
15 }
16 return list;
17 }
哼,看透你了
(2020-10-30新增)
当我们把当前传入的实体通过反射获得public字段及值、主键,我们就可以了把Update语句动态拼接出来了,非主键字段加在UPDATE 表名称 SET后面,主键字段放在WHERE条件后面,即:UPDATE 表名称 SET 列名称 = 新值 WHERE 列名称 = 某值
BaseRepository-》GetUpdateSql来来来Sql出现了(提高性能可以优化,缓存当前项目所有表的增删查改Sql语句)
1 /// <summary>
2 /// get update sql
3 /// </summary>
4 /// <param name="entity"></param>
5 /// <returns></returns>
6 private string GetUpdateSql(T entity)
7 {
8 string tableName = GetCurrentTableName();
9 StringBuilder stringBuilder = new StringBuilder();
10 List<PropertyInfo> properties = GetExcludeKeyAllFields();
11 foreach (var item in properties)
12 {
13 stringBuilder.AppendFormat("{0}=@{0},", item.Name);
14 }
15 stringBuilder.Remove(stringBuilder.Length - 1, 1);
16 stringBuilder.Append(" WHERE ");
17 List<PropertyInfo> propertyKeys = GetKey();
18 foreach (var propertyKey in propertyKeys)
19 {
20 stringBuilder.AppendFormat("{0}=@{0} AND ", propertyKey.Name);
21 }
22 stringBuilder.Remove(stringBuilder.Length - 4, 4);
23 return string.Format("UPDATE {0} SET {1}", tableName, stringBuilder);
24 }
(2020-11-01新增start)
BaseRepository-》泛型获取GetMySqlParameters(Sql注入的问题,可以根据项目需要获取xxxParameter);
1 /// <summary>
2 /// get sql parameters
3 /// </summary>
4 /// <param name="properties">properties</param>
5 /// <param name="entity">entity</param>
6 /// <returns>return sql parameters</returns>
7 private MySqlParameter[] GetMySqlParameters(PropertyInfo[] properties, T entity)
8 {
9 List<MySqlParameter> list = new List<MySqlParameter>();
10 foreach (var propertie in properties)
11 {
12 object obj = propertie.GetValue(entity);
13 if (obj == null)
14 {
15 list.Add(new MySqlParameter($"@{propertie.Name}", DBNull.Value));
16 }
17 else
18 {
19 list.Add(new MySqlParameter($"@{propertie.Name}", propertie.GetValue(entity)));
20 }
21 }
22 if (list == null || list.Count <= 0)
23 {
24 throw new ArgumentNullException("get sql parameters failed");
25 }
26 return list.ToArray();
27 }
(2020-11-01新增end)
BaseRepository-》泛型Update;
1 /// <summary>
2 /// udpate entity
3 /// </summary>
4 /// <param name="entity">entity</param>
5 /// <returns>return true or false</returns>
6 public bool Update(T entity)
7 {
8 string sql = GetUpdateSql(entity);
9 MySqlParameter[] parameters = GetMySqlParameters(entity.GetType().GetProperties(), entity);
10 int row = context.Database.ExecuteSqlRaw(sql, parameters);
11 return row > 0 ? true : false;
12 }
实操Repository方法泛型约束;
1 public bool Update(Learn_Student learnStudent)
2 {
3 using (MySqlDbContext mySqlDbContext = new MySqlDbContext())
4 {
5 BaseRepository<Learn_Student> baseRepository = new BaseRepository<Learn_Student>(mySqlDbContext);
6 return baseRepository.Update(learnStudent);
7 }
8 }
注:learn-orm-net目前只是作为学习ORM框架原理的Demo,项目会做出一定的优化处理,但不能直接拿来在项目中使用,毕竟现在NET Framework、NET Core已经有很多优秀的ORM框架,NET下一次发布就是只有一个版本了,我们没有必要重复造轮子,造轮子是因为没有现成的优秀的轮子可用。
代码下载地址:SourceCode作者水平有限欢迎园友纠正错误及不恰当之处,予以及时修正以免误导他人!
