Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / Orcas / QFE / ndp / fx / src / DataEntity / System / Data / Objects / objectresult_tresulttype.cs / 1 / objectresult_tresulttype.cs
//----------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//
// @owner [....]
// @backupowner [....]
//---------------------------------------------------------------------
namespace System.Data.Objects
{
using System;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Data;
using System.Data.Common;
using System.Data.Metadata.Edm;
using System.Data.Mapping;
using System.Data.Objects.DataClasses;
using System.Diagnostics;
using System.Linq.Expressions;
using System.Data.Common.Internal.Materialization;
///
/// This class implements IEnumerable of T and IDisposable. Instance of this class
/// is returned from ObjectQuery<T>.Execute method.
///
[System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1710:IdentifiersShouldHaveCorrectSuffix")]
public sealed class ObjectResult : ObjectResult, IEnumerable
{
private Shaper _shaper;
private DbDataReader _reader;
private readonly EntitySet _singleEntitySet;
private readonly TypeUsage _resultItemType;
private IBindingList _cachedBindingList;
internal ObjectResult(Shaper shaper, EntitySet singleEntitySet, TypeUsage resultItemType)
{
_shaper = shaper;
_reader = _shaper.Reader;
_singleEntitySet = singleEntitySet;
_resultItemType = resultItemType;
}
private void EnsureCanEnumerateResults()
{
if (null == _shaper)
{
// Enumerating more than once is not allowed.
throw EntityUtil.CannotReEnumerateQueryResults();
}
}
///
/// Returns an enumerator that iterates through the collection.
///
public IEnumerator GetEnumerator()
{
EnsureCanEnumerateResults();
Shaper shaper = _shaper;
_shaper = null;
IEnumerator result = shaper.GetEnumerator();
return result;
}
///
/// Performs tasks associated with freeing, releasing, or resetting resources.
///
public override void Dispose()
{
DbDataReader reader = _reader;
_reader = null;
if (null != reader)
{
reader.Dispose();
}
if (_shaper != null)
{
// This case includes when the ObjectResult is disposed before it
// created an ObjectQueryEnumeration; at this time, the connection can be released
if (_shaper.Context != null)
{
_shaper.Context.ReleaseConnection();
}
_shaper = null;
}
}
internal override IEnumerator GetEnumeratorInternal()
{
return ((IEnumerable)this).GetEnumerator();
}
internal override IList GetIListSourceListInternal()
{
// You can only enumerate the query results once, and the creation of an ObjectView consumes this enumeration.
// However, there are situations where setting the DataSource of a control can result in multiple calls to this method.
// In order to enable this scenario and allow direct binding to the ObjectResult instance,
// the ObjectView is cached and returned on subsequent calls to this method.
if (_cachedBindingList == null)
{
EnsureCanEnumerateResults();
bool forceReadOnly = this._shaper.MergeOption == MergeOption.NoTracking;
_cachedBindingList = ObjectViewFactory.CreateViewForQuery(this._resultItemType, this, this._shaper.Context, forceReadOnly, this._singleEntitySet);
}
return _cachedBindingList;
}
public override Type ElementType
{
get { return typeof(T); }
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
//----------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//
// @owner [....]
// @backupowner [....]
//---------------------------------------------------------------------
namespace System.Data.Objects
{
using System;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Data;
using System.Data.Common;
using System.Data.Metadata.Edm;
using System.Data.Mapping;
using System.Data.Objects.DataClasses;
using System.Diagnostics;
using System.Linq.Expressions;
using System.Data.Common.Internal.Materialization;
///
/// This class implements IEnumerable of T and IDisposable. Instance of this class
/// is returned from ObjectQuery<T>.Execute method.
///
[System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Naming", "CA1710:IdentifiersShouldHaveCorrectSuffix")]
public sealed class ObjectResult : ObjectResult, IEnumerable
{
private Shaper _shaper;
private DbDataReader _reader;
private readonly EntitySet _singleEntitySet;
private readonly TypeUsage _resultItemType;
private IBindingList _cachedBindingList;
internal ObjectResult(Shaper shaper, EntitySet singleEntitySet, TypeUsage resultItemType)
{
_shaper = shaper;
_reader = _shaper.Reader;
_singleEntitySet = singleEntitySet;
_resultItemType = resultItemType;
}
private void EnsureCanEnumerateResults()
{
if (null == _shaper)
{
// Enumerating more than once is not allowed.
throw EntityUtil.CannotReEnumerateQueryResults();
}
}
///
/// Returns an enumerator that iterates through the collection.
///
public IEnumerator GetEnumerator()
{
EnsureCanEnumerateResults();
Shaper shaper = _shaper;
_shaper = null;
IEnumerator result = shaper.GetEnumerator();
return result;
}
///
/// Performs tasks associated with freeing, releasing, or resetting resources.
///
public override void Dispose()
{
DbDataReader reader = _reader;
_reader = null;
if (null != reader)
{
reader.Dispose();
}
if (_shaper != null)
{
// This case includes when the ObjectResult is disposed before it
// created an ObjectQueryEnumeration; at this time, the connection can be released
if (_shaper.Context != null)
{
_shaper.Context.ReleaseConnection();
}
_shaper = null;
}
}
internal override IEnumerator GetEnumeratorInternal()
{
return ((IEnumerable)this).GetEnumerator();
}
internal override IList GetIListSourceListInternal()
{
// You can only enumerate the query results once, and the creation of an ObjectView consumes this enumeration.
// However, there are situations where setting the DataSource of a control can result in multiple calls to this method.
// In order to enable this scenario and allow direct binding to the ObjectResult instance,
// the ObjectView is cached and returned on subsequent calls to this method.
if (_cachedBindingList == null)
{
EnsureCanEnumerateResults();
bool forceReadOnly = this._shaper.MergeOption == MergeOption.NoTracking;
_cachedBindingList = ObjectViewFactory.CreateViewForQuery(this._resultItemType, this, this._shaper.Context, forceReadOnly, this._singleEntitySet);
}
return _cachedBindingList;
}
public override Type ElementType
{
get { return typeof(T); }
}
}
}
// 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
- QuaternionAnimationBase.cs
- StandardRuntimeEnumValidator.cs
- XmlElementAttribute.cs
- SocketException.cs
- LiteralControl.cs
- ConditionBrowserDialog.cs
- DeferredTextReference.cs
- EncoderFallback.cs
- XmlDataProvider.cs
- ExtenderHelpers.cs
- FileChangeNotifier.cs
- TemplatedWizardStep.cs
- PlainXmlWriter.cs
- PolyLineSegment.cs
- MemberInfoSerializationHolder.cs
- StyleSelector.cs
- SecurityKeyUsage.cs
- HWStack.cs
- QueueProcessor.cs
- ControlAdapter.cs
- FixedSOMTextRun.cs
- ScriptControlDescriptor.cs
- DataGridBoolColumn.cs
- BuildResult.cs
- FixedElement.cs
- ViewEvent.cs
- RefreshPropertiesAttribute.cs
- KeyInterop.cs
- ResizeBehavior.cs
- ResourceBinder.cs
- KeyPullup.cs
- XmlObjectSerializerWriteContextComplex.cs
- _BaseOverlappedAsyncResult.cs
- ValidationEventArgs.cs
- HostingEnvironment.cs
- JsonDeserializer.cs
- DoubleIndependentAnimationStorage.cs
- BitmapEffect.cs
- SvcMapFile.cs
- DataIdProcessor.cs
- ResXBuildProvider.cs
- FlowDocumentPageViewerAutomationPeer.cs
- TypeUnloadedException.cs
- ConnectionInterfaceCollection.cs
- XmlElementAttribute.cs
- QueryCacheEntry.cs
- SafeRightsManagementQueryHandle.cs
- DependencyObjectType.cs
- PropertyNames.cs
- HtmlWindow.cs
- BufferedOutputStream.cs
- ActivityDelegate.cs
- TemplatingOptionsDialog.cs
- InheritanceContextHelper.cs
- SequentialWorkflowHeaderFooter.cs
- HttpRuntime.cs
- WsiProfilesElementCollection.cs
- CdpEqualityComparer.cs
- ToolStripItemTextRenderEventArgs.cs
- PropertyOrder.cs
- DataPagerFieldItem.cs
- prefixendpointaddressmessagefiltertable.cs
- MenuRendererStandards.cs
- ObjectContextServiceProvider.cs
- XsdBuilder.cs
- EdmRelationshipNavigationPropertyAttribute.cs
- InputScopeAttribute.cs
- ExternalCalls.cs
- KnownBoxes.cs
- SettingsPropertyValueCollection.cs
- ExpressionBindingCollection.cs
- UnsafeNativeMethods.cs
- ContentDisposition.cs
- ProxyGenerationError.cs
- ScrollBar.cs
- WebPartDisplayModeEventArgs.cs
- StylusEventArgs.cs
- SafeThemeHandle.cs
- ClaimSet.cs
- IndexOutOfRangeException.cs
- ShutDownListener.cs
- EntitySetBase.cs
- TypeResolver.cs
- CustomWebEventKey.cs
- Helpers.cs
- GenericsInstances.cs
- SpeechUI.cs
- ClientTarget.cs
- ParallelEnumerable.cs
- KernelTypeValidation.cs
- WebSysDefaultValueAttribute.cs
- FastEncoder.cs
- FusionWrap.cs
- ChtmlMobileTextWriter.cs
- _UriSyntax.cs
- BypassElement.cs
- ToRequest.cs
- XMLUtil.cs
- CodeActivityContext.cs
- QuaternionAnimation.cs