mcs/class/System.Data/System.Data.SqlClient/SqlTransaction.cs

   1 //
   2 // System.Data.SqlClient.SqlTransaction.cs
   3 //
   4 // Author:
   5 //   Tim Coleman (tim@timcoleman.com)
   6 //
   7 // Copyright (C) Tim Coleman, 2002
   8 //
   9
  10 //
  11 // Copyright (C) 2004 Novell, Inc (http://www.novell.com)
  12 //
  13 // Permission is hereby granted, free of charge, to any person obtaining
  14 // a copy of this software and associated documentation files (the
  15 // "Software"), to deal in the Software without restriction, including
  16 // without limitation the rights to use, copy, modify, merge, publish,
  17 // distribute, sublicense, and/or sell copies of the Software, and to
  18 // permit persons to whom the Software is furnished to do so, subject to
  19 // the following conditions:
  20 //
  21 // The above copyright notice and this permission notice shall be
  22 // included in all copies or substantial portions of the Software.
  23 //
  24 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  25 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  26 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  27 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  28 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  29 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  30 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  31 //
  32
  33 using System;
  34 using System.Data;
  35 using System.Data.Common;
  36
  37 namespace System.Data.SqlClient
  38 {
  39 #if NET_2_0
  40         public sealed class SqlTransaction : DbTransaction, IDbTransaction, IDisposable
  41 #else
  42         public sealed class SqlTransaction : MarshalByRefObject, IDbTransaction, IDisposable
  43 #endif // NET_2_0
  44         {
  45                 #region Fields
  46
  47                 bool disposed;
  48                 SqlConnection connection;
  49                 IsolationLevel isolationLevel;
  50                 bool isOpen;
  51
  52                 #endregion
  53
  54                 #region Constructors
  55
  56                 internal SqlTransaction (SqlConnection connection, IsolationLevel isolevel)
  57                 {
  58                         this.connection = connection;
  59                         this.isolationLevel = isolevel;
  60                         isOpen = true;
  61                 }
  62
  63                 #endregion // Constructors
  64
  65                 #region Properties
  66
  67                 public
  68 #if NET_2_0
  69                 new
  70 #endif // NET_2_0
  71                 SqlConnection Connection {
  72                         get { return connection; }
  73                 }
  74
  75                 internal bool IsOpen {
  76                         get { return isOpen; }
  77                 }
  78
  79                 public
  80 #if NET_2_0
  81                 override
  82 #endif // NET_2_0
  83                 IsolationLevel IsolationLevel {
  84                         get {
  85                                 if (!isOpen)
  86                                         throw ExceptionHelper.TransactionNotUsable (GetType ());
  87                                 return isolationLevel;
  88                         }
  89                 }
  90
  91 #if NET_2_0
  92                 protected override DbConnection DbConnection {
  93                         get { return Connection; }
  94                 }
  95 #else
  96                 IDbConnection IDbTransaction.Connection {
  97                         get { return Connection; }
  98                 }
  99 #endif
 100
 101                 #endregion // Properties
 102
 103                 #region Methods
 104
 105                 public
 106 #if NET_2_0
 107                 override
 108 #endif // NET_2_0
 109                 void Commit ()
 110                 {
 111                         if (!isOpen)
 112                                 throw ExceptionHelper.TransactionNotUsable (GetType ());
 113
 114                         connection.Tds.Execute ("COMMIT TRANSACTION");
 115                         connection.Transaction = null;
 116                         connection = null;
 117                         isOpen = false;
 118                 }
 119
 120 #if NET_2_0
 121                 protected override
 122 #endif
 123                 void Dispose (bool disposing)
 124                 {
 125                         if (!disposed) {
 126                                 if (disposing) {
 127                                         if (isOpen) // in case it is called in the dispose of the class, then the isOpen is already false
 128                                                 Rollback ();
 129                                 }
 130                                 disposed = true;
 131                         }
 132                 }
 133
 134 #if !NET_2_0
 135                 public void Dispose ()
 136                 {
 137                         Dispose (true);
 138                         GC.SuppressFinalize (this);
 139                 }
 140 #endif
 141
 142                 public
 143 #if NET_2_0
 144                 override
 145 #endif // NET_2_0
 146                 void Rollback ()
 147                 {
 148                         Rollback (String.Empty);
 149                 }
 150
 151                 public void Rollback (string transactionName)
 152                 {
 153 #if NET_2_0
 154                         if (disposed)
 155                                 return;
 156 #endif
 157
 158                         if (!isOpen)
 159                                 throw ExceptionHelper.TransactionNotUsable (GetType ());
 160
 161                         connection.Tds.Execute (String.Format ("IF @@TRANCOUNT > 0 ROLLBACK TRANSACTION {0}",
 162                                                                 transactionName));
 163                         isOpen = false;
 164                         connection.Transaction = null;
 165                         connection = null;
 166                 }
 167
 168                 public void Save (string savePointName)
 169                 {
 170                         if (!isOpen)
 171                                 throw ExceptionHelper.TransactionNotUsable (GetType ());
 172                         connection.Tds.Execute (String.Format ("SAVE TRANSACTION {0}", savePointName));
 173                 }
 174
 175                 #endregion // Methods
 176         }
 177 }