2 // System.Data.OleDb.OleDbTransaction
5 // Rodrigo Moya (rodrigo@ximian.com)
6 // Tim Coleman (tim@timcoleman.com)
8 // Copyright (C) Rodrigo Moya, 2002
9 // Copyright (C) Tim Coleman, 2002
10 // Copyright (C) 2004-2005 Novell, Inc (http://www.novell.com)
12 // Permission is hereby granted, free of charge, to any person obtaining
13 // a copy of this software and associated documentation files (the
14 // "Software"), to deal in the Software without restriction, including
15 // without limitation the rights to use, copy, modify, merge, publish,
16 // distribute, sublicense, and/or sell copies of the Software, and to
17 // permit persons to whom the Software is furnished to do so, subject to
18 // the following conditions:
20 // The above copyright notice and this permission notice shall be
21 // included in all copies or substantial portions of the Software.
23 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
24 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
25 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
26 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
27 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
28 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
29 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
32 using System.Data.Common;
34 namespace System.Data.OleDb
36 public sealed class OleDbTransaction : DbTransaction, IDbTransaction
41 OleDbConnection connection;
42 IntPtr gdaTransaction;
50 internal OleDbTransaction (OleDbConnection connection, int depth)
51 : this (connection, depth, IsolationLevel.ReadCommitted)
55 internal OleDbTransaction (OleDbConnection connection)
56 : this (connection, 1)
60 internal OleDbTransaction (OleDbConnection connection, int depth, IsolationLevel isolevel)
62 this.connection = connection;
64 gdaTransaction = libgda.gda_transaction_new (depth.ToString ());
67 case IsolationLevel.ReadCommitted :
68 libgda.gda_transaction_set_isolation_level (gdaTransaction,
69 GdaTransactionIsolation.ReadCommitted);
71 case IsolationLevel.ReadUncommitted :
72 libgda.gda_transaction_set_isolation_level (gdaTransaction,
73 GdaTransactionIsolation.ReadUncommitted);
75 case IsolationLevel.RepeatableRead :
76 libgda.gda_transaction_set_isolation_level (gdaTransaction,
77 GdaTransactionIsolation.RepeatableRead);
79 case IsolationLevel.Serializable :
80 libgda.gda_transaction_set_isolation_level (gdaTransaction,
81 GdaTransactionIsolation.Serializable);
85 libgda.gda_connection_begin_transaction (connection.GdaConnection, gdaTransaction);
89 internal OleDbTransaction (OleDbConnection connection, IsolationLevel isolevel)
90 : this (connection, 1, isolevel)
95 #endregion // Constructors
99 public new OleDbConnection Connection {
105 protected override DbConnection DbConnection {
106 get { return connection; }
111 IsolationLevel IsolationLevel {
114 throw ExceptionHelper.TransactionNotUsable (GetType ());
116 switch (libgda.gda_transaction_get_isolation_level (gdaTransaction)) {
117 case GdaTransactionIsolation.ReadCommitted :
118 return IsolationLevel.ReadCommitted;
119 case GdaTransactionIsolation.ReadUncommitted :
120 return IsolationLevel.ReadUncommitted;
121 case GdaTransactionIsolation.RepeatableRead :
122 return IsolationLevel.RepeatableRead;
123 case GdaTransactionIsolation.Serializable :
124 return IsolationLevel.Serializable;
126 return IsolationLevel.Unspecified;
130 #endregion // Properties
134 public OleDbTransaction Begin ()
137 throw ExceptionHelper.TransactionNotUsable (GetType ());
138 return new OleDbTransaction (connection, depth + 1);
141 public OleDbTransaction Begin (IsolationLevel isolevel)
144 throw ExceptionHelper.TransactionNotUsable (GetType ());
145 return new OleDbTransaction (connection, depth + 1, isolevel);
153 throw ExceptionHelper.TransactionNotUsable (GetType ());
155 if (!libgda.gda_connection_commit_transaction (connection.GdaConnection,
157 throw new InvalidOperationException ();
164 void Dispose (bool disposing)
167 if (disposing && isOpen)
172 base.Dispose (disposing);
181 throw ExceptionHelper.TransactionNotUsable (GetType ());
183 if (!libgda.gda_connection_rollback_transaction (connection.GdaConnection,
185 throw new InvalidOperationException ();
190 #endregion // Methods