手撸ORM浅谈ORM框架之Update篇

快速传送

手撸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作为条件之一，来满足当前的业务需要；

/// <summary>
/// get key-atttribute
/// </summary>
/// <returns>return key-attribute</returns>
private List<PropertyInfo> GetKey()
{
    List<PropertyInfo> list = new List<PropertyInfo>();
    PropertyInfo[] properties = typeof(T).GetProperties();
    foreach (var item in properties)
    {
        if (item.CustomAttributes.Any(c => c.AttributeType.Name == nameof(KeyAttribute)))
        {
            list.Add(item);
        }
    }
    return list;
}

哼，看透你了

(2020-10-30新增)

当我们把当前传入的实体通过反射获得public字段及值、主键，我们就可以了把Update语句动态拼接出来了，非主键字段加在UPDATE 表名称 SET后面，主键字段放在WHERE条件后面，即：UPDATE 表名称 SET 列名称 = 新值 WHERE 列名称 = 某值

BaseRepository-》GetUpdateSql来来来Sql出现了(提高性能可以优化，缓存当前项目所有表的增删查改Sql语句)

/// <summary>
/// get update sql
/// </summary>
/// <param name="entity"></param>
/// <returns></returns>
private string GetUpdateSql(T entity)
{
    string tableName = GetCurrentTableName();
    StringBuilder stringBuilder = new StringBuilder();
    List<PropertyInfo> properties = GetExcludeKeyAllFields();
    foreach (var item in properties)
    {
        stringBuilder.AppendFormat("{0}=@{0},", item.Name);
    }
    stringBuilder.Remove(stringBuilder.Length - 1, 1);
    stringBuilder.Append(" WHERE ");
    List<PropertyInfo> propertyKeys = GetKey();
    foreach (var propertyKey in propertyKeys)
    {
        stringBuilder.AppendFormat("{0}=@{0} AND ", propertyKey.Name);
    }
    stringBuilder.Remove(stringBuilder.Length - 4, 4);
    return string.Format("UPDATE {0} SET {1}", tableName, stringBuilder);
}

(2020-11-01新增start)

BaseRepository-》泛型获取GetMySqlParameters(Sql注入的问题，可以根据项目需要获取xxxParameter)；

/// <summary>
/// get sql parameters
/// </summary>
/// <param name="properties">properties</param>
/// <param name="entity">entity</param>
/// <returns>return sql parameters</returns>
private MySqlParameter[] GetMySqlParameters(PropertyInfo[] properties, T entity)
{
    List<MySqlParameter> list = new List<MySqlParameter>();
    foreach (var propertie in properties)
    {
        object obj = propertie.GetValue(entity);
        if (obj == null)
        {
            list.Add(new MySqlParameter($"@{propertie.Name}", DBNull.Value));
        }
        else
        {
            list.Add(new MySqlParameter($"@{propertie.Name}", propertie.GetValue(entity)));
        }
    }
    if (list == null || list.Count <= 0)
    {
        throw new ArgumentNullException("get sql parameters failed");
    }
    return list.ToArray();
}

(2020-11-01新增end)

BaseRepository-》泛型Update；

/// <summary>
/// udpate entity
/// </summary>
/// <param name="entity">entity</param>
/// <returns>return true or false</returns>
public bool Update(T entity)
{
    string sql = GetUpdateSql(entity);
    MySqlParameter[] parameters = GetMySqlParameters(entity.GetType().GetProperties(), entity);
    int row = context.Database.ExecuteSqlRaw(sql, parameters);
    return row > 0 ? true : false;
}

 实操Repository方法泛型约束；

public bool Update(Learn_Student learnStudent)
{
    using (MySqlDbContext mySqlDbContext = new MySqlDbContext())
    {
        BaseRepository<Learn_Student> baseRepository = new BaseRepository<Learn_Student>(mySqlDbContext);
        return baseRepository.Update(learnStudent);
    }
}

注：learn-orm-net目前只是作为学习ORM框架原理的Demo，项目会做出一定的优化处理，但不能直接拿来在项目中使用，毕竟现在NET Framework、NET Core已经有很多优秀的ORM框架，NET下一次发布就是只有一个版本了，我们没有必要重复造轮子，造轮子是因为没有现成的优秀的轮子可用。

代码下载地址: SourceCode  作者水平有限欢迎园友纠正错误及不恰当之处，予以及时修正以免误导他人！