ABP實現EF執行SQL（增刪改查）解決方案

前言

　　一般情況下，使用EF中的語法可以幫助我們完成絕大部分業務，但是也有特殊的情況需要直接執行的Sql語句。比如，我們的業務過於復雜繁瑣，或是有些業務使用EF操作時比較復雜，但是使用的Sql時會很簡單等，這時就有了以下需求了。

具體實現

　　1，首先我們需要定義一個接口類：ISqlExecuter（名字看你心情了）

public interface ISqlExecuter
    {
        /// <summary>
        /// 執行給定的命令
        /// </summary>
        /// <param name="sql">命令字符串</param>
        /// <param name="parameters">要應用於命令字符串的參數</param>
        /// <returns>執行命令后由數據庫返回的結果</returns>
        int Execute(string sql);

        /// <summary>
        /// 傳入查詢sql，返回List<T>數組
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        Task<List<T>> SqlQuery<T>(string sql) where T : class, new();
    }

　　2，定義實現類：SqlExecuter（名字看你心情了）

 public class SqlExecuter : ISqlExecuter, ITransientDependency
    {
        private IDbContextProvider<OADbContext> _dbContextProvider = null;

        public SqlExecuter(IDbContextProvider<OADbContext> dbContextProvider)
        {
            _dbContextProvider = dbContextProvider;//IocManager.Instance.Resolve<IDbContextProvider<OADbContext>>();
        }

        /// <summary>
        /// 執行給定的命令
        /// </summary>
        /// <param name="sql">命令字符串</param>
        /// <param name="parameters">要應用於命令字符串的參數</param>
        /// <returns>執行命令后由數據庫返回的結果</returns>
        public int Execute(string sql)
        {
            return _dbContextProvider.GetDbContext().Database.ExecuteSqlCommand(new RawSqlString(sql));
        }

        /// <summary>
        /// 傳入查詢sql，返回List<T>數組
        /// </summary>
        /// <param name="sql"></param>
        /// <returns></returns>
        public async Task<List<T>> SqlQuery<T>(string sql) where T : class, new()
        {
            return await Task.Run(() =>
            {
                var db = _dbContextProvider.GetDbContext().Database;
                var conn = db.GetDbConnection();
                if (conn.State != ConnectionState.Open)
                    conn.Open();

                var result = new List<T>();

                try
                {
                    RelationalDataReader query = null;

                    using (db.GetService<IConcurrencyDetector>().EnterCriticalSection())
                    {
                        var rawSqlCommand = db.GetService<IRawSqlCommandBuilder>().Build(sql);

                        query = rawSqlCommand.ExecuteReader(db.GetService<IRelationalConnection>());
                    }

                    //獲取DbDataReader
                    var dr = query.DbDataReader;

                    var properties = typeof(T).GetProperties().ToList();

                    while (dr.Read())
                    {
                        var obj = new T();
                        foreach (var property in properties)
                        {
                            //獲取該字段明的列序號，從0開始
                            var id = dr.GetOrdinal(property.Name.ToLower());

                            if (!dr.IsDBNull(id))
                            {
                                if (dr.GetValue(id) != DBNull.Value)
                                {
                                    property.SetValue(obj, dr.GetValue(id));
                                }
                            }
                        }

                        result.Add(obj);
                    }

                    //關閉DbDataReader
                    dr.Close();
                }
                catch (Exception e)
                {
                    throw new UserFriendlyException(e.Message);
                }

                return result;
            });
        }
    }

注意：

　　引用ITransientDependency接口是為了ABP的自動注冊到容器。

使用方式

　　1，注入實例：

　　2，調用