mcs/class/System.Data/System.Data.OleDb/OleDbTransaction.cs

   1 //
   2 // System.Data.OleDb.OleDbTransaction
   3 //
   4 // Authors:
   5 //   Rodrigo Moya (rodrigo@ximian.com)
   6 //   Tim Coleman (tim@timcoleman.com)
   7 //
   8 // Copyright (C) Rodrigo Moya, 2002
   9 // Copyright (C) Tim Coleman, 2002
  10 //
  11
  12 using System.Data;
  13 using System.Data.Common;
  14
  15 namespace System.Data.OleDb
  16 {
  17         public sealed class OleDbTransaction : MarshalByRefObject, IDbTransaction, IDisposable
  18         {
  19                 #region Fields
  20
  21                 OleDbConnection connection;
  22                 IsolationLevel isolationLevel;
  23                 IntPtr gdaTransaction;
  24                 int depth;
  25
  26                 #endregion // Fields
  27
  28                 #region Constructors
  29
  30                 internal OleDbTransaction (OleDbConnection connection, int depth)
  31                 {
  32                         this.connection = connection;
  33                         isolationLevel = IsolationLevel.ReadCommitted;
  34
  35                         gdaTransaction = libgda.gda_transaction_new (depth.ToString ());
  36                         libgda.gda_connection_begin_transaction (connection.GdaConnection, gdaTransaction);
  37                 }
  38
  39                 internal OleDbTransaction (OleDbConnection connection)
  40                         : this (connection, 1)
  41                 {
  42                 }
  43
  44                 internal OleDbTransaction (OleDbConnection connection, int depth, IsolationLevel isolevel)
  45                         : this (connection, depth)
  46                 {
  47                         isolationLevel = isolevel;
  48                 }
  49
  50                 internal OleDbTransaction (OleDbConnection connection, IsolationLevel isolevel)
  51                         : this (connection, 1, isolevel)
  52                 {
  53                 }
  54
  55
  56                 #endregion // Constructors
  57
  58                 #region Properties
  59
  60                 public OleDbConnection Connection {
  61                         get {
  62                                 return connection;
  63                         }
  64                 }
  65
  66                 IDbConnection IDbTransaction.Connection {
  67                         get {
  68                                 return connection;
  69                         }
  70                 }
  71
  72                 public IsolationLevel IsolationLevel {
  73                         get {
  74                                 return isolationLevel;
  75                         }
  76                 }
  77
  78                 #endregion // Properties
  79
  80                 #region Methods
  81
  82                 public OleDbTransaction Begin ()
  83                 {
  84                         return new OleDbTransaction (connection, depth + 1);
  85                 }
  86
  87                 public OleDbTransaction Begin (IsolationLevel isolevel)
  88                 {
  89                         return new OleDbTransaction (connection, depth + 1, isolevel);
  90                 }
  91
  92                 public void Commit ()
  93                 {
  94                         if (!libgda.gda_connection_commit_transaction (connection.GdaConnection,
  95                                                                        gdaTransaction))
  96                                 throw new InvalidOperationException ();
  97                 }
  98
  99                 [MonoTODO]
 100                 ~OleDbTransaction ()
 101                 {
 102                 }
 103
 104                 [MonoTODO]
 105                 void IDisposable.Dispose ()
 106                 {
 107                         throw new NotImplementedException ();
 108                 }
 109
 110                 public void Rollback ()
 111                 {
 112                         if (!libgda.gda_connection_rollback_transaction (connection.GdaConnection,
 113                                                                          gdaTransaction))
 114                                 throw new InvalidOperationException ();
 115                 }
 116
 117                 #endregion // Methods
 118         }
 119 }