mcs/class/System.Data/System.Data.ProviderBase.jvm/AbstractTransaction.cs

   1 //
   2 // System.Data.ProviderBase.AbstractTransaction
   3 //
   4 // Authors:
   5 //      Konstantin Triger <kostat@mainsoft.com>
   6 //      Boris Kirzner <borisk@mainsoft.com>
   7 //
   8 // (C) 2005 Mainsoft Corporation (http://www.mainsoft.com)
   9 //
  10
  11 //
  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:
  19 //
  20 // The above copyright notice and this permission notice shall be
  21 // included in all copies or substantial portions of the Software.
  22 //
  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.
  30 //
  31
  32 using System.Data.Common;
  33
  34 namespace System.Data.ProviderBase
  35 {
  36
  37     using java.sql;
  38
  39     using System.Data;
  40
  41     public abstract class AbstractTransaction : DbTransaction
  42     {
  43
  44         protected String _transactionName;
  45         protected AbstractDBConnection _connection;
  46
  47         protected IsolationLevel _isolationLevel;
  48
  49         public AbstractTransaction(
  50             IsolationLevel isolationLevel,
  51             AbstractDBConnection connection,
  52             String transactionName)
  53         {
  54                         connection.ValidateBeginTransaction();
  55             _transactionName = transactionName;
  56             _connection = connection;
  57             _isolationLevel = isolationLevel;
  58             try
  59             {
  60                 _connection.JdbcConnection.setAutoCommit(false);
  61                 _connection.JdbcConnection.setTransactionIsolation(
  62                 convertIsolationLevel(isolationLevel));
  63             }
  64             catch (SQLException exp)
  65             {
  66                 throw new System.InvalidOperationException(exp.Message, exp);
  67             }
  68         }
  69
  70
  71         /**
  72          * @see System.Data.IDbTransaction#Connection
  73          */
  74         protected override DbConnection DbConnection
  75         {
  76             get
  77             {
  78                 return _connection;
  79             }
  80         }
  81
  82         /**
  83          * @see System.Data.IDbTransaction#IsolationLevel
  84          */
  85         public override IsolationLevel IsolationLevel
  86         {
  87             get
  88             {
  89                 return _isolationLevel;
  90             }
  91         }
  92
  93         /**
  94          * @see System.Data.IDbTransaction#Commit()
  95          */
  96         public override void Commit()
  97         {
  98                         if (_connection == null)
  99                                 return;
 100
 101             try
 102             {
 103                 _connection.JdbcConnection.commit();
 104                                 _connection.JdbcConnection.setAutoCommit(true);
 105                                 _connection = null;
 106             }
 107             catch (SQLException exp)
 108             {
 109                 throw new SystemException(exp.Message, exp);
 110             }
 111         }
 112
 113         /**
 114          * @see System.Data.IDbTransaction#Rollback()
 115          */
 116         public override void Rollback()
 117         {
 118                         if (_connection == null)
 119                                 return;
 120
 121             try
 122             {
 123                 _connection.JdbcConnection.rollback();
 124                                 _connection.JdbcConnection.setAutoCommit(true);
 125                                 _connection = null;
 126             }
 127             catch (SQLException exp)
 128             {
 129                 throw new SystemException(exp.Message, exp);
 130             }
 131         }
 132
 133                 internal AbstractTransaction ActiveTransaction {
 134                         get {
 135                                 // recoursively return parent transaction when nesting will
 136                                 // be implemented
 137                                 return _connection != null ? this : null;
 138                         }
 139                 }
 140
 141         private int convertIsolationLevel(IsolationLevel isolationLevel)
 142         {
 143             if (isolationLevel == IsolationLevel.Unspecified)
 144                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_NONE;
 145             if (isolationLevel == IsolationLevel.ReadCommitted)
 146                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_READ_COMMITTED;
 147             if (isolationLevel == IsolationLevel.ReadUncommitted)
 148                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_READ_UNCOMMITTED;
 149             if (isolationLevel == IsolationLevel.RepeatableRead)
 150                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_REPEATABLE_READ;
 151             if (isolationLevel == IsolationLevel.Serializable)
 152                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_SERIALIZABLE;
 153
 154             throw new NotSupportedException("The Isolation level '" + isolationLevel + "' is not supported");
 155         }
 156     }
 157 }