Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / Orcas / QFE / ndp / fx / src / DLinq / Dlinq / SqlClient / Query / SqlLiftIndependentRowExpressions.cs / 2 / SqlLiftIndependentRowExpressions.cs
using System; using System.Collections.Generic; using System.Text; using System.Diagnostics.CodeAnalysis; namespace System.Data.Linq.SqlClient { ////// Find projection expressions on the right side of CROSS APPLY that do not /// depend exclusively on right side productions and move them outside of the /// CROSS APPLY by enclosing the CROSS APPLY with a new source. /// class SqlLiftIndependentRowExpressions { internal static SqlNode Lift(SqlNode node) { ColumnLifter cl = new ColumnLifter(); node = cl.Visit(node); return node; } private class ColumnLifter : SqlVisitor { SelectScope expressionSink; SqlAggregateChecker aggregateChecker; internal ColumnLifter() { this.aggregateChecker = new SqlAggregateChecker(); } class SelectScope { // Stack of projections lifted from the right to be pushed on the left. internal Stack> Lifted = new Stack
>(); internal IEnumerable
LeftProduction; internal HashSet ReferencedExpressions = new HashSet (); } internal override SqlSelect VisitSelect(SqlSelect select) { SelectScope s = expressionSink; // Don't lift through a TOP. if (select.Top != null) { expressionSink = null; } // Don't lift through a GROUP BY (or implicit GROUP BY). if (select.GroupBy.Count > 0 || this.aggregateChecker.HasAggregates(select)) { expressionSink = null; } // Don't lift through DISTINCT if (select.IsDistinct) { expressionSink = null; } if (expressionSink != null) { List keep = new List (); List lift = new List (); foreach (SqlColumn sc in select.Row.Columns) { bool referencesLeftsideAliases = SqlAliasesReferenced.ReferencesAny(sc.Expression, expressionSink.LeftProduction); bool isLockedExpression = expressionSink.ReferencedExpressions.Contains(sc); if (referencesLeftsideAliases && !isLockedExpression) { lift.Add(sc); } else { keep.Add(sc); } } select.Row.Columns.Clear(); select.Row.Columns.AddRange(keep); if (lift.Count > 0) { expressionSink.Lifted.Push(lift); } } SqlSelect sel = base.VisitSelect(select); expressionSink = s; return sel; } internal override SqlExpression VisitColumnRef(SqlColumnRef cref) { if (expressionSink!=null) { expressionSink.ReferencedExpressions.Add(cref.Column); } return cref; } internal override SqlSource VisitJoin(SqlJoin join) { if (join.JoinType == SqlJoinType.CrossApply) { // Visit the left side as usual. join.Left = this.VisitSource(join.Left); // Visit the condition as usual. join.Condition = this.VisitExpression(join.Condition); // Visit the right, with the expressionSink set. SelectScope s = expressionSink; expressionSink = new SelectScope(); expressionSink.LeftProduction = SqlGatherProducedAliases.Gather(join.Left); join.Right = this.VisitSource(join.Right); // Were liftable expressions found? SqlSource newSource = join; foreach (List cols in expressionSink.Lifted) { newSource = PushSourceDown(newSource, cols); } expressionSink = s; return newSource; } return base.VisitJoin(join); } [SuppressMessage("Microsoft.Performance", "CA1822:MarkMembersAsStatic", Justification="Unknown reason.")] private SqlSource PushSourceDown(SqlSource sqlSource, List cols) { SqlSelect ns = new SqlSelect(new SqlNop(cols[0].ClrType, cols[0].SqlType, sqlSource.SourceExpression), sqlSource, sqlSource.SourceExpression); ns.Row.Columns.AddRange(cols); return new SqlAlias(ns); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. using System; using System.Collections.Generic; using System.Text; using System.Diagnostics.CodeAnalysis; namespace System.Data.Linq.SqlClient { /// /// Find projection expressions on the right side of CROSS APPLY that do not /// depend exclusively on right side productions and move them outside of the /// CROSS APPLY by enclosing the CROSS APPLY with a new source. /// class SqlLiftIndependentRowExpressions { internal static SqlNode Lift(SqlNode node) { ColumnLifter cl = new ColumnLifter(); node = cl.Visit(node); return node; } private class ColumnLifter : SqlVisitor { SelectScope expressionSink; SqlAggregateChecker aggregateChecker; internal ColumnLifter() { this.aggregateChecker = new SqlAggregateChecker(); } class SelectScope { // Stack of projections lifted from the right to be pushed on the left. internal Stack> Lifted = new Stack
>(); internal IEnumerable
LeftProduction; internal HashSet ReferencedExpressions = new HashSet (); } internal override SqlSelect VisitSelect(SqlSelect select) { SelectScope s = expressionSink; // Don't lift through a TOP. if (select.Top != null) { expressionSink = null; } // Don't lift through a GROUP BY (or implicit GROUP BY). if (select.GroupBy.Count > 0 || this.aggregateChecker.HasAggregates(select)) { expressionSink = null; } // Don't lift through DISTINCT if (select.IsDistinct) { expressionSink = null; } if (expressionSink != null) { List keep = new List (); List lift = new List (); foreach (SqlColumn sc in select.Row.Columns) { bool referencesLeftsideAliases = SqlAliasesReferenced.ReferencesAny(sc.Expression, expressionSink.LeftProduction); bool isLockedExpression = expressionSink.ReferencedExpressions.Contains(sc); if (referencesLeftsideAliases && !isLockedExpression) { lift.Add(sc); } else { keep.Add(sc); } } select.Row.Columns.Clear(); select.Row.Columns.AddRange(keep); if (lift.Count > 0) { expressionSink.Lifted.Push(lift); } } SqlSelect sel = base.VisitSelect(select); expressionSink = s; return sel; } internal override SqlExpression VisitColumnRef(SqlColumnRef cref) { if (expressionSink!=null) { expressionSink.ReferencedExpressions.Add(cref.Column); } return cref; } internal override SqlSource VisitJoin(SqlJoin join) { if (join.JoinType == SqlJoinType.CrossApply) { // Visit the left side as usual. join.Left = this.VisitSource(join.Left); // Visit the condition as usual. join.Condition = this.VisitExpression(join.Condition); // Visit the right, with the expressionSink set. SelectScope s = expressionSink; expressionSink = new SelectScope(); expressionSink.LeftProduction = SqlGatherProducedAliases.Gather(join.Left); join.Right = this.VisitSource(join.Right); // Were liftable expressions found? SqlSource newSource = join; foreach (List cols in expressionSink.Lifted) { newSource = PushSourceDown(newSource, cols); } expressionSink = s; return newSource; } return base.VisitJoin(join); } [SuppressMessage("Microsoft.Performance", "CA1822:MarkMembersAsStatic", Justification="Unknown reason.")] private SqlSource PushSourceDown(SqlSource sqlSource, List cols) { SqlSelect ns = new SqlSelect(new SqlNop(cols[0].ClrType, cols[0].SqlType, sqlSource.SourceExpression), sqlSource, sqlSource.SourceExpression); ns.Row.Columns.AddRange(cols); return new SqlAlias(ns); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Executor.cs
- BaseProcessor.cs
- PropertyPath.cs
- FileEnumerator.cs
- Repeater.cs
- DateTimeFormatInfoScanner.cs
- HotSpotCollectionEditor.cs
- ConfigurationValidatorAttribute.cs
- SourceFileBuildProvider.cs
- RequestBringIntoViewEventArgs.cs
- ReachPageContentCollectionSerializerAsync.cs
- ScriptIgnoreAttribute.cs
- OracleInternalConnection.cs
- ColumnCollection.cs
- SectionInformation.cs
- ColumnCollection.cs
- SharedStatics.cs
- OutputCacheSettingsSection.cs
- HttpBrowserCapabilitiesWrapper.cs
- SHA512Managed.cs
- FlowDocumentPage.cs
- ColumnResult.cs
- DeviceSpecificDialogCachedState.cs
- AddInIpcChannel.cs
- EditorPartDesigner.cs
- StylusCollection.cs
- TimelineCollection.cs
- FlowDocumentPaginator.cs
- OperatingSystem.cs
- DataGridViewColumnStateChangedEventArgs.cs
- XamlContextStack.cs
- BitmapEffectGeneralTransform.cs
- FirstMatchCodeGroup.cs
- NamedPermissionSet.cs
- VisualStyleElement.cs
- DateTimeSerializationSection.cs
- ExpandableObjectConverter.cs
- HttpHandlerAction.cs
- TextBoxRenderer.cs
- SessionEndedEventArgs.cs
- PaperSource.cs
- DoubleCollection.cs
- MexBindingBindingCollectionElement.cs
- Subtree.cs
- FigureParaClient.cs
- QilExpression.cs
- PasswordPropertyTextAttribute.cs
- MobileDeviceCapabilitiesSectionHandler.cs
- TableCell.cs
- SubstitutionList.cs
- AngleUtil.cs
- FrameworkContentElement.cs
- WindowsGraphics.cs
- TextContainerChangedEventArgs.cs
- WorkflowViewElement.cs
- PinnedBufferMemoryStream.cs
- ImpersonateTokenRef.cs
- WebPartCatalogCloseVerb.cs
- AudioDeviceOut.cs
- DateTimeFormatInfoScanner.cs
- ArraySet.cs
- PublishLicense.cs
- ListViewContainer.cs
- ColorBlend.cs
- MimeXmlImporter.cs
- PointCollectionConverter.cs
- MexTcpBindingElement.cs
- LayoutSettings.cs
- SchemaEntity.cs
- Timeline.cs
- ContextMenuStrip.cs
- JsonXmlDataContract.cs
- InputMethodStateTypeInfo.cs
- SystemTcpStatistics.cs
- BinaryMessageFormatter.cs
- HttpApplicationFactory.cs
- ValueExpressions.cs
- BindingContext.cs
- BreakSafeBase.cs
- ObjectCloneHelper.cs
- PartialCachingControl.cs
- _UriSyntax.cs
- TagPrefixAttribute.cs
- ApplicationServiceManager.cs
- NullableFloatSumAggregationOperator.cs
- ValidatorUtils.cs
- ColorConverter.cs
- TextFindEngine.cs
- LinearKeyFrames.cs
- ChtmlSelectionListAdapter.cs
- PtsContext.cs
- XmlIgnoreAttribute.cs
- Html32TextWriter.cs
- TreeViewTemplateSelector.cs
- SqlComparer.cs
- DashStyle.cs
- WebConfigurationManager.cs
- CodePrimitiveExpression.cs
- EllipseGeometry.cs