OciTransactionHandle.cs :  » 2.6.4-mono-.net-core » System.Data » System » Data » OracleClient » Oci » C# / CSharp Open Source

// 
// OciTransactionHandle.cs 
//  
// Part of managed C#/.NET library System.Data.OracleClient.dll
//
// Part of the Mono class libraries at
// mcs/class/System.Data.OracleClient/System.Data.OracleClient.Oci
//
// Assembly: System.Data.OracleClient.dll
// Namespace: System.Data.OracleClient.Oci
// 
// Author: 
//     Tim Coleman <tim@timcoleman.com>
//         
// Copyright (C) Tim Coleman, 2003
// 

using System;
using System.Runtime.InteropServices;

namespace System.Data.OracleClient.Oci{
  internal sealed class OciTransactionHandle : OciHandle, IDisposable
  {
    #region Fields

    bool disposed = false;
    OciErrorHandle errorHandle;
    OciServiceHandle serviceHandle;

    #endregion // Fields

    #region Constructors

    public OciTransactionHandle (OciHandle parent, IntPtr handle)
      : base (OciHandleType.Transaction, parent, handle)
    {
    }

    #endregion // Constructors

    #region Properties

    public OciErrorHandle ErrorHandle {
      get { return errorHandle; }
      set { errorHandle = value; }
    }

    public OciServiceHandle Service {
      get { return serviceHandle; }
      set { serviceHandle = value; }
    }

    #endregion // Properties

    #region Methods

    public void AttachToServiceContext ()
    {
      int status = 0;
      status = OciCalls.OCIAttrSet (Service,
              OciHandleType.Service,
              this,
              0,
              OciAttributeType.Transaction,
              ErrorHandle);
      if (status != 0) {
        OciErrorInfo info = ErrorHandle.HandleError ();
        throw new OracleException (info.ErrorCode, info.ErrorMessage);
      }
    }

    public void DetachFromServiceContext ()
    {
      int status = 0;
      status = OciCalls.OCIAttrSet (Service,
        OciHandleType.Service,
        IntPtr.Zero,
        0,
        OciAttributeType.Transaction,
        ErrorHandle);
      if (status != 0) 
      {
        OciErrorInfo info = ErrorHandle.HandleError ();
        throw new OracleException (info.ErrorCode, info.ErrorMessage);
      }
    }

    public void Begin ()
    {
      int status = 0;

      AttachToServiceContext ();

      status = OciCalls.OCITransStart (Service,
            ErrorHandle,
            60,
            OciTransactionFlags.New);

      if (status != 0) {
        OciErrorInfo info = ErrorHandle.HandleError ();
        throw new OracleException (info.ErrorCode, info.ErrorMessage);
      }
    }

    public void Commit ()
    {
      int status = 0;
      AttachToServiceContext ();
      try {
        status = OciCalls.OCITransCommit (Service, ErrorHandle, 0);

        if (status != 0) 
        {
          OciErrorInfo info = ErrorHandle.HandleError ();
          throw new OracleException (info.ErrorCode, info.ErrorMessage);
        }
      }
      finally {
        DetachFromServiceContext ();
      }
    }

    protected override void Dispose (bool disposing)
    {
      if (!disposed) {
        disposed = true;
        base.Dispose (disposing);
      }
    }

    public void Rollback ()
    {
      try {
        int status = 0;
        AttachToServiceContext ();
        status = OciCalls.OCITransRollback (Service, ErrorHandle, 0);

        if (status != 0) {
          OciErrorInfo info = ErrorHandle.HandleError ();
          throw new OracleException (info.ErrorCode, info.ErrorMessage);
        }
      }
      finally {
        DetachFromServiceContext ();
      }
    }

    #endregion // Methods
  }
}