Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / Orcas / SP / 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
- EntityContainer.cs
- UInt16Converter.cs
- FilterRepeater.cs
- columnmapfactory.cs
- ClientUtils.cs
- AttributeCollection.cs
- DoubleAnimation.cs
- TextDpi.cs
- InvalidPrinterException.cs
- XmlSequenceWriter.cs
- MembershipPasswordException.cs
- StandardOleMarshalObject.cs
- UndoManager.cs
- StringSource.cs
- ScriptResourceAttribute.cs
- DataGridPagingPage.cs
- PkcsUtils.cs
- LineMetrics.cs
- MD5HashHelper.cs
- MethodCallTranslator.cs
- TextRangeBase.cs
- QuotedPrintableStream.cs
- DetailsView.cs
- WebPartMenu.cs
- ErrorTolerantObjectWriter.cs
- MasterPageBuildProvider.cs
- Visual3D.cs
- StylusPointPropertyId.cs
- SelectiveScrollingGrid.cs
- ImageSourceValueSerializer.cs
- SystemException.cs
- SiteMapPath.cs
- XmlUrlResolver.cs
- TextEditorMouse.cs
- DataKey.cs
- ToolStripProgressBar.cs
- BaseTemplateParser.cs
- AsyncPostBackErrorEventArgs.cs
- ElementInit.cs
- AutoResizedEvent.cs
- PageParserFilter.cs
- GifBitmapEncoder.cs
- IntegerFacetDescriptionElement.cs
- XmlNotation.cs
- AccessControlEntry.cs
- Cursors.cs
- ObjectItemCollectionAssemblyCacheEntry.cs
- AuthenticationConfig.cs
- ProviderConnectionPointCollection.cs
- StyleSheetComponentEditor.cs
- CollectionConverter.cs
- PropertyToken.cs
- DSACryptoServiceProvider.cs
- SystemPens.cs
- ValueUtilsSmi.cs
- ACL.cs
- safesecurityhelperavalon.cs
- DataRelationPropertyDescriptor.cs
- LifetimeServices.cs
- ExtractCollection.cs
- ToolBarButtonDesigner.cs
- DockAndAnchorLayout.cs
- Quaternion.cs
- SQLDateTimeStorage.cs
- EventSetterHandlerConverter.cs
- SystemColorTracker.cs
- LabelEditEvent.cs
- UIElementAutomationPeer.cs
- ResourceCodeDomSerializer.cs
- ErrorFormatterPage.cs
- ErrorTableItemStyle.cs
- HtmlTableRowCollection.cs
- FillErrorEventArgs.cs
- Bezier.cs
- FixedSOMTableRow.cs
- OutputScopeManager.cs
- ListBoxItem.cs
- ResourceAttributes.cs
- DisplayNameAttribute.cs
- CompiledQuery.cs
- SoapReflectionImporter.cs
- PropertyHelper.cs
- LayoutEngine.cs
- TakeOrSkipQueryOperator.cs
- KeyValueInternalCollection.cs
- BamlTreeMap.cs
- RecognizedWordUnit.cs
- Faults.cs
- IdentitySection.cs
- GridItem.cs
- DataServiceProviderMethods.cs
- RequestQueue.cs
- ConcatQueryOperator.cs
- NetPeerTcpBinding.cs
- BrowserDefinition.cs
- CompilerError.cs
- FragmentQueryProcessor.cs
- DataServiceProviderMethods.cs
- DbConnectionHelper.cs
- RawStylusSystemGestureInputReport.cs