Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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
- MultiTouchSystemGestureLogic.cs
- WebPartZoneCollection.cs
- BitmapEffectOutputConnector.cs
- OleDbInfoMessageEvent.cs
- FieldBuilder.cs
- UIPermission.cs
- RoleService.cs
- SQLMoney.cs
- DirectoryNotFoundException.cs
- Point3DKeyFrameCollection.cs
- SerializationEventsCache.cs
- RoleManagerModule.cs
- XmlWriter.cs
- ValidatingPropertiesEventArgs.cs
- IDQuery.cs
- EventProxy.cs
- XmlSerializer.cs
- TickBar.cs
- ObjectListItem.cs
- TextTabProperties.cs
- StrokeCollectionConverter.cs
- CommandBindingCollection.cs
- BamlLocalizationDictionary.cs
- ProxyElement.cs
- Content.cs
- Atom10FormatterFactory.cs
- diagnosticsswitches.cs
- DefinitionUpdate.cs
- WebBrowserNavigatedEventHandler.cs
- DataGridViewButtonColumn.cs
- ECDiffieHellmanPublicKey.cs
- BaseTemplateParser.cs
- FrameworkTextComposition.cs
- CodeCastExpression.cs
- NotificationContext.cs
- TraceProvider.cs
- PathFigure.cs
- WindowsPrincipal.cs
- EUCJPEncoding.cs
- ActivitiesCollection.cs
- PropertiesTab.cs
- XPathNodeInfoAtom.cs
- PasswordDeriveBytes.cs
- AutomationPropertyInfo.cs
- ResXResourceSet.cs
- FactoryMaker.cs
- FunctionImportMapping.ReturnTypeRenameMapping.cs
- BCLDebug.cs
- SimpleFieldTemplateUserControl.cs
- NodeFunctions.cs
- TiffBitmapEncoder.cs
- Int32Storage.cs
- DataRowExtensions.cs
- KeyProperty.cs
- AutomationPattern.cs
- Rss20FeedFormatter.cs
- SocketAddress.cs
- CodeChecksumPragma.cs
- ChildChangedEventArgs.cs
- TaiwanLunisolarCalendar.cs
- HttpWebRequestElement.cs
- SectionVisual.cs
- SmtpSection.cs
- InternalConfigHost.cs
- MetadataSerializer.cs
- SqlErrorCollection.cs
- ColumnReorderedEventArgs.cs
- JournalEntryStack.cs
- HostProtectionPermission.cs
- SendKeys.cs
- WebColorConverter.cs
- _HeaderInfo.cs
- ItemCheckEvent.cs
- TargetFrameworkAttribute.cs
- Function.cs
- AvTraceFormat.cs
- ToolStripRendererSwitcher.cs
- ExceptionValidationRule.cs
- Positioning.cs
- TcpClientSocketManager.cs
- DeclaredTypeValidatorAttribute.cs
- BindingBase.cs
- JavaScriptSerializer.cs
- Wildcard.cs
- WebServiceErrorEvent.cs
- ScrollEvent.cs
- FilterUserControlBase.cs
- EncodingDataItem.cs
- ReverseComparer.cs
- WebPartsSection.cs
- StyleCollectionEditor.cs
- TemplatedWizardStep.cs
- XmlChildNodes.cs
- RightsManagementManager.cs
- StateManagedCollection.cs
- InheritanceUI.cs
- WindowsComboBox.cs
- ToolStripControlHost.cs
- NonVisualControlAttribute.cs
- SqlParameterCollection.cs