Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / DataEntity / System / Data / Common / CommandTrees / Internal / ExpressionCopier.cs / 1305376 / ExpressionCopier.cs
//----------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//
// @owner [....]
// @backupOwner [....]
//---------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Data.Metadata.Edm;
using System.Data.Common.CommandTrees;
using System.Data.Common.CommandTrees.ExpressionBuilder;
using System.Diagnostics;
using System.Globalization;
using System.Linq;
using System.Data.Common.EntitySql;
namespace System.Data.Common.CommandTrees.Internal
{
///
/// Ensures that all metadata in a given expression tree is from the specified metadata workspace,
/// potentially rebinding and rebuilding the expressions to appropriate replacement metadata where necessary.
///
internal class DbExpressionRebinder : DefaultExpressionVisitor
{
private readonly MetadataWorkspace _metadata;
private readonly Perspective _perspective;
protected DbExpressionRebinder(MetadataWorkspace targetWorkspace)
{
Debug.Assert(targetWorkspace != null, "Metadata workspace is null");
_metadata = targetWorkspace;
_perspective = new ModelPerspective(targetWorkspace);
}
//
[System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Performance", "CA1811:AvoidUncalledPrivateCode")]
internal static DbExpression BindToWorkspace(DbExpression expression, MetadataWorkspace targetWorkspace)
{
Debug.Assert(expression != null, "expression is null");
DbExpressionRebinder copier = new DbExpressionRebinder(targetWorkspace);
return copier.VisitExpression(expression);
}
protected override EntitySetBase VisitEntitySet(EntitySetBase entitySet)
{
EntityContainer container;
if (_metadata.TryGetEntityContainer(entitySet.EntityContainer.Name, entitySet.EntityContainer.DataSpace, out container))
{
EntitySetBase extent = null;
if (container.BaseEntitySets.TryGetValue(entitySet.Name, false, out extent) &&
extent != null &&
entitySet.BuiltInTypeKind == extent.BuiltInTypeKind) // EntitySet -> EntitySet, AssociationSet -> AssociationSet, etc
{
return extent;
}
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_EntitySetNotFound(entitySet.EntityContainer.Name, entitySet.Name));
}
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_EntityContainerNotFound(entitySet.EntityContainer.Name));
}
protected override EdmFunction VisitFunction(EdmFunction function)
{
List argumentTypes = new List(function.Parameters.Count);
foreach (FunctionParameter funcParam in function.Parameters)
{
TypeUsage mappedParamType = this.VisitTypeUsage(funcParam.TypeUsage);
argumentTypes.Add(mappedParamType);
}
if (DataSpace.SSpace == function.DataSpace)
{
EdmFunction foundFunc = null;
if (_metadata.TryGetFunction(function.Name,
function.NamespaceName,
argumentTypes.ToArray(),
false /* ignoreCase */,
function.DataSpace,
out foundFunc) &&
foundFunc != null)
{
return foundFunc;
}
}
else
{
// find the function
IList candidateFunctions;
if (_perspective.TryGetFunctionByName(function.FullName, /*ignoreCase:*/ false, out candidateFunctions))
{
Debug.Assert(null != candidateFunctions && candidateFunctions.Count > 0, "Perspective.TryGetFunctionByName returned true with null/empty function result list");
bool isAmbiguous;
EdmFunction retFunc = FunctionOverloadResolver.ResolveFunctionOverloads(candidateFunctions, argumentTypes, /*isGroupAggregateFunction:*/ false, out isAmbiguous);
if (!isAmbiguous &&
retFunc != null)
{
return retFunc;
}
}
}
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_FunctionNotFound(TypeHelpers.GetFullName(function)));
}
protected override EdmType VisitType(EdmType type)
{
EdmType retType = type;
if (BuiltInTypeKind.RefType == type.BuiltInTypeKind)
{
RefType refType = (RefType)type;
EntityType mappedEntityType = (EntityType)this.VisitType(refType.ElementType);
if (!object.ReferenceEquals(refType.ElementType, mappedEntityType))
{
retType = new RefType(mappedEntityType);
}
}
else if (BuiltInTypeKind.CollectionType == type.BuiltInTypeKind)
{
CollectionType collectionType = (CollectionType)type;
TypeUsage mappedElementType = this.VisitTypeUsage(collectionType.TypeUsage);
if (!object.ReferenceEquals(collectionType.TypeUsage, mappedElementType))
{
retType = new CollectionType(mappedElementType);
}
}
else if (BuiltInTypeKind.RowType == type.BuiltInTypeKind)
{
RowType rowType = (RowType)type;
List> mappedPropInfo = null;
for (int idx = 0; idx < rowType.Properties.Count; idx++)
{
EdmProperty originalProp = rowType.Properties[idx];
TypeUsage mappedPropType = this.VisitTypeUsage(originalProp.TypeUsage);
if (!object.ReferenceEquals(originalProp.TypeUsage, mappedPropType))
{
if (mappedPropInfo == null)
{
mappedPropInfo = new List>(
rowType.Properties.Select(
prop => new KeyValuePair(prop.Name, prop.TypeUsage)
));
}
mappedPropInfo[idx] = new KeyValuePair(originalProp.Name, mappedPropType);
}
}
if (mappedPropInfo != null)
{
IEnumerable mappedProps = mappedPropInfo.Select(propInfo => new EdmProperty(propInfo.Key, propInfo.Value));
retType = new RowType(mappedProps, rowType.InitializerMetadata);
}
}
else
{
if (!_metadata.TryGetType(type.Name, type.NamespaceName, type.DataSpace, out retType) ||
null == retType)
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_TypeNotFound(TypeHelpers.GetFullName(type)));
}
}
return retType;
}
protected override TypeUsage VisitTypeUsage(TypeUsage type)
{
//
// If the target metatadata workspace contains the same type instances, then the type does not
// need to be 'mapped' and the same TypeUsage instance may be returned. This can happen if the
// target workspace and the workspace of the source Command Tree are using the same ItemCollection.
//
EdmType retEdmType = this.VisitType(type.EdmType);
if (object.ReferenceEquals(retEdmType, type.EdmType))
{
return type;
}
//
// Retrieve the Facets from this type usage so that
// 1) They can be used to map the type if it is a primitive type
// 2) They can be applied to the new type usage that references the mapped type
//
Facet[] facets = new Facet[type.Facets.Count];
int idx = 0;
foreach (Facet f in type.Facets)
{
facets[idx] = f;
idx++;
}
return TypeUsage.Create(retEdmType, facets);
}
private bool TryGetMember(DbExpression instance, string memberName, out TMember member) where TMember : EdmMember
{
member = null;
StructuralType declType = instance.ResultType.EdmType as StructuralType;
if (declType != null)
{
EdmMember foundMember = null;
if (declType.Members.TryGetValue(memberName, false, out foundMember))
{
member = foundMember as TMember;
}
}
return (member != null);
}
public override DbExpression Visit(DbPropertyExpression expression)
{
EntityUtil.CheckArgumentNull(expression, "expression");
DbExpression result = expression;
DbExpression newInstance = this.VisitExpression(expression.Instance);
if (!object.ReferenceEquals(expression.Instance, newInstance))
{
if (Helper.IsRelationshipEndMember(expression.Property))
{
RelationshipEndMember endMember;
if(!TryGetMember(newInstance, expression.Property.Name, out endMember))
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_EndNotFound(expression.Property.Name, TypeHelpers.GetFullName(newInstance.ResultType.EdmType)));
}
result = DbExpressionBuilder.Property(newInstance, endMember);
}
else if (Helper.IsNavigationProperty(expression.Property))
{
NavigationProperty navProp;
if (!TryGetMember(newInstance, expression.Property.Name, out navProp))
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_NavPropertyNotFound(expression.Property.Name, TypeHelpers.GetFullName(newInstance.ResultType.EdmType)));
}
result = DbExpressionBuilder.Property(newInstance, navProp);
}
else
{
EdmProperty prop;
if (!TryGetMember(newInstance, expression.Property.Name, out prop))
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_PropertyNotFound(expression.Property.Name, TypeHelpers.GetFullName(newInstance.ResultType.EdmType)));
}
result = DbExpressionBuilder.Property(newInstance, prop);
}
}
return result;
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
//----------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//
// @owner [....]
// @backupOwner [....]
//---------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Data.Metadata.Edm;
using System.Data.Common.CommandTrees;
using System.Data.Common.CommandTrees.ExpressionBuilder;
using System.Diagnostics;
using System.Globalization;
using System.Linq;
using System.Data.Common.EntitySql;
namespace System.Data.Common.CommandTrees.Internal
{
///
/// Ensures that all metadata in a given expression tree is from the specified metadata workspace,
/// potentially rebinding and rebuilding the expressions to appropriate replacement metadata where necessary.
///
internal class DbExpressionRebinder : DefaultExpressionVisitor
{
private readonly MetadataWorkspace _metadata;
private readonly Perspective _perspective;
protected DbExpressionRebinder(MetadataWorkspace targetWorkspace)
{
Debug.Assert(targetWorkspace != null, "Metadata workspace is null");
_metadata = targetWorkspace;
_perspective = new ModelPerspective(targetWorkspace);
}
//
[System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Performance", "CA1811:AvoidUncalledPrivateCode")]
internal static DbExpression BindToWorkspace(DbExpression expression, MetadataWorkspace targetWorkspace)
{
Debug.Assert(expression != null, "expression is null");
DbExpressionRebinder copier = new DbExpressionRebinder(targetWorkspace);
return copier.VisitExpression(expression);
}
protected override EntitySetBase VisitEntitySet(EntitySetBase entitySet)
{
EntityContainer container;
if (_metadata.TryGetEntityContainer(entitySet.EntityContainer.Name, entitySet.EntityContainer.DataSpace, out container))
{
EntitySetBase extent = null;
if (container.BaseEntitySets.TryGetValue(entitySet.Name, false, out extent) &&
extent != null &&
entitySet.BuiltInTypeKind == extent.BuiltInTypeKind) // EntitySet -> EntitySet, AssociationSet -> AssociationSet, etc
{
return extent;
}
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_EntitySetNotFound(entitySet.EntityContainer.Name, entitySet.Name));
}
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_EntityContainerNotFound(entitySet.EntityContainer.Name));
}
protected override EdmFunction VisitFunction(EdmFunction function)
{
List argumentTypes = new List(function.Parameters.Count);
foreach (FunctionParameter funcParam in function.Parameters)
{
TypeUsage mappedParamType = this.VisitTypeUsage(funcParam.TypeUsage);
argumentTypes.Add(mappedParamType);
}
if (DataSpace.SSpace == function.DataSpace)
{
EdmFunction foundFunc = null;
if (_metadata.TryGetFunction(function.Name,
function.NamespaceName,
argumentTypes.ToArray(),
false /* ignoreCase */,
function.DataSpace,
out foundFunc) &&
foundFunc != null)
{
return foundFunc;
}
}
else
{
// find the function
IList candidateFunctions;
if (_perspective.TryGetFunctionByName(function.FullName, /*ignoreCase:*/ false, out candidateFunctions))
{
Debug.Assert(null != candidateFunctions && candidateFunctions.Count > 0, "Perspective.TryGetFunctionByName returned true with null/empty function result list");
bool isAmbiguous;
EdmFunction retFunc = FunctionOverloadResolver.ResolveFunctionOverloads(candidateFunctions, argumentTypes, /*isGroupAggregateFunction:*/ false, out isAmbiguous);
if (!isAmbiguous &&
retFunc != null)
{
return retFunc;
}
}
}
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_FunctionNotFound(TypeHelpers.GetFullName(function)));
}
protected override EdmType VisitType(EdmType type)
{
EdmType retType = type;
if (BuiltInTypeKind.RefType == type.BuiltInTypeKind)
{
RefType refType = (RefType)type;
EntityType mappedEntityType = (EntityType)this.VisitType(refType.ElementType);
if (!object.ReferenceEquals(refType.ElementType, mappedEntityType))
{
retType = new RefType(mappedEntityType);
}
}
else if (BuiltInTypeKind.CollectionType == type.BuiltInTypeKind)
{
CollectionType collectionType = (CollectionType)type;
TypeUsage mappedElementType = this.VisitTypeUsage(collectionType.TypeUsage);
if (!object.ReferenceEquals(collectionType.TypeUsage, mappedElementType))
{
retType = new CollectionType(mappedElementType);
}
}
else if (BuiltInTypeKind.RowType == type.BuiltInTypeKind)
{
RowType rowType = (RowType)type;
List> mappedPropInfo = null;
for (int idx = 0; idx < rowType.Properties.Count; idx++)
{
EdmProperty originalProp = rowType.Properties[idx];
TypeUsage mappedPropType = this.VisitTypeUsage(originalProp.TypeUsage);
if (!object.ReferenceEquals(originalProp.TypeUsage, mappedPropType))
{
if (mappedPropInfo == null)
{
mappedPropInfo = new List>(
rowType.Properties.Select(
prop => new KeyValuePair(prop.Name, prop.TypeUsage)
));
}
mappedPropInfo[idx] = new KeyValuePair(originalProp.Name, mappedPropType);
}
}
if (mappedPropInfo != null)
{
IEnumerable mappedProps = mappedPropInfo.Select(propInfo => new EdmProperty(propInfo.Key, propInfo.Value));
retType = new RowType(mappedProps, rowType.InitializerMetadata);
}
}
else
{
if (!_metadata.TryGetType(type.Name, type.NamespaceName, type.DataSpace, out retType) ||
null == retType)
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_TypeNotFound(TypeHelpers.GetFullName(type)));
}
}
return retType;
}
protected override TypeUsage VisitTypeUsage(TypeUsage type)
{
//
// If the target metatadata workspace contains the same type instances, then the type does not
// need to be 'mapped' and the same TypeUsage instance may be returned. This can happen if the
// target workspace and the workspace of the source Command Tree are using the same ItemCollection.
//
EdmType retEdmType = this.VisitType(type.EdmType);
if (object.ReferenceEquals(retEdmType, type.EdmType))
{
return type;
}
//
// Retrieve the Facets from this type usage so that
// 1) They can be used to map the type if it is a primitive type
// 2) They can be applied to the new type usage that references the mapped type
//
Facet[] facets = new Facet[type.Facets.Count];
int idx = 0;
foreach (Facet f in type.Facets)
{
facets[idx] = f;
idx++;
}
return TypeUsage.Create(retEdmType, facets);
}
private bool TryGetMember(DbExpression instance, string memberName, out TMember member) where TMember : EdmMember
{
member = null;
StructuralType declType = instance.ResultType.EdmType as StructuralType;
if (declType != null)
{
EdmMember foundMember = null;
if (declType.Members.TryGetValue(memberName, false, out foundMember))
{
member = foundMember as TMember;
}
}
return (member != null);
}
public override DbExpression Visit(DbPropertyExpression expression)
{
EntityUtil.CheckArgumentNull(expression, "expression");
DbExpression result = expression;
DbExpression newInstance = this.VisitExpression(expression.Instance);
if (!object.ReferenceEquals(expression.Instance, newInstance))
{
if (Helper.IsRelationshipEndMember(expression.Property))
{
RelationshipEndMember endMember;
if(!TryGetMember(newInstance, expression.Property.Name, out endMember))
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_EndNotFound(expression.Property.Name, TypeHelpers.GetFullName(newInstance.ResultType.EdmType)));
}
result = DbExpressionBuilder.Property(newInstance, endMember);
}
else if (Helper.IsNavigationProperty(expression.Property))
{
NavigationProperty navProp;
if (!TryGetMember(newInstance, expression.Property.Name, out navProp))
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_NavPropertyNotFound(expression.Property.Name, TypeHelpers.GetFullName(newInstance.ResultType.EdmType)));
}
result = DbExpressionBuilder.Property(newInstance, navProp);
}
else
{
EdmProperty prop;
if (!TryGetMember(newInstance, expression.Property.Name, out prop))
{
throw EntityUtil.Argument(System.Data.Entity.Strings.Cqt_Copier_PropertyNotFound(expression.Property.Name, TypeHelpers.GetFullName(newInstance.ResultType.EdmType)));
}
result = DbExpressionBuilder.Property(newInstance, prop);
}
}
return result;
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- UIElementParaClient.cs
- Codec.cs
- Bidi.cs
- XmlAttributeProperties.cs
- FormsAuthenticationUser.cs
- SpeakInfo.cs
- IgnoreFlushAndCloseStream.cs
- Part.cs
- CustomAttributeFormatException.cs
- MatrixStack.cs
- MatrixAnimationUsingPath.cs
- BitmapPalettes.cs
- StreamAsIStream.cs
- fixedPageContentExtractor.cs
- GridViewHeaderRowPresenter.cs
- SqlDataSourceCommandParser.cs
- UInt16Storage.cs
- GlyphsSerializer.cs
- ContextConfiguration.cs
- StorageMappingItemLoader.cs
- ParseNumbers.cs
- SemanticResolver.cs
- CookieProtection.cs
- TransformGroup.cs
- XmlChoiceIdentifierAttribute.cs
- Geometry3D.cs
- ProfileServiceManager.cs
- Soap.cs
- PreDigestedSignedInfo.cs
- DoWorkEventArgs.cs
- ToolboxDataAttribute.cs
- CacheAxisQuery.cs
- KeyMatchBuilder.cs
- SchemaImporter.cs
- FormViewRow.cs
- InstanceHandleReference.cs
- OutputCacheModule.cs
- SHA1CryptoServiceProvider.cs
- ScriptReferenceBase.cs
- ProfileInfo.cs
- HttpValueCollection.cs
- GetCertificateRequest.cs
- _TLSstream.cs
- CodeExpressionCollection.cs
- TransformedBitmap.cs
- TransactionManagerProxy.cs
- PermissionAttributes.cs
- XmlILConstructAnalyzer.cs
- Crypto.cs
- NativeMethods.cs
- RsaSecurityToken.cs
- DataGridViewColumnTypePicker.cs
- DispatcherEventArgs.cs
- OrderByExpression.cs
- FixedPageAutomationPeer.cs
- RegexGroupCollection.cs
- PeerNearMe.cs
- CompositeTypefaceMetrics.cs
- GeneralTransform3DTo2D.cs
- ConfigurationElement.cs
- DeviceSpecificChoice.cs
- DBCommand.cs
- SoapFaultCodes.cs
- SqlDependencyUtils.cs
- FileLogRecord.cs
- InstanceKeyNotReadyException.cs
- SHA256Managed.cs
- X509WindowsSecurityToken.cs
- XPathDocumentNavigator.cs
- CodeCastExpression.cs
- SharedUtils.cs
- DefaultBinder.cs
- PartialCachingAttribute.cs
- WebEvents.cs
- ResourceDisplayNameAttribute.cs
- AutomationEvent.cs
- Point3DValueSerializer.cs
- TraceData.cs
- XPathNodePointer.cs
- XmlWrappingReader.cs
- RemotingSurrogateSelector.cs
- CommonXSendMessage.cs
- CodeAttributeDeclaration.cs
- IsolatedStorageException.cs
- DrawingCollection.cs
- EventRecord.cs
- HtmlInputText.cs
- StylusShape.cs
- NameValueCollection.cs
- IntegerValidatorAttribute.cs
- ItemAutomationPeer.cs
- SqlReorderer.cs
- PickDesigner.xaml.cs
- SudsWriter.cs
- Perspective.cs
- Util.cs
- KeyValueConfigurationCollection.cs
- UTF7Encoding.cs
- BitmapEffectDrawingContent.cs
- RadioButton.cs