Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / fx / src / Data / System / Data / Common / dbenumerator.cs / 1 / dbenumerator.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace System.Data.Common { using System; using System.Collections; using System.Data; using System.Data.ProviderBase; using System.Diagnostics; using System.ComponentModel; #if WINFSInternalOnly internal #else public #endif class DbEnumerator : IEnumerator { internal IDataReader _reader; internal IDataRecord _current; internal SchemaInfo[] _schemaInfo; // shared schema info among all the data records internal PropertyDescriptorCollection _descriptors; // cached property descriptors private FieldNameLookup _fieldNameLookup; // MDAC 69015 private bool closeReader; // users must get enumerators off of the datareader interfaces public DbEnumerator(IDataReader reader) { if (null == reader) { throw ADP.ArgumentNull("reader"); } _reader = reader; } public DbEnumerator(IDataReader reader, bool closeReader) { // MDAC 68670 if (null == reader) { throw ADP.ArgumentNull("reader"); } _reader = reader; this.closeReader = closeReader; } public object Current { get { return _current; } } /*public IDataRecord Current { get { return _current; } }*/ /* virtual internal IDataRecord NewRecord(SchemaInfo[] si, object[] values, PropertyDescriptorCollection descriptors) { return new DbDataRecord(si, values, descriptors); } virtual internal void GetValues(object[] values) { _reader.GetValues(values); } */ public bool MoveNext() { if (null == _schemaInfo) { BuildSchemaInfo(); } Debug.Assert(null != _schemaInfo && null != _descriptors, "unable to build schema information!"); _current = null; if (_reader.Read()) { // setup our current record object[] values = new object[_schemaInfo.Length]; _reader.GetValues(values); // this.GetValues() _current = new DataRecordInternal(_schemaInfo, values, _descriptors, _fieldNameLookup); // this.NewRecord() return true; } if (closeReader) { _reader.Close(); } return false; } [ EditorBrowsableAttribute(EditorBrowsableState.Never) ] // MDAC 69508 public void Reset() { throw ADP.NotSupported(); } private void BuildSchemaInfo() { int count = _reader.FieldCount; string[] fieldnames = new string[count]; for (int i = 0; i < count; ++i) { fieldnames[i] = _reader.GetName(i); } ADP.BuildSchemaTableInfoTableNames(fieldnames); // MDAC 71401 SchemaInfo[] si = new SchemaInfo[count]; PropertyDescriptor[] props = new PropertyDescriptor[_reader.FieldCount]; for (int i = 0; i < si.Length; i++) { SchemaInfo s = new SchemaInfo(); s.name = _reader.GetName(i); s.type = _reader.GetFieldType(i); s.typeName = _reader.GetDataTypeName(i); props[i] = new DbColumnDescriptor(i, fieldnames[i], s.type); si[i] = s; } _schemaInfo = si; _fieldNameLookup = new FieldNameLookup(_reader, -1); // MDAC 71470 _descriptors = new PropertyDescriptorCollection(props); } sealed private class DbColumnDescriptor : PropertyDescriptor { int _ordinal; Type _type; internal DbColumnDescriptor(int ordinal, string name, Type type) : base(name, null) { _ordinal = ordinal; _type = type; } public override Type ComponentType { get { return typeof(IDataRecord); } } public override bool IsReadOnly { get { return true; } } public override Type PropertyType { get { return _type; } } public override bool CanResetValue(object component) { return false; } public override object GetValue(object component) { return ((IDataRecord)component)[_ordinal]; } public override void ResetValue(object component) { throw ADP.NotSupported(); } public override void SetValue(object component, object value) { throw ADP.NotSupported(); } public override bool ShouldSerializeValue(object component) { return false; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //[....] //----------------------------------------------------------------------------- namespace System.Data.Common { using System; using System.Collections; using System.Data; using System.Data.ProviderBase; using System.Diagnostics; using System.ComponentModel; #if WINFSInternalOnly internal #else public #endif class DbEnumerator : IEnumerator { internal IDataReader _reader; internal IDataRecord _current; internal SchemaInfo[] _schemaInfo; // shared schema info among all the data records internal PropertyDescriptorCollection _descriptors; // cached property descriptors private FieldNameLookup _fieldNameLookup; // MDAC 69015 private bool closeReader; // users must get enumerators off of the datareader interfaces public DbEnumerator(IDataReader reader) { if (null == reader) { throw ADP.ArgumentNull("reader"); } _reader = reader; } public DbEnumerator(IDataReader reader, bool closeReader) { // MDAC 68670 if (null == reader) { throw ADP.ArgumentNull("reader"); } _reader = reader; this.closeReader = closeReader; } public object Current { get { return _current; } } /*public IDataRecord Current { get { return _current; } }*/ /* virtual internal IDataRecord NewRecord(SchemaInfo[] si, object[] values, PropertyDescriptorCollection descriptors) { return new DbDataRecord(si, values, descriptors); } virtual internal void GetValues(object[] values) { _reader.GetValues(values); } */ public bool MoveNext() { if (null == _schemaInfo) { BuildSchemaInfo(); } Debug.Assert(null != _schemaInfo && null != _descriptors, "unable to build schema information!"); _current = null; if (_reader.Read()) { // setup our current record object[] values = new object[_schemaInfo.Length]; _reader.GetValues(values); // this.GetValues() _current = new DataRecordInternal(_schemaInfo, values, _descriptors, _fieldNameLookup); // this.NewRecord() return true; } if (closeReader) { _reader.Close(); } return false; } [ EditorBrowsableAttribute(EditorBrowsableState.Never) ] // MDAC 69508 public void Reset() { throw ADP.NotSupported(); } private void BuildSchemaInfo() { int count = _reader.FieldCount; string[] fieldnames = new string[count]; for (int i = 0; i < count; ++i) { fieldnames[i] = _reader.GetName(i); } ADP.BuildSchemaTableInfoTableNames(fieldnames); // MDAC 71401 SchemaInfo[] si = new SchemaInfo[count]; PropertyDescriptor[] props = new PropertyDescriptor[_reader.FieldCount]; for (int i = 0; i < si.Length; i++) { SchemaInfo s = new SchemaInfo(); s.name = _reader.GetName(i); s.type = _reader.GetFieldType(i); s.typeName = _reader.GetDataTypeName(i); props[i] = new DbColumnDescriptor(i, fieldnames[i], s.type); si[i] = s; } _schemaInfo = si; _fieldNameLookup = new FieldNameLookup(_reader, -1); // MDAC 71470 _descriptors = new PropertyDescriptorCollection(props); } sealed private class DbColumnDescriptor : PropertyDescriptor { int _ordinal; Type _type; internal DbColumnDescriptor(int ordinal, string name, Type type) : base(name, null) { _ordinal = ordinal; _type = type; } public override Type ComponentType { get { return typeof(IDataRecord); } } public override bool IsReadOnly { get { return true; } } public override Type PropertyType { get { return _type; } } public override bool CanResetValue(object component) { return false; } public override object GetValue(object component) { return ((IDataRecord)component)[_ordinal]; } public override void ResetValue(object component) { throw ADP.NotSupported(); } public override void SetValue(object component, object value) { throw ADP.NotSupported(); } public override bool ShouldSerializeValue(object component) { return false; } } } } // 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
- XmlSerializationWriter.cs
- DynamicMethod.cs
- DataGridViewTopLeftHeaderCell.cs
- EventProvider.cs
- XamlTreeBuilder.cs
- PropertyInformationCollection.cs
- RadialGradientBrush.cs
- Pair.cs
- PropertyGridView.cs
- TextFindEngine.cs
- DataGridViewColumnEventArgs.cs
- ColumnReorderedEventArgs.cs
- CheckBox.cs
- SqlInfoMessageEvent.cs
- MsmqIntegrationAppDomainProtocolHandler.cs
- OpenFileDialog.cs
- initElementDictionary.cs
- Logging.cs
- DataGridItemEventArgs.cs
- ServiceModelDictionary.cs
- XmlSchemaException.cs
- DeploymentSectionCache.cs
- SerializationSectionGroup.cs
- MissingManifestResourceException.cs
- TextRangeEditLists.cs
- IDQuery.cs
- XamlGridLengthSerializer.cs
- BrowserInteropHelper.cs
- RawTextInputReport.cs
- PasswordRecovery.cs
- DiagnosticTrace.cs
- CounterSetInstance.cs
- Encoding.cs
- DeferredSelectedIndexReference.cs
- unitconverter.cs
- ServicePoint.cs
- HtmlLabelAdapter.cs
- XmlSchemaIdentityConstraint.cs
- ToolStripDropDownButton.cs
- ReadonlyMessageFilter.cs
- UrlMappingsModule.cs
- RewritingPass.cs
- DetailsViewCommandEventArgs.cs
- HtmlHead.cs
- ScriptingJsonSerializationSection.cs
- VectorConverter.cs
- MemberPathMap.cs
- XNameTypeConverter.cs
- ExecutionScope.cs
- AssemblyAttributes.cs
- DataGridViewElement.cs
- NetworkStream.cs
- NumericUpDownAcceleration.cs
- DSASignatureFormatter.cs
- DllNotFoundException.cs
- _ConnectOverlappedAsyncResult.cs
- ObjectDataSourceStatusEventArgs.cs
- DataGridViewRow.cs
- HyperLink.cs
- SafeMILHandle.cs
- ColumnBinding.cs
- AspNetSynchronizationContext.cs
- MarkerProperties.cs
- StructuredType.cs
- StreamWithDictionary.cs
- IgnoreFlushAndCloseStream.cs
- ETagAttribute.cs
- RuntimeCompatibilityAttribute.cs
- ResourceDictionary.cs
- RemotingConfiguration.cs
- Normalization.cs
- AsyncInvokeOperation.cs
- TabControl.cs
- LinkTarget.cs
- OperatingSystem.cs
- X509CertificateValidator.cs
- MethodBuilderInstantiation.cs
- DataSourceCacheDurationConverter.cs
- WebHttpSecurityModeHelper.cs
- StorageTypeMapping.cs
- FilterQuery.cs
- UpdateCompiler.cs
- CroppedBitmap.cs
- RegionInfo.cs
- BindingExpressionBase.cs
- XmlSecureResolver.cs
- Pen.cs
- TypeToken.cs
- GroupBoxRenderer.cs
- MutexSecurity.cs
- Clock.cs
- SubstitutionList.cs
- TemplateColumn.cs
- Wildcard.cs
- COAUTHIDENTITY.cs
- GeometryGroup.cs
- TranslateTransform.cs
- UnsafeNativeMethods.cs
- DispatcherOperation.cs
- NavigationHelper.cs