Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / DLinq / Dlinq / SqlClient / Query / SqlLiftIndependentRowExpressions.cs / 1305376 / 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.
Link Menu
![Network programming in C#, Network Programming in VB.NET, Network Programming in .NET](/images/book.jpg)
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- NativeMethods.cs
- FileLevelControlBuilderAttribute.cs
- KeyGestureValueSerializer.cs
- DetailsViewInsertEventArgs.cs
- UrlPath.cs
- OleDbTransaction.cs
- DataSourceCache.cs
- SqlFormatter.cs
- DataGridDefaultColumnWidthTypeConverter.cs
- MSAANativeProvider.cs
- LicFileLicenseProvider.cs
- ModelMemberCollection.cs
- RepeatBehavior.cs
- ListItemCollection.cs
- DesignSurface.cs
- BehaviorEditorPart.cs
- configsystem.cs
- PerformanceCounter.cs
- URI.cs
- LicenseManager.cs
- ScrollEvent.cs
- BuildResultCache.cs
- CopyNamespacesAction.cs
- PersonalizationEntry.cs
- WindowsRichEditRange.cs
- BulletedListEventArgs.cs
- OrderToken.cs
- ResponseBodyWriter.cs
- WS2007HttpBindingElement.cs
- SQLInt64Storage.cs
- ProtectedConfigurationSection.cs
- DecoratedNameAttribute.cs
- SettingsSection.cs
- CounterSample.cs
- SmtpCommands.cs
- DictionaryEntry.cs
- WebPartAuthorizationEventArgs.cs
- CodeStatement.cs
- BinaryQueryOperator.cs
- PropertyItemInternal.cs
- ZipIOZip64EndOfCentralDirectoryLocatorBlock.cs
- FixUp.cs
- NetworkInformationPermission.cs
- HotSpotCollection.cs
- OptimalBreakSession.cs
- DataGridViewCellCollection.cs
- ButtonField.cs
- TableItemPattern.cs
- TaskSchedulerException.cs
- MemberRelationshipService.cs
- Storyboard.cs
- XmlObjectSerializerReadContextComplex.cs
- Splitter.cs
- AesCryptoServiceProvider.cs
- SoapSchemaImporter.cs
- SwitchAttribute.cs
- OracleSqlParser.cs
- MissingFieldException.cs
- QueryCacheKey.cs
- TemplateDefinition.cs
- FixedSOMLineRanges.cs
- ViewStateException.cs
- SystemThemeKey.cs
- DataGridRow.cs
- WindowsEditBoxRange.cs
- ButtonChrome.cs
- HttpCapabilitiesBase.cs
- ClrProviderManifest.cs
- CodeSnippetStatement.cs
- QuaternionValueSerializer.cs
- NamedElement.cs
- DynamicILGenerator.cs
- IgnorePropertiesAttribute.cs
- FreezableCollection.cs
- CellTreeNodeVisitors.cs
- ComponentCollection.cs
- Pair.cs
- EpmContentDeSerializerBase.cs
- RegexWriter.cs
- SynchronizedCollection.cs
- WebException.cs
- SqlBinder.cs
- XamlTypeWithExplicitNamespace.cs
- CodeConditionStatement.cs
- DataKey.cs
- SharedStatics.cs
- Scene3D.cs
- WebPartEditorOkVerb.cs
- HtmlProps.cs
- ExtendedPropertyCollection.cs
- NameGenerator.cs
- MemoryStream.cs
- PriorityChain.cs
- TreeNodeSelectionProcessor.cs
- AmbientValueAttribute.cs
- UnregisterInfo.cs
- XmlMapping.cs
- CodeComment.cs
- CodeArgumentReferenceExpression.cs
- OutputCacheSettingsSection.cs