0
我想在我的web api上通过一个原始的sql连接与实体框架。这是我的api代码。实体框架查询不返回正确的结果
namespace HannaOilAndGas2.Controllers
{
[Produces("application/json")]
[Route("api/mainview")]
public class MainViewApi : Controller
{
private readonly ScadaContext _context;
public MainViewApi(ScadaContext context)
{
_context = context;
}
// GET: api/values
[HttpGet]
[Route("allmainview")]
public IEnumerable<Device> GetAllMainView()
{
return _context.Device.FromSql(
"SELECT PD.RecId, D.Location, Round(PD.SPOT_FLOW_RATE,0), Round(PD.PREVIOUS_DAY_VOLUME,0)," +
"Round(PD.LINE_PRESSURE,0), Round(PD.DIFFERENTIAL_PRESSURE,0), Round(PD.TEMPERATURE,0)," +
"Round(PD.BATTERY_VOLTAGE,0) ROUND(PD.FCP,0), ROUND(PD.FTP,0) D.LAST_COMMUNICATION, D.LAST_COMMUNICATION_METHOD" +
"FROM DEVICE D" +
"JOIN POLL_DATA PD" +
"ON D.HANNA_DEVICE_ID = PD.HANNA_DEVICE_ID").Where(x => x.MeterId != "HOGC%");
}
我的设备型号是这样的，因为所有这些表涉及到设备
namespace HannaOilAndGas2.Data
{
public partial class Device
{
public Device()
{
DailyData = new HashSet<DailyData>();
PollBattery = new HashSet<PollBattery>();
PollDifferentialPressure = new HashSet<PollDifferentialPressure>();
PollFcp = new HashSet<PollFcp>();
PollFtp = new HashSet<PollFtp>();
PollLinePressure = new HashSet<PollLinePressure>();
PollPdVolume = new HashSet<PollPdVolume>();
PollSpotFlowRate = new HashSet<PollSpotFlowRate>();
PollTemperature = new HashSet<PollTemperature>();
PollData = new HashSet<PollData>();
ChokeHistory = new HashSet<ChokeHistory>();
CommentsHistory = new HashSet<CommentsHistory>();
ContractHourHistory = new HashSet<ContractHourHistory>();
HourlyData = new HashSet<HourlyData>();
MeterTubeSizeHistory = new HashSet<MeterTubeSizeHistory>();
OrificeCoeffHistory = new HashSet<OrificeCoeffHistory>();
PlateSizeHistory = new HashSet<PlateSizeHistory>();
PollDataHistorical = new HashSet<PollDataHistorical>();
ShutinHistory = new HashSet<ShutinHistory>();
}
public int HannaDeviceId { get; set; }
public int? MdbDeviceId { get; set; }
public string SpreadsheetId { get; set; }
public string SpectraId { get; set; }
public string ServiceStarId { get; set; }
public string MeterId { get; set; }
public string Location { get; set; }
public float? ShutinPressure { get; set; }
public float? Latitude { get; set; }
public float? Longitude { get; set; }
public float? Choke { get; set; }
public float? OrificeCoeff { get; set; }
public decimal? MeterTubeSize { get; set; }
public float? ContractHour { get; set; }
public string SecTwnRange { get; set; }
public string County { get; set; }
public string State { get; set; }
public decimal? PlateSize { get; set; }
public string Comments { get; set; }
public DateTime? LastCommunication { get; set; }
public string LastCommunicationMethod { get; set; }
public virtual ICollection<DailyData> DailyData { get; set; }
public virtual ICollection<PollBattery> PollBattery { get; set; }
public virtual ICollection<PollDifferentialPressure> PollDifferentialPressure { get; set; }
public virtual ICollection<PollFcp> PollFcp { get; set; }
public virtual ICollection<PollFtp> PollFtp { get; set; }
public virtual ICollection<PollLinePressure> PollLinePressure { get; set; }
public virtual ICollection<PollPdVolume> PollPdVolume { get; set; }
public virtual ICollection<PollSpotFlowRate> PollSpotFlowRate { get; set; }
public virtual ICollection<PollTemperature> PollTemperature { get; set; }
public virtual ICollection<PollData> PollData { get; set; }
public virtual ICollection<ChokeHistory> ChokeHistory { get; set; }
public virtual ICollection<CommentsHistory> CommentsHistory { get; set; }
public virtual ICollection<ContractHourHistory> ContractHourHistory { get; set; }
public virtual ICollection<HourlyData> HourlyData { get; set; }
public virtual ICollection<MeterTubeSizeHistory> MeterTubeSizeHistory { get; set; }
public virtual ICollection<OrificeCoeffHistory> OrificeCoeffHistory { get; set; }
public virtual ICollection<PlateSizeHistory> PlateSizeHistory { get; set; }
public virtual ICollection<PollDataHistorical> PollDataHistorical { get; set; }
public virtual ICollection<ShutinHistory> ShutinHistory { get; set; }
}
}
这是我的上下文
public partial class ScadaContext : DbContext
{
public ScadaContext(DbContextOptions<ScadaContext> options) : base(options)
{}
public ScadaContext()
{
}
public virtual DbSet<ChokeHistory> ChokeHistory { get; set; }
public virtual DbSet<CommentsHistory> CommentsHistory { get; set; }
public virtual DbSet<ContractHourHistory> ContractHourHistory { get; set; }
public virtual DbSet<DailyData> DailyData { get; set; }
public virtual DbSet<Device> Device { get; set; }
public virtual DbSet<HourlyData> HourlyData { get; set; }
public virtual DbSet<MeterTubeSizeHistory> MeterTubeSizeHistory { get; set; }
public virtual DbSet<OrificeCoeffHistory> OrificeCoeffHistory { get; set; }
public virtual DbSet<PlateSizeHistory> PlateSizeHistory { get; set; }
public virtual DbSet<PollBattery> PollBattery { get; set; }
public virtual DbSet<PollData> PollData { get; set; }
public virtual DbSet<PollDataHistorical> PollDataHistorical { get; set; }
public virtual DbSet<PollDifferentialPressure> PollDifferentialPressure { get; set; }
public virtual DbSet<PollFcp> PollFcp { get; set; }
public virtual DbSet<PollFtp> PollFtp { get; set; }
public virtual DbSet<PollLinePressure> PollLinePressure { get; set; }
public virtual DbSet<PollPdVolume> PollPdVolume { get; set; }
public virtual DbSet<PollSpotFlowRate> PollSpotFlowRate { get; set; }
public virtual DbSet<PollTemperature> PollTemperature { get; set; }
public virtual DbSet<ShutinHistory> ShutinHistory { get; set; }
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity<ChokeHistory>(entity =>
{
entity.HasKey(e => e.RecId)
.HasName("PK_CHOKE_HISTORY");
entity.ToTable("CHOKE_HISTORY");
entity.Property(e => e.RecId).HasColumnName("RecID");
entity.Property(e => e.Choke).HasColumnName("CHOKE");
entity.Property(e => e.HannaDeviceId).HasColumnName("HANNA_DEVICE_ID");
entity.Property(e => e.ImportMethod)
.IsRequired()
.HasColumnName("IMPORT_METHOD")
.HasMaxLength(50);
entity.Property(e => e.Timestamp)
.HasColumnName("TIMESTAMP")
.HasColumnType("datetime")
.HasDefaultValueSql("getdate()");
entity.HasOne(d => d.HannaDevice)
.WithMany(p => p.ChokeHistory)
.HasForeignKey(d => d.HannaDeviceId)
.HasConstraintName("FK_CHOKE_HISTORY_DEVICE");
});
我所有的表都建立了以下这个我想在api中获取查询的工作，但我所得到的是[]的空白结果。我是相当新的实体框架我读过，你可以做这样的原始SQL。我不知道我在做什么错误的任何帮助，将不胜感激。我的应用程序是一个.net核心1.1应用程序。
感谢你看起来尖端清洁，但仍刚刚起步[]作为我的结果 –
我编辑的答案，请测试，然后告诉我结果 –
变化的答案，改变SQL查询 –