zoukankan      html  css  js  c++  java
  • 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);
                }
            }
  • 相关阅读:
    【每日一题】 UVA
    【每日一题】 UVA
    【每日一题】 UVA
    【每日一题】 UVA
    【每日一题】UVA
    【每日一题】 uva-232 模拟+输出要求很严格
    【每日一题】 UVA
    MYSQL约束
    数据库,SQL分类
    类加载器&反射&模块化
  • 原文地址:https://www.cnblogs.com/SpeakHero/p/8944516.html
Copyright © 2011-2022 走看看