mcs/class/Mono.Data.TdsClient/Mono.Data.TdsClient/TdsTransaction.cs

   1 //
   2 // Mono.Data.TdsClient.TdsTransaction.cs
   3 //
   4 // Author:
   5 //   Tim Coleman (tim@timcoleman.com)
   6 //
   7 // Copyright (C) Tim Coleman, 2002
   8 //
   9
  10 //
  11 // Permission is hereby granted, free of charge, to any person obtaining
  12 // a copy of this software and associated documentation files (the
  13 // "Software"), to deal in the Software without restriction, including
  14 // without limitation the rights to use, copy, modify, merge, publish,
  15 // distribute, sublicense, and/or sell copies of the Software, and to
  16 // permit persons to whom the Software is furnished to do so, subject to
  17 // the following conditions:
  18 //
  19 // The above copyright notice and this permission notice shall be
  20 // included in all copies or substantial portions of the Software.
  21 //
  22 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  23 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  24 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  25 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  26 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  27 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  29 //
  30
  31 using System;
  32 using System.Data;
  33 using System.Data.Common;
  34
  35 namespace Mono.Data.TdsClient {
  36         public sealed class TdsTransaction : MarshalByRefObject, IDbTransaction, IDisposable
  37         {
  38                 #region Fields
  39
  40                 bool disposed = false;
  41
  42                 TdsConnection connection;
  43                 IsolationLevel isolationLevel;
  44                 bool isOpen;
  45
  46                 #endregion
  47
  48                 #region Constructors
  49
  50                 internal TdsTransaction (TdsConnection connection, IsolationLevel isolevel)
  51                 {
  52                         this.connection = connection;
  53                         this.isolationLevel = isolevel;
  54                         isOpen = true;
  55                 }
  56
  57                 #endregion // Constructors
  58
  59                 #region Properties
  60
  61                 public TdsConnection Connection {
  62                         get { return connection; }
  63                 }
  64
  65                 internal bool IsOpen {
  66                         get { return isOpen; }
  67                 }
  68
  69                 public IsolationLevel IsolationLevel {
  70                         get { return isolationLevel; }
  71                 }
  72
  73                 IDbConnection IDbTransaction.Connection {
  74                         get { return Connection; }
  75                 }
  76
  77                 #endregion // Properties
  78
  79                 #region Methods
  80
  81                 public void Commit ()
  82                 {
  83                         if (!isOpen)
  84                                 throw new InvalidOperationException ("The Transaction was not open.");
  85                         connection.Tds.Execute ("COMMIT TRANSACTION");
  86                         connection.Transaction = null;
  87                         isOpen = false;
  88                 }
  89
  90                 private void Dispose (bool disposing)
  91                 {
  92                         if (!disposed) {
  93                                 if (disposing)
  94                                         Rollback ();
  95                                 disposed = true;
  96                         }
  97                 }
  98
  99                 public void Dispose ()
 100                 {
 101                         Dispose (true);
 102                         GC.SuppressFinalize (this);
 103                 }
 104
 105                 public void Rollback ()
 106                 {
 107                         Rollback (String.Empty);
 108                 }
 109
 110                 public void Rollback (string transactionName)
 111                 {
 112                         if (!isOpen)
 113                                 throw new InvalidOperationException ("The Transaction was not open.");
 114                         connection.Tds.Execute (String.Format ("ROLLBACK TRANSACTION {0}", transactionName));
 115                         isOpen = false;
 116                 }
 117
 118                 public void Save (string savePointName)
 119                 {
 120                         if (!isOpen)
 121                                 throw new InvalidOperationException ("The Transaction was not open.");
 122                         connection.Tds.Execute (String.Format ("SAVE TRANSACTION {0}", savePointName));
 123                 }
 124
 125                 #endregion // Methods
 126         }
 127 }