Mercurial > pub > bltoolkit
diff Source/Data/Linq/Builder/DeleteBuilder.cs @ 0:f990fcb411a9
Копия текущей версии из github
author | cin |
---|---|
date | Thu, 27 Mar 2014 21:46:09 +0400 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/Source/Data/Linq/Builder/DeleteBuilder.cs Thu Mar 27 21:46:09 2014 +0400 @@ -0,0 +1,99 @@ +using System; +using System.Linq.Expressions; + +namespace BLToolkit.Data.Linq.Builder +{ + using BLToolkit.Linq; + using Data.Sql; + + class DeleteBuilder : MethodCallBuilder + { + protected override bool CanBuildMethodCall(ExpressionBuilder builder, MethodCallExpression methodCall, BuildInfo buildInfo) + { + return methodCall.IsQueryable("Delete"); + } + + protected override IBuildContext BuildMethodCall(ExpressionBuilder builder, MethodCallExpression methodCall, BuildInfo buildInfo) + { + var sequence = builder.BuildSequence(new BuildInfo(buildInfo, methodCall.Arguments[0])); + + if (methodCall.Arguments.Count == 2) + sequence = builder.BuildWhere(buildInfo.Parent, sequence, (LambdaExpression)methodCall.Arguments[1].Unwrap(), false); + + sequence.SqlQuery.QueryType = QueryType.Delete; + + // Check association. + // + var ctx = sequence as SelectContext; + + if (ctx != null && ctx.IsScalar) + { + var res = ctx.IsExpression(null, 0, RequestFor.Association); + + if (res.Result && res.Context is TableBuilder.AssociatedTableContext) + { + var atc = (TableBuilder.AssociatedTableContext)res.Context; + sequence.SqlQuery.Delete.Table = atc.SqlTable; + } + else + { + res = ctx.IsExpression(null, 0, RequestFor.Table); + + if (res.Result && res.Context is TableBuilder.TableContext) + { + var tc = (TableBuilder.TableContext)res.Context; + + if (sequence.SqlQuery.From.Tables.Count == 0 || sequence.SqlQuery.From.Tables[0].Source != tc.SqlQuery) + sequence.SqlQuery.Delete.Table = tc.SqlTable; + } + } + } + + return new DeleteContext(buildInfo.Parent, sequence); + } + + protected override SequenceConvertInfo Convert( + ExpressionBuilder builder, MethodCallExpression methodCall, BuildInfo buildInfo, ParameterExpression param) + { + return null; + } + + class DeleteContext : SequenceContextBase + { + public DeleteContext(IBuildContext parent, IBuildContext sequence) + : base(parent, sequence, null) + { + } + + public override void BuildQuery<T>(Query<T> query, ParameterExpression queryParameter) + { + query.SetNonQueryQuery(); + } + + public override Expression BuildExpression(Expression expression, int level) + { + throw new InvalidOperationException(); + } + + public override SqlInfo[] ConvertToSql(Expression expression, int level, ConvertFlags flags) + { + throw new InvalidOperationException(); + } + + public override SqlInfo[] ConvertToIndex(Expression expression, int level, ConvertFlags flags) + { + throw new InvalidOperationException(); + } + + public override IsExpressionResult IsExpression(Expression expression, int level, RequestFor requestFlag) + { + throw new InvalidOperationException(); + } + + public override IBuildContext GetContext(Expression expression, int level, BuildInfo buildInfo) + { + throw new InvalidOperationException(); + } + } + } +}