问题描述
我正在使用 .NET Core 框架 (5.0) 开发质量保证应用程序。最初,我使用了 MS sql Server DB,它运行良好。但是,现在由于需求变化,我现在已经转移到 MysqL Server。
我已经使用代码优先的方法(实体框架)成功地集成了数据库。此外,我正在使用 NuGet 包 Pomelo.EntityFrameworkCore.MysqL 并且一切正常,除了下面提到的 Linq 查询我遇到异常 - 这个 MysqLConnection 已经在使用中强>.
public List<ErrorMessage> GetErrorMessage(int productId)
{
List<ErrorMessage> localList = new List<ErrorMessage>();
var product = _db.Products.Where(a => a.ProductId == productId).FirstOrDefault();
if (product != null)
{
var products = _db.Products
.Where(q => q.ProductName.ToLower() == product.ProductName.ToLower()).Select(e => e.ProductId);
foreach (var item in products)
{
var errormessage = _db.ErrorMessageTracks.Where(q => q.ProductId == item).Select(e => e.ErrorMessage);
foreach (var msg in errormessage)
{
if (!localList.Select(q => q.ErrorMessageId).Contains(msg.ErrorMessageId))
{
localList.Add(msg);
}
}
}
}
return localList;
}
我已经提到了其他类似的问题,但我无法解决这个问题,因为我不知道如何关闭 sql 连接,因为我使用的是 Linq Query 而不是实际的 sql Join。任何帮助将不胜感激!
解决方法
您可以在linq查询的末尾添加ToList()
,应该可以解决问题:
var products = _db.Products.Where(q => q.ProductName.ToLower() == product.ProductName.ToLower())
.Select(e => e.ProductId).ToList();