OUTER JOIN未在EF Core中返回预期结果
本文关键字：返回 结果 Core JOIN 未在 EF OUTER | 更新日期: 2023-09-27 18:07:04
在我的ASP.NET MVC Core应用程序中，POST操作方法Test没有返回预期的结果。该web应用程序是使用此官方ASP.NET Core网站创建的，并进行了轻微修改。真正的应用程序可以从这里下载，并且使用最新版本的VS2015。该应用程序正在使用EF Core。如果你下载了这个项目，你将需要做以下步骤来测试以上意想不到的结果：
注意：这些步骤的顺序很重要。这是一个非常小的测试项目。步骤2将创建一个名为ASPCore_Blogs的小型SQL Server Db。因此，请确保SQL Server正在运行：
- 下载项目后，在VS2015中打开项目之前，请确保从项目目录中删除
.vs文件夹(如果项目挂起，您可能必须使用windows操作系统的Task Manager强制关闭它，然后重新打开它才能工作。这是VS2015中的已知问题( - 打开
startup.cs文件，并在Configuration((方法中将数据库实例名称从MyComputer'SQLServerInstance更改为您正在使用的任何实例。在根目录中的appsettings.json文件中执行相同操作 - 在VS2015 PM窗口中，运行PM>更新数据库上下文BloggingContext[确保SQL Server正在运行]
- 然后运行：PM>更新数据库上下文ApplicationDbContext
-
运行web应用程序。通过输入登录/密码信息进行注册。登录需要在电子邮件中(test@test.com)在主页左侧：
-
点击链接
Blog Create创建4个博客，如下所示：Blog1@test.com，Blog2@test.com，Blog3@test.com，Blog4@test.com - 点击链接
Blogs Index验证以上4个博客是否全部创建 - 单击
Test链接。此视图由GET操作方法Test调用。在相应的视图(Test.cshtml(上，您将看到页面上的Url列显示了上述所有4个博客。CCD_ 17和CCD_ 18列为空白。将Title列填充为：标题1、标题2、标题3、标题4。将Content列填充为：Content1、Content2、Content3、Content4 - 现在，转到相应的名为
ASPCore_BlogsNAxis的SQL Server数据库，以Edit模式打开Posts表，手动将PostYear列的值分别更改为：19981999199882001(注意：1998是故意重复的( - 现在，转到同一SQL Server数据库中的
Blogs表，并输入一个额外的博客Blog5@test.com - 现在，运行web应用程序并再次单击
Test链接(位于主页左侧(。您将看到Get操作方法Test使用左外部联接来显示所有5个博客，但右侧列(Title和Content(的值在第5行中为空，正如预期的那样，因为左外部联接不满足第5个博客的BlogId上的联接条件。到目前为止还不错 - 现在，在
Test.cshtml视图的Year下拉列表中，选择年份为1998，然后单击GO按钮。根据POST操作方法Test的第一个if条件，应用程序应该只显示三条记录(两条用于1998，第五条不满足联接条件(：第一条、第三条和第五条记录
但事实并非如此。当您从下拉列表中选择不同年份并单击GO按钮重复此操作时，您会看到输出与预期不一样。
示例数据：
博客表数据:
BlogId Url
1 test1.com
2 test2.com
3 test3.com
4 test4.com
5 test5.com
发布表数据：
PostId BlogId Content PostYear Title
1 1 Content1 1998 Title1
2 2 Content2 1999 Title2
3 3 Content3 1998 Title3
4 4 Content4 2001 Title4
Test中的LEFT外部JOIN操作GET方法应返回:
BlogId Url PostId Content PostYear Title
1 test1.com 1 Content1 1998 Title1
2 test2.com 2 Content2 1999 Title2
3 test3.com 3 Content3 1998 Title3
4 test4.com 4 Content4 2001 Title4
5 test5.com NULL NULL NULL NULL
当您在下拉列表中选择1998年并单击Go按钮时，Test(…(Post action方法查询应返回但它随机返回任何行：
BlogId Url PostId Content PostYear Title
1 test1.com 1 Content1 1998 Title1
3 test3com 3 Content2 1998 Title3
5 test5.com NULL NULL NULL NULL
型号：
public class BloggingContext : DbContext
{
public BloggingContext(DbContextOptions<BloggingContext> options)
: base(options)
{ }
public DbSet<Blog> Blogs { get; set; }
public DbSet<Post> Posts { get; set; }
}
public class Blog
{
public int BlogId { get; set; }
public string Url { get; set; }
public List<Post> Posts { get; set; }
}
public class Post
{
public int PostId { get; set; }
public string Title { get; set; }
public string Content { get; set; }
public int PostYear { get; set; }
public int BlogId { get; set; }
public Blog Blog { get; set; }
}
BlogsController:
public class BlogsController : Controller
{
private readonly BloggingContext _context;
public BlogsController(BloggingContext context)
{
_context = context;
}
// GET: Blogs
public async Task<IActionResult> Index()
{
return View(_context.Blogs.ToList());
}
// GET: /Blogs/Test
[HttpGet]
public async Task<IActionResult> Test(string returnUrl = null)
{
ViewData["ReturnUrl"] = returnUrl;
ViewBag.YearsList = Enumerable.Range(1996, 29).Select(g => new SelectListItem { Value = g.ToString(), Text = g.ToString() }).ToList();
//return View(await _context.Blogs.Include(p => p.Posts).ToListAsync());
var qrVM = from b in _context.Blogs
join p in _context.Posts on b.BlogId equals p.BlogId into bp
from c in bp.DefaultIfEmpty()
select new BlogsWithRelatedPostsViewModel { BlogID = b.BlogId, PostID = (c == null ? 0 : c.PostId), Url = b.Url, Title = (c == null ? string.Empty : c.Title), Content = (c == null ? string.Empty : c.Content) };
return View(await qrVM.ToListAsync());
}
// POST: /Blogs/Test
[HttpPost]
[ValidateAntiForgeryToken]
public async Task<IActionResult> Test(List<BlogsWithRelatedPostsViewModel> list, string GO, int currentlySelectedIndex, string returnUrl = null)
{
ViewData["ReturnUrl"] = returnUrl;
ViewBag.YearsList = Enumerable.Range(1996, 29).Select(g => new SelectListItem { Value = g.ToString(), Text = g.ToString() }).ToList();
if (!string.IsNullOrEmpty(GO))
{
var qrVM = from b in _context.Blogs
join p in _context.Posts on b.BlogId equals p.BlogId into bp
from c in bp.DefaultIfEmpty()
where c == null? true : c.PostYear.Equals(currentlySelectedIndex)
select new BlogsWithRelatedPostsViewModel { BlogID = b.BlogId, PostID = (c == null ? 0 : c.PostId), Url = b.Url, Title = (c == null ? string.Empty : c.Title), Content = (c == null ? string.Empty : c.Content) };
return View(await qrVM.ToListAsync());
}
else if (ModelState.IsValid)
{
foreach (var item in list)
{
var oPost = _context.Posts.Where(r => r.PostId.Equals(item.PostID)).FirstOrDefault();
if (oPost != null)
{
oPost.Title = item.Title;
oPost.Content = item.Content;
oPost.PostYear = currentlySelectedIndex;
oPost.BlogId = item.BlogID; //according to new post below the blogId should exist for a newly created port - but just in case
}
else
{
if (item.PostID == 0)
{
Post oPostNew = new Post { BlogId = item.BlogID, Title = item.Title, Content = item.Content, PostYear = currentlySelectedIndex }; //need to use currentlySelectedIndex intead of item.FiscalYear in case of adding a record
_context.Add(oPostNew);
}
}
}
await _context.SaveChangesAsync();
//return RedirectToLocal(returnUrl);
return View(list);
}
// If we got this far, something failed, redisplay form
return View();
}
// GET: Blogs/Details/5
public async Task<IActionResult> Details(int? id)
{
if (id == null)
{
return NotFound();
}
var blog = await _context.Blogs.SingleOrDefaultAsync(m => m.BlogId == id);
if (blog == null)
{
return NotFound();
}
return View(blog);
}
// GET: Blogs/Create
[HttpGet]
public IActionResult Create()
{
return View();
}
// POST: Blogs/Create
// To protect from overposting attacks, please enable the specific properties you want to bind to, for
// more details see http://go.microsoft.com/fwlink/?LinkId=317598.
[HttpPost]
[ValidateAntiForgeryToken]
public async Task<IActionResult> Create([Bind("BlogId,Url")] Blog blog)
{
if (ModelState.IsValid)
{
_context.Blogs.Add(blog);
await _context.SaveChangesAsync();
return RedirectToAction("Index");
}
return View(blog);
}
// GET: Blogs/Edit/5
public async Task<IActionResult> Edit(int? id)
{
if (id == null)
{
return NotFound();
}
var blog = await _context.Blogs.SingleOrDefaultAsync(m => m.BlogId == id);
if (blog == null)
{
return NotFound();
}
return View(blog);
}
// POST: Blogs/Edit/5
// To protect from overposting attacks, please enable the specific properties you want to bind to, for
// more details see http://go.microsoft.com/fwlink/?LinkId=317598.
[HttpPost]
[ValidateAntiForgeryToken]
public async Task<IActionResult> Edit(int id, [Bind("BlogId,Url")] Blog blog)
{
if (id != blog.BlogId)
{
return NotFound();
}
if (ModelState.IsValid)
{
try
{
_context.Update(blog);
await _context.SaveChangesAsync();
}
catch (DbUpdateConcurrencyException)
{
if (!BlogExists(blog.BlogId))
{
return NotFound();
}
else
{
throw;
}
}
return RedirectToAction("Index");
}
return View(blog);
}
// GET: Blogs/Delete/5
public async Task<IActionResult> Delete(int? id)
{
if (id == null)
{
return NotFound();
}
var blog = await _context.Blogs.SingleOrDefaultAsync(m => m.BlogId == id);
if (blog == null)
{
return NotFound();
}
return View(blog);
}
// POST: Blogs/Delete/5
[HttpPost, ActionName("Delete")]
[ValidateAntiForgeryToken]
public async Task<IActionResult> DeleteConfirmed(int id)
{
var blog = await _context.Blogs.SingleOrDefaultAsync(m => m.BlogId == id);
_context.Blogs.Remove(blog);
await _context.SaveChangesAsync();
return RedirectToAction("Index");
}
private bool BlogExists(int id)
{
return _context.Blogs.Any(e => e.BlogId == id);
}
}
更新：
- 添加了步骤2，要求用户更改连接字符串
- 从bp中删除了新的Post((。
Test()的GET/Post操作方法中的DefaultIfEmpty(new Post(((。但同样的错误仍然存在
在linq查询中，在这里执行DefaultIfEmtpy调用：
from c in bp.DefaultIfEmpty(new Post())
where c == null? true : c.PostYear.Equals(currentlySelectedIndex)
您使用了重载，其中DefaultIfEmtpy将在new Post()实例为空时返回该实例，而不是返回null。但是您的逻辑期望它返回null。将狙击手的第一行替换为返回null的过载：
from c in bp.DefaultIfEmpty()