EF core 學習 執行原生sql語句 之ExecuteReader 和ExecuteScalar


通過ef core 源碼分析 Microsoft.EntityFrameworkCore.Storage.RelationalCommandExtensions類中有相應的方法 為此得到相應的結果:

為此在我們的數據上下文中拓展方法:

 public async Task<DbDataReader> ExecuteReaderAsync(RawSqlString sql, params object[] parameters)
        {
            using (await Database.GetService<IConcurrencyDetector>().EnterCriticalSectionAsync(default))
            {
                RawSqlCommand rawSqlCommand = Database.GetService<IRawSqlCommandBuilder>().Build(sql.Format, parameters);
                return (await rawSqlCommand.RelationalCommand.ExecuteReaderAsync(Database.GetService<IRelationalConnection>(), rawSqlCommand.ParameterValues)).DbDataReader;
            }
        }
        //  FormattableString
        public Task<DbDataReader> ExecuteReaderAsync(FormattableString sql)
        {
            return ExecuteReaderAsync(sql.Format, sql.GetArguments());
        }
        public Task<object> ExecuteScalarAsync(FormattableString sql)
        {
            return ExecuteScalarAsync(sql.Format, sql.GetArguments());
        }
        public async Task<object> ExecuteScalarAsync(RawSqlString sql, params object[] parameters)
        {
            using (await Database.GetService<IConcurrencyDetector>().EnterCriticalSectionAsync(default))
            {
                RawSqlCommand rawSqlCommand = Database.GetService<IRawSqlCommandBuilder>().Build(sql.Format, parameters);
                return await rawSqlCommand.RelationalCommand.ExecuteScalarAsync(Database.GetService<IRelationalConnection>(), rawSqlCommand.ParameterValues);
            }
        }

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM