Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / ndp / fx / src / DataOracleClient / System / Data / OracleClient / OciLobLocator.cs / 1 / OciLobLocator.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //----------------------------------------------------------------------------- namespace System.Data.OracleClient { using System; using System.Data.Common; using System.Data.SqlTypes; using System.Diagnostics; using System.Globalization; using System.IO; using System.Runtime.ConstrainedExecution; using System.Runtime.InteropServices; using System.Text; using System.Threading; sealed internal class OciLobLocator { private OracleConnection _connection; // the connection the lob is attached to private int _connectionCloseCount; // The close count of the connection; used to decide if we're zombied private OracleType _lobType; // the underlying data type of the LOB locator private OciHandle _descriptor; // the lob/file descriptor. private int _cloneCount; // the number of clones of this object -- used to know when we can close the lob/bfile. private int _openMode; // zero when not opened, otherwise, it's the value of OracleLobOpenMode internal OciLobLocator(OracleConnection connection, OracleType lobType) { _connection = connection; _connectionCloseCount = connection.CloseCount; _lobType = lobType; _cloneCount = 1; switch (lobType) { case OracleType.Blob: case OracleType.Clob: case OracleType.NClob: _descriptor = new OciLobDescriptor(connection.ServiceContextHandle); break; case OracleType.BFile: _descriptor = new OciFileDescriptor(connection.ServiceContextHandle); break; default: Debug.Assert(false, "Invalid lobType"); break; } } internal OracleConnection Connection { get { return _connection; } } internal bool ConnectionIsClosed { // returns TRUE when the parent connection object has been closed get { return (null == _connection) || (_connectionCloseCount != _connection.CloseCount); } } internal OciErrorHandle ErrorHandle { // Every OCI call needs an error handle, so make it available // internally. get { return Connection.ErrorHandle; } } internal OciHandle Descriptor { [ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success)] get { return _descriptor; } } public OracleType LobType { get { return _lobType; } } internal OciServiceContextHandle ServiceContextHandle { // You need to provide the service context handle to things like the // OCI execute call so a statement handle can be associated with a // connection. Better make it available internally, then. get { return Connection.ServiceContextHandle; } } internal OciLobLocator Clone() { Interlocked.Increment(ref _cloneCount); return this; } internal void Dispose() { int cloneCount = Interlocked.Decrement(ref _cloneCount); if (0 == cloneCount) { if (0 != _openMode && !ConnectionIsClosed) { ForceClose(); } OciHandle.SafeDispose(ref _descriptor); GC.KeepAlive(this); _connection = null; } } internal void ForceClose() { if (0 != _openMode) { int rc = TracedNativeMethods.OCILobClose( ServiceContextHandle, ErrorHandle, Descriptor ); if (0 != rc) { Connection.CheckError(ErrorHandle, rc); } _openMode = 0; } } internal void ForceOpen() { if (0 != _openMode) { int rc = TracedNativeMethods.OCILobOpen( ServiceContextHandle, ErrorHandle, Descriptor, (byte)_openMode ); if (0 != rc) { _openMode = 0; // failure means we didn't really open it. Connection.CheckError(ErrorHandle, rc); } } } internal void Open (OracleLobOpenMode mode) { OracleLobOpenMode openMode = (OracleLobOpenMode)Interlocked.CompareExchange(ref _openMode, (int)mode, 0); if (0 == openMode) { ForceOpen(); } else if (mode != openMode) { throw ADP.CannotOpenLobWithDifferentMode(mode, openMode); } } internal static void SafeDispose(ref OciLobLocator locator) { // Safely disposes of the handle (even if it is already null) and // then nulls it out. if (null != locator) { locator.Dispose(); } locator = null; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //[....] //----------------------------------------------------------------------------- namespace System.Data.OracleClient { using System; using System.Data.Common; using System.Data.SqlTypes; using System.Diagnostics; using System.Globalization; using System.IO; using System.Runtime.ConstrainedExecution; using System.Runtime.InteropServices; using System.Text; using System.Threading; sealed internal class OciLobLocator { private OracleConnection _connection; // the connection the lob is attached to private int _connectionCloseCount; // The close count of the connection; used to decide if we're zombied private OracleType _lobType; // the underlying data type of the LOB locator private OciHandle _descriptor; // the lob/file descriptor. private int _cloneCount; // the number of clones of this object -- used to know when we can close the lob/bfile. private int _openMode; // zero when not opened, otherwise, it's the value of OracleLobOpenMode internal OciLobLocator(OracleConnection connection, OracleType lobType) { _connection = connection; _connectionCloseCount = connection.CloseCount; _lobType = lobType; _cloneCount = 1; switch (lobType) { case OracleType.Blob: case OracleType.Clob: case OracleType.NClob: _descriptor = new OciLobDescriptor(connection.ServiceContextHandle); break; case OracleType.BFile: _descriptor = new OciFileDescriptor(connection.ServiceContextHandle); break; default: Debug.Assert(false, "Invalid lobType"); break; } } internal OracleConnection Connection { get { return _connection; } } internal bool ConnectionIsClosed { // returns TRUE when the parent connection object has been closed get { return (null == _connection) || (_connectionCloseCount != _connection.CloseCount); } } internal OciErrorHandle ErrorHandle { // Every OCI call needs an error handle, so make it available // internally. get { return Connection.ErrorHandle; } } internal OciHandle Descriptor { [ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success)] get { return _descriptor; } } public OracleType LobType { get { return _lobType; } } internal OciServiceContextHandle ServiceContextHandle { // You need to provide the service context handle to things like the // OCI execute call so a statement handle can be associated with a // connection. Better make it available internally, then. get { return Connection.ServiceContextHandle; } } internal OciLobLocator Clone() { Interlocked.Increment(ref _cloneCount); return this; } internal void Dispose() { int cloneCount = Interlocked.Decrement(ref _cloneCount); if (0 == cloneCount) { if (0 != _openMode && !ConnectionIsClosed) { ForceClose(); } OciHandle.SafeDispose(ref _descriptor); GC.KeepAlive(this); _connection = null; } } internal void ForceClose() { if (0 != _openMode) { int rc = TracedNativeMethods.OCILobClose( ServiceContextHandle, ErrorHandle, Descriptor ); if (0 != rc) { Connection.CheckError(ErrorHandle, rc); } _openMode = 0; } } internal void ForceOpen() { if (0 != _openMode) { int rc = TracedNativeMethods.OCILobOpen( ServiceContextHandle, ErrorHandle, Descriptor, (byte)_openMode ); if (0 != rc) { _openMode = 0; // failure means we didn't really open it. Connection.CheckError(ErrorHandle, rc); } } } internal void Open (OracleLobOpenMode mode) { OracleLobOpenMode openMode = (OracleLobOpenMode)Interlocked.CompareExchange(ref _openMode, (int)mode, 0); if (0 == openMode) { ForceOpen(); } else if (mode != openMode) { throw ADP.CannotOpenLobWithDifferentMode(mode, openMode); } } internal static void SafeDispose(ref OciLobLocator locator) { // Safely disposes of the handle (even if it is already null) and // then nulls it out. if (null != locator) { locator.Dispose(); } locator = null; } } } // 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
- IgnoreSection.cs
- DSASignatureFormatter.cs
- BinaryFormatter.cs
- TextParagraphCache.cs
- SerializableReadOnlyDictionary.cs
- SingleTagSectionHandler.cs
- WebContext.cs
- CookieProtection.cs
- SqlTopReducer.cs
- CookielessHelper.cs
- TrustManager.cs
- DataGridViewColumn.cs
- DetailsViewCommandEventArgs.cs
- DbMetaDataColumnNames.cs
- XamlSerializerUtil.cs
- BaseDataList.cs
- ChannelHandler.cs
- keycontainerpermission.cs
- UpDownEvent.cs
- DelegatingTypeDescriptionProvider.cs
- SqlFacetAttribute.cs
- FilterEventArgs.cs
- BitmapFrameEncode.cs
- CalendarAutomationPeer.cs
- ColorMatrix.cs
- XmlSignificantWhitespace.cs
- MergeFilterQuery.cs
- PeerDuplexChannelListener.cs
- ApplicationInterop.cs
- CaseInsensitiveComparer.cs
- Utils.cs
- XmlSchemaSimpleTypeList.cs
- StateBag.cs
- CompositeTypefaceMetrics.cs
- DefaultWorkflowTransactionService.cs
- MessageAction.cs
- StandardCommandToolStripMenuItem.cs
- _DomainName.cs
- TypeBuilder.cs
- EdmEntityTypeAttribute.cs
- ClusterRegistryConfigurationProvider.cs
- DbProviderFactory.cs
- RoleService.cs
- CultureSpecificCharacterBufferRange.cs
- PropertyItemInternal.cs
- LayeredChannelListener.cs
- EntityDataSourceEntitySetNameItem.cs
- CheckBoxStandardAdapter.cs
- Receive.cs
- securitymgrsite.cs
- wmiprovider.cs
- TouchesCapturedWithinProperty.cs
- FormsAuthenticationUserCollection.cs
- BufferedGraphicsContext.cs
- unsafenativemethodstextservices.cs
- VectorCollectionValueSerializer.cs
- TextWriterTraceListener.cs
- TaiwanCalendar.cs
- ConstrainedDataObject.cs
- CommandManager.cs
- SimpleType.cs
- Screen.cs
- RoutedUICommand.cs
- EventManager.cs
- DispatcherOperation.cs
- FixedFlowMap.cs
- Comparer.cs
- ZipArchive.cs
- NativeMethods.cs
- ParameterModifier.cs
- ChannelToken.cs
- ILGenerator.cs
- Configuration.cs
- WebPartHeaderCloseVerb.cs
- QuadraticBezierSegment.cs
- BaseResourcesBuildProvider.cs
- TextServicesContext.cs
- WindowsTokenRoleProvider.cs
- AccessedThroughPropertyAttribute.cs
- CustomGrammar.cs
- WebPartEventArgs.cs
- RuntimeConfigurationRecord.cs
- RequestResizeEvent.cs
- SchemaTableOptionalColumn.cs
- OdbcRowUpdatingEvent.cs
- XmlDataProvider.cs
- CategoryAttribute.cs
- XmlSchema.cs
- SourceChangedEventArgs.cs
- PassportAuthentication.cs
- UIElementIsland.cs
- OperandQuery.cs
- AdjustableArrowCap.cs
- XpsFont.cs
- ACE.cs
- VirtualDirectoryMappingCollection.cs
- DefaultParameterValueAttribute.cs
- PageBreakRecord.cs
- ListViewDeleteEventArgs.cs
- TransformerTypeCollection.cs