手擼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  作者水平有限歡迎園友糾正錯誤及不恰當之處，予以及時修正以免誤導他人！