【问题描述】
在对linq2db进行删除操作前,先将需要删除的数据集查询出来,
再调用db.[表对象].delete()方法执行删除操作,代码如下:
using (SqliteDB db = new SqliteDB(connectionString))
{
IQuerable<T> infoList = db.[表对象].where(x => x.attr == condition);
if (infoList != null && infoList.Count() > 0)
{
foreach ([表对象] info in infoList)
{
deleteCount += db.Delete<[表对象]>(info);
}
if (deleteCount != infoList.Count())
{
result = false;
}
}
}
执行结果异常,报错提示如下:
System.InvalidOperationException: Cannot set CommandText while a DataReader is active
【分析原因】
读取操作与更新或删除操作不可以放在同一个数据库会话中
【解决方法】
将查询操作、更新或删除使用独立的数据库会话,代码如下:
IQuerable<T> infoList = null;
using (SqliteDB db = new SqliteDB(connectionString))
{
infoList = db.[表对象].where(x => x.attr == condition);
}
if (infoList != null && infoList.Count() > 0)
{
using (SqliteDB db = new SqliteDB(connectionString))
{
foreach ([表对象] info in infoList)
{
deleteCount += db.Delete<[表对象]>(info);
}
if (deleteCount != infoList.Count())
{
result = false;
}
}
}