我正在尝试使用LINQ执行DELETE,这将生成单个查询。
我是这样做的:
// NorthwintEntities is an ADO.NET Entitity Data Model
var northwindEntities = new NorthwindEntities();
northwindEntities.Order_Details.Delete(o => o.Order_ID == 11076);
这是我的扩展:
public static class EntityExtensions
{
private static Regex rxTableName = new Regex(@"^FROM\s+(?<table>\[[^\]]*\](\.\[[^\]]*\]){0,2})\s+AS\s+(?<alias>\[[^\]]*\])", RegexOptions.Multiline);
public static void Delete<T>(this ObjectSet<T> entity, Expression<Func<T, bool>> expression) where T : EntityObject
{
var selectQuery = entity.Where(expression).Select(x => 1);
string selectQueryString = ((ObjectQuery)selectQuery).ToTraceString();
string deleteQueryString = ConvertSqlSelectToDelete(selectQueryString);
entity.Context.ExecuteStoreCommand(deleteQueryString);
}
private static string ConvertSqlSelectToDelete(string selectQuery)
{
if (selectQuery.IndexOf(" JOIN ") > -1)
{
throw new Exception("Query with JOIN is not supported: " + selectQuery);
}
Match match = rxTableName.Match(selectQuery);
if (!match.Success)
{
throw new Exception("Unable to convert SELECT: " + selectQuery);
}
string deleteQuery = "DELETE \r\n" + selectQuery.Substring(match.Index);
deleteQuery = deleteQuery.Replace(match.Groups["alias"].Value + ".", "");
deleteQuery = deleteQuery.Replace("AS " + match.Groups["alias"].Value, "");
return deleteQuery;
}
}
这有效,但我有一些意见。
- 我不是在这里使用Regex的忠实粉丝,但这是我获得表名的唯一方法。 (entity.EntitySet.Name并不总是返回正确的名称。[Order Details]是一个例子)。
- 完成此操作后,我发现了这一点 http://msmvps.com/blogs/matthieu/archive/2010/05/21/bulk-delete-v3.aspx 但无论如何都无法让它发挥作用。保持从上下文中获取NotImplementedException为null。
- 使用连接删除似乎不起作用。我正在使用SQL Server Compact 3.5进行测试,也许这是一个限制。
所以我的问题是:有更简单的方法吗?如果是这样,它是什么?
任何帮助都将不胜感激。