GroupJoinExpression.cs 2.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. /* Copyright 2015-present MongoDB Inc.
  2. *
  3. * Licensed under the Apache License, Version 2.0 (the "License");
  4. * you may not use this file except in compliance with the License.
  5. * You may obtain a copy of the License at
  6. *
  7. * http://www.apache.org/licenses/LICENSE-2.0
  8. *
  9. * Unless required by applicable law or agreed to in writing, software
  10. * distributed under the License is distributed on an "AS IS" BASIS,
  11. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. * See the License for the specific language governing permissions and
  13. * limitations under the License.
  14. */
  15. using System;
  16. using System.Collections.Generic;
  17. using System.Linq;
  18. using System.Linq.Expressions;
  19. using System.Text;
  20. using System.Threading.Tasks;
  21. using MongoDB.Driver.Core.Misc;
  22. namespace MongoDB.Driver.Linq.Expressions
  23. {
  24. internal sealed class GroupJoinExpression : ExtensionExpression, ISourcedExpression
  25. {
  26. private readonly Type _type;
  27. private readonly Expression _source;
  28. private readonly Expression _joined;
  29. private readonly Expression _sourceKeySelector;
  30. private readonly Expression _joinedKeySelector;
  31. private readonly string _joinedItemName;
  32. public GroupJoinExpression(Type type, Expression source, Expression joined, Expression sourceKeySelector, Expression joinedKeySelector, string joinedItemName)
  33. {
  34. _type = Ensure.IsNotNull(type, nameof(type));
  35. _source = Ensure.IsNotNull(source, nameof(source));
  36. _joined = Ensure.IsNotNull(joined, nameof(joined));
  37. _sourceKeySelector = Ensure.IsNotNull(sourceKeySelector, nameof(sourceKeySelector));
  38. _joinedKeySelector = Ensure.IsNotNull(joinedKeySelector, nameof(joinedKeySelector));
  39. _joinedItemName = Ensure.IsNotNull(joinedItemName, nameof(joinedItemName));
  40. }
  41. public override ExtensionExpressionType ExtensionType => ExtensionExpressionType.GroupJoin;
  42. public Expression Joined => _joined;
  43. public Expression JoinedKeySelector => _joinedKeySelector;
  44. public string JoinedItemName => _joinedItemName;
  45. public Expression Source => _source;
  46. public Expression SourceKeySelector => _sourceKeySelector;
  47. public override Type Type => _type;
  48. protected internal override Expression Accept(ExtensionExpressionVisitor visitor)
  49. {
  50. return visitor.VisitGroupJoin(this);
  51. }
  52. public Expression Update(Expression source, Expression joined, Expression sourceKeySelector, Expression joinedKeySelector)
  53. {
  54. if (source != _source ||
  55. joined != _joined ||
  56. sourceKeySelector != _sourceKeySelector ||
  57. joinedKeySelector != _joinedKeySelector)
  58. {
  59. return new GroupJoinExpression(_type, source, joined, sourceKeySelector, joinedKeySelector, _joinedItemName);
  60. }
  61. return this;
  62. }
  63. }
  64. }