Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / Orcas / NetFXw7 / ndp / fx / src / DLinq / Dlinq / SqlClient / Query / SqlLiftIndependentRowExpressions.cs / 1 / 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
- FontFaceLayoutInfo.cs
- UIElementAutomationPeer.cs
- DrawToolTipEventArgs.cs
- DataGridPageChangedEventArgs.cs
- ServiceReference.cs
- XmlElementCollection.cs
- SqlConnectionFactory.cs
- TextClipboardData.cs
- ChannelBuilder.cs
- HttpException.cs
- XmlCharCheckingReader.cs
- SafeLibraryHandle.cs
- CreateUserWizardStep.cs
- Typeface.cs
- SolidBrush.cs
- SoapExtensionStream.cs
- CommandHelper.cs
- DataGridViewComboBoxColumn.cs
- PathGeometry.cs
- ProgressChangedEventArgs.cs
- ReferenceEqualityComparer.cs
- ButtonBase.cs
- OutputWindow.cs
- FileNotFoundException.cs
- Activation.cs
- ScriptResourceHandler.cs
- KnownTypes.cs
- Int32AnimationBase.cs
- BitVector32.cs
- ContentControl.cs
- ReferenceEqualityComparer.cs
- PropertyReference.cs
- AbandonedMutexException.cs
- XmlUtil.cs
- XmlMessageFormatter.cs
- MarkupExtensionParser.cs
- SessionEndedEventArgs.cs
- VScrollBar.cs
- JsonQueryStringConverter.cs
- Base64Encoder.cs
- ObjectTypeMapping.cs
- MsmqIntegrationAppDomainProtocolHandler.cs
- ColumnTypeConverter.cs
- HttpListenerRequest.cs
- PagerSettings.cs
- WebBrowserSiteBase.cs
- HtmlDocument.cs
- RSAProtectedConfigurationProvider.cs
- Html32TextWriter.cs
- SqlConnectionManager.cs
- IndicShape.cs
- PackagingUtilities.cs
- CommandID.cs
- WorkflowCommandExtensionItem.cs
- Hex.cs
- X509ChainElement.cs
- RuntimeCompatibilityAttribute.cs
- WizardForm.cs
- ScrollBar.cs
- GenerateScriptTypeAttribute.cs
- CompilerCollection.cs
- ComponentResourceKey.cs
- GridPatternIdentifiers.cs
- FontDriver.cs
- Rectangle.cs
- PermissionSet.cs
- ObjectHelper.cs
- PageBreakRecord.cs
- ProtocolsConfigurationEntry.cs
- PropertyToken.cs
- InternalBufferOverflowException.cs
- VariantWrapper.cs
- Brush.cs
- SimpleApplicationHost.cs
- ToolStripDropDownMenu.cs
- AssemblyInfo.cs
- MultiViewDesigner.cs
- CorruptStoreException.cs
- Events.cs
- AmbiguousMatchException.cs
- ListBindingConverter.cs
- GroupItemAutomationPeer.cs
- XmlComplianceUtil.cs
- NameValueSectionHandler.cs
- SafePipeHandle.cs
- Crypto.cs
- LocationUpdates.cs
- BitSet.cs
- MsmqInputMessage.cs
- DocumentApplicationDocumentViewer.cs
- XmlIterators.cs
- EDesignUtil.cs
- EdmProperty.cs
- MappingMetadataHelper.cs
- Util.cs
- MaskedTextBoxDesigner.cs
- EntityDataSourceDesigner.cs
- RichTextBox.cs
- LinqDataSourceUpdateEventArgs.cs
- SecurityDocument.cs