我试图将一个ASP.NET 4.5应用程序移植到.NET Core，但是有一个真正的问题我似乎无法解决。
我的现有应用程序执行返回多个数据表的数据集的存储过程。Entity Framework可以自动将返回的字段映射到我的实体属性，但仅适用于数据集中的第一个数据表（自然而然）。
因此，我正在尝试弄清楚是否有可能以某种方式拦截模型构建过程，并使用自定义代码处理数据集并查看其他数据表以设置实体字段。
我知道我可以使用直接使用SqlConnection执行存储过程的常规方法，但我想知道Entity Framework是否已经有了这样做的方法。
目前，执行返回数据的存储过程的方式是使用DbSet.FromSql方法。
using (var context = new SampleContext())
{
var data= context.MyEntity
.FromSql("EXEC GetData")
.ToList();
}
DbSet 上调用DbSet 类型上的所有属性using (var context = new SampleContext())
using (var command = context.Database.GetDbConnection().CreateCommand())
{
command.CommandText = "GetData";
command.CommandType = CommandType.StoredProcedure;
context.Database.OpenConnection();
using (var result = command.ExecuteReader())
{
// do something with result
}
}
DataSet dataSet = null;
using (var context = new SampleContext())
using (var command = context.Database.GetDbConnection().CreateCommand())
{
command.CommandText = "GetData";
command.CommandType = CommandType.StoredProcedure;
context.Database.OpenConnection();
using (SqlDataAdapter adapter = new SqlDataAdapter())
{
adapter.SelectCommand = command;
dataSet = new DataSet();
adapter.Fill(dataSet);
return dataSet;
}
}
为了回答@DKhanaf关于多个数据集的问题，您可以使用SqlDataAdapter将所有结果集填充到DataSet对象中。不过SqlDataAdapter需要完整的.NET Framework，所以您必须在针对.NET 462或类似框架的情况下运行您的.NETCore项目。
using (var context = new SampleContext())
using (var command = context.Database.GetDbConnection().CreateCommand())
{
command.CommandText = "GetData";
command.CommandType = CommandType.StoredProcedure;
context.Database.OpenConnection();
using (SqlDataAdapter adapter = new SqlDataAdapter(command))
{
var ds = new DataSet();
adapter.Fill(ds);
return ds;
}
}
}
我使用了StoredProcedureEFCore nuget包，链接为https://github.com/verdie-g/StoredProcedureEFCore,EnterpriseLibrary.Data.NetCore,EFCor.SqlServer,EFCore.Tools
我尝试使用{仓储模式}的DbFirst方法.. 我想是这样
startup.cs
ConfigureServices(IServiceCollection services){
services.AddDbContext<AppDbContext>(opt => opt
.UseSqlServer(Configuration.GetConnectionString("SampleConnectionString")));
services.AddScoped<ISomeDAL, SomeDAL>();
}
public class AppDbContext : DbContext{
public AppDbContext(DbContextOptions<AppDbContext> options) : base(options)
{}
}
ISomeDAl接口有{GetPropertiesResponse GetAllPropertiesByCity(int CityId);}
public class SomeDAL : ISomeDAL
{
private readonly AppDbContext context;
public SomeDAL(AppDbContext context)
{
this.context = context;
}
public GetPropertiesResponse GetAllPropertiesByCity(int CityId)
{
//Create Required Objects for response
//wont support ref Objects through params
context.LoadStoredProc(SQL_STATEMENT)
.AddParam("CityID", CityId).Exec( r =>
{
while (r.Read())
{
ORMapping<GenericRespStatus> orm = new ORMapping<GenericRespStatus>();
orm.AssignObject(r, _Status);
}
if (r.NextResult())
{
while (r.Read())
{
Property = new Property();
ORMapping<Property> orm = new ORMapping<Property>();
orm.AssignObject(r, Property);
_propertyDetailsResult.Add(Property);
}
}
});
return new GetPropertiesResponse{Status=_Status,PropertyDetails=_propertyDetailsResult};
}
}
public class GetPropertiesResponse
{
public GenericRespStatus Status;
public List<Property> PropertyDetails;
public GetPropertiesResponse()
{
PropertyDetails = new List<Property>();
}
}
public class GenericRespStatus
{
public int ResCode { get; set; }
public string ResMsg { get; set; }
}
internal class ORMapping<T>
{
public void AssignObject(IDataReader record, T myClass)
{
PropertyInfo[] propertyInfos = typeof(T).GetProperties();
for (int i = 0; i < record.FieldCount; i++)
{
if (propertyInfos.Any(obj => obj.Name == record.GetName(i))) //&& record.GetValue(i) != DBNull.Value
{
propertyInfos.Single(obj => obj.Name == record.GetName(i)).SetValue(myClass, Convert.ChangeType(record.GetValue(i), record.GetFieldType(i)));
}
}
}
}
dbContext.TableName.FromSql("stored_proc")。不过，我不确定这是否会将所有其他表中的字段都映射出来。 - Craig Curtis