_context.Set<Entity>().FromSql("dbo.Stored_Proc").ToList();
但是，如果我的返回值不是上下文中的实体，则无法完成。
任何帮助将不胜感激。
这很简单。
以下是三个步骤：
public class SPModel
{
public int Id { get; set; }
public DateTime? CreatedDateTime { get; set; }
etc...
}
public class YourDbContext : DbContext
{
public virtual DbSet<SPModel> YourDbSet { get; set; }
....
}
请不要将此类映射到任何SQL表中！
var spModels = await dbContext.YourDbSet
.FromSqlRaw("EXECUTE yourStoredProcedure {0},{1}", param1, param2)
.ToListAsync();
一些有用的内容：
FromSql()中的参数感到头痛。我有一个DateTime值，我想将其转换为PostgreSQL中的date，但系统会自动将DateTime转换为timestamp without timezone。是否有任何方法可以像在AdoDB中使用的那样指定NpgsqlDbType？我的意思是，在AdoDB中，我们可以使用这个：cmd.Parameters.Add("param", NpgsqlDbType.Date);。如何在FromSql()中实现这个功能？ - FirantoFromSql() 可以使用 SqlParameter 对象来定义参数。在 PostgreSQL 中，我使用 NpgsqlParameter（SqlParameter 的 npgsql 实现）。问题解决了。 :) - FirantomodelBuilder.Entity<SPModel>().HasNoKey(); 并使用 [NotMapped] 属性标记 SPModel。 - Roman Borovetspublic static DbCommand LoadStoredProc(
this DbContext context, string storedProcName)
{
var cmd = context.Database.GetDbConnection().CreateCommand();
cmd.CommandText = storedProcName;
cmd.CommandType = System.Data.CommandType.StoredProcedure;
return cmd;
}
public static DbCommand WithSqlParam(
this DbCommand cmd, string paramName, object paramValue)
{
if (string.IsNullOrEmpty(cmd.CommandText))
throw new InvalidOperationException(
"Call LoadStoredProc before using this method");
var param = cmd.CreateParameter();
param.ParameterName = paramName;
param.Value = paramValue;
cmd.Parameters.Add(param);
return cmd;
}
private static List<T> MapToList<T>(this DbDataReader dr)
{
var objList = new List<T>();
var props = typeof(T).GetRuntimeProperties();
var colMapping = dr.GetColumnSchema()
.Where(x => props.Any(y => y.Name.ToLower() == x.ColumnName.ToLower()))
.ToDictionary(key => key.ColumnName.ToLower());
if (dr.HasRows)
{
while (dr.Read())
{
T obj = Activator.CreateInstance<T>();
foreach (var prop in props)
{
var val =
dr.GetValue(colMapping[prop.Name.ToLower()].ColumnOrdinal.Value);
prop.SetValue(obj, val == DBNull.Value ? null : val);
}
objList.Add(obj);
}
}
return objList;
}
public static async Task<List<T>> ExecuteStoredProc<T>(this DbCommand command)
{
using (command)
{
if (command.Connection.State == System.Data.ConnectionState.Closed)
command.Connection.Open();
try
{
using (var reader = await command.ExecuteReaderAsync())
{
return reader.MapToList<T>();
}
}
catch(Exception e)
{
throw (e);
}
finally
{
command.Connection.Close();
}
}
}
List<MyType> myTypeList = new List<MyType>();
using(var context = new MyDbContext())
{
myTypeList = context.LoadStoredProc("StoredProcedureName")
.WithSqlParam("firstparamname", firstParamValue)
.WithSqlParam("secondparamname", secondParamValue).
.ExecureStoredProc<MyType>();
}
可以通过以下扩展实现，而无需定义任何DbQuery或DbSet。适用于Efcore 3及以上版本。
public class CustomType
{
public int Id { get; set; }
public string Name { get; set; }
}
public static class DbContextExtensions
{
public static IList<T> SqlQuery<T>(this DbContext context, string sql, params object[] parameters) where T : class
{
using (var dbcontext = new ContextForQueryType<T>(context.Database.GetDbConnection()))
{
return dbcontext.Set<T>().FromSqlRaw(sql, parameters).AsNoTracking().ToList();
}
}
public static async Task<IList<T>> SqlQueryAsync<T>(this DbContext context, string sql, params object[] parameters) where T : class
{
using (var dbcontext = new ContextForQueryType<T>(context.Database.GetDbConnection()))
{
return await dbcontext.Set<T>().FromSqlRaw(sql, parameters).AsNoTracking().ToListAsync();
}
}
private class ContextForQueryType<T> : DbContext where T : class
{
private readonly System.Data.Common.DbConnection connection;
public ContextForQueryType(System.Data.Common.DbConnection connection)
{
this.connection = connection;
}
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
optionsBuilder.UseSqlServer(connection, options => options.EnableRetryOnFailure());
base.OnConfiguring(optionsBuilder);
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity<T>().HasNoKey();
base.OnModelCreating(modelBuilder);
}
}
}
并且像这样执行：
var param = new SqlParameter("@IdParam", SqlDbType.VarChar, 10);
param.Value = Id.ToString();
string sqlQuery = "Exec [dbo].[usp_get_custom_type] @IdParam";
await context.SqlQueryAsync<CustomType>(sqlQuery);
我尝试了所有其他解决方案，但对我没有用。但我找到了一个正确的解决方案，它可能对这里的某个人有帮助。
我的原始答案- https://dev59.com/Fl4b5IYBdhLWcg3w3k-Y#57224037
要调用存储过程并将结果返回到EF Core模型列表中，我们必须遵循3个步骤。
第一步。
您需要添加一个新类，就像您的实体类一样。该类应具有与SP中所有列相对应的属性。例如，如果您的SP返回名为Id和Name的两列，则您的新类应该是：
public class MySPModel
{
public int Id {get; set;}
public string Name {get; set;}
}
步骤2。
然后，您必须将一个DbQuery属性添加到您的DBContext类中，以用于您的SP。
public partial class Sonar_Health_AppointmentsContext : DbContext
{
public virtual DbSet<Booking> Booking { get; set; } // your existing DbSets
...
public virtual DbQuery<MySPModel> MySP { get; set; } // your new DbQuery
...
}
步骤三。
现在，您将能够从您的DBContext调用并获取您的SP的结果。
var result = await _context.Query<MySPModel>().AsNoTracking().FromSql(string.Format("EXEC {0} {1}", functionName, parameter)).ToListAsync();
我正在使用通用的UnitOfWork & Repository。因此，我的执行SP的函数是
/// <summary>
/// Execute function. Be extra care when using this function as there is a risk for SQL injection
/// </summary>
public async Task<IEnumerable<T>> ExecuteFuntion<T>(string functionName, string parameter) where T : class
{
return await _context.Query<T>().AsNoTracking().FromSql(string.Format("EXEC {0} {1}", functionName, parameter)).ToListAsync();
}
希望对某人有所帮助！！！