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

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