经过ef core 源码分析 Microsoft.EntityFrameworkCore.Storage.RelationalCommandExtensions类中有相应的方法 为此获得相应的结果:sql
为此在咱们的数据上下文中拓展方法:async
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); } }