diff options
| author | Konstantin Triger <kostat@mono-cvs.ximian.com> | 2005-05-01 20:52:03 +0400 |
|---|---|---|
| committer | Konstantin Triger <kostat@mono-cvs.ximian.com> | 2005-05-01 20:52:03 +0400 |
| commit | ba2e565a7ad2712c33114119cdf1e9ad06ac9250 (patch) | |
| tree | f30e40c75b02bc3ba5a21db3d53f96180a157cf4 /mcs/class/System.Data/System.Data.ProviderBase | |
| parent | 0094a5a30131c2c27ac7955c72d342f6eff00649 (diff) | |
svn path=/branches/Mainsoft.System.Data/mcs/; revision=43849
Diffstat (limited to 'mcs/class/System.Data/System.Data.ProviderBase')
| -rw-r--r-- | mcs/class/System.Data/System.Data.ProviderBase/AbstractTransaction.cs | 152 |
1 files changed, 152 insertions, 0 deletions
diff --git a/mcs/class/System.Data/System.Data.ProviderBase/AbstractTransaction.cs b/mcs/class/System.Data/System.Data.ProviderBase/AbstractTransaction.cs new file mode 100644 index 00000000000..586976b19b0 --- /dev/null +++ b/mcs/class/System.Data/System.Data.ProviderBase/AbstractTransaction.cs @@ -0,0 +1,152 @@ +/*
+ * Copyright (c) 2002-2004 Mainsoft Corporation.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ */
+
+namespace System.Data.Common
+{
+
+ using java.sql;
+
+ using System.Data;
+ /**
+ * @author erand
+ */
+ public abstract class AbstractTransaction : DbTransaction
+ {
+
+ protected String _transactionName;
+ protected AbstractDBConnection _connection;
+
+ protected IsolationLevel _isolationLevel;
+
+ public AbstractTransaction(
+ IsolationLevel isolationLevel,
+ AbstractDBConnection connection,
+ String transactionName)
+ {
+ connection.ValidateBeginTransaction();
+ _transactionName = transactionName;
+ _connection = connection;
+ _isolationLevel = isolationLevel;
+ try
+ {
+ _connection.JdbcConnection.setAutoCommit(false);
+ _connection.JdbcConnection.setTransactionIsolation(
+ convertIsolationLevel(isolationLevel));
+ }
+ catch (SQLException exp)
+ {
+ throw new System.InvalidOperationException(exp.Message);
+ }
+ }
+
+
+ /**
+ * @see System.Data.IDbTransaction#Connection
+ */
+ protected override DbConnection DbConnection
+ {
+ get
+ {
+ return _connection;
+ }
+ }
+
+ /**
+ * @see System.Data.IDbTransaction#IsolationLevel
+ */
+ public override IsolationLevel IsolationLevel
+ {
+ get
+ {
+ return _isolationLevel;
+ }
+ }
+
+ /**
+ * @see System.Data.IDbTransaction#Commit()
+ */
+ public override void Commit()
+ {
+ if (_connection == null)
+ return;
+
+ try
+ {
+ _connection.JdbcConnection.commit();
+ _connection.JdbcConnection.setAutoCommit(true);
+ _connection = null;
+ }
+ catch (SQLException exp)
+ {
+ throw new SystemException(exp.Message);
+ }
+ }
+
+ /**
+ * @see System.Data.IDbTransaction#Rollback()
+ */
+ public override void Rollback()
+ {
+ if (_connection == null)
+ return;
+
+ try
+ {
+ _connection.JdbcConnection.rollback();
+ _connection = null;
+ }
+ catch (SQLException exp)
+ {
+ throw new SystemException(exp.Message);
+ }
+ }
+
+ public override void Dispose()
+ {
+ Rollback();
+ }
+
+ internal AbstractTransaction ActiveTransaction {
+ get {
+ // recoursively return parent transaction when nesting will
+ // be implemented
+ return _connection != null ? this : null;
+ }
+ }
+
+ private int convertIsolationLevel(IsolationLevel isolationLevel)
+ {
+ if (isolationLevel == IsolationLevel.Unspecified)
+ return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_NONE;
+ if (isolationLevel == IsolationLevel.ReadCommitted)
+ return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_READ_COMMITTED;
+ if (isolationLevel == IsolationLevel.ReadUncommitted)
+ return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_READ_UNCOMMITTED;
+ if (isolationLevel == IsolationLevel.RepeatableRead)
+ return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_REPEATABLE_READ;
+ if (isolationLevel == IsolationLevel.Serializable)
+ return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_SERIALIZABLE;
+
+ throw new NotSupportedException("The Isolation level '" + isolationLevel + "' is not supported");
+ }
+ }
+}
\ No newline at end of file |