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

   1 //\r
   2 // System.Data.ProviderBase.AbstractTransaction\r
   3 //\r
   4 // Authors:\r
   5 //      Konstantin Triger <kostat@mainsoft.com>\r
   6 //      Boris Kirzner <borisk@mainsoft.com>\r
   7 //      \r
   8 // (C) 2005 Mainsoft Corporation (http://www.mainsoft.com)\r
   9 //\r
  10 \r
  11 //\r
  12 // Permission is hereby granted, free of charge, to any person obtaining\r
  13 // a copy of this software and associated documentation files (the\r
  14 // "Software"), to deal in the Software without restriction, including\r
  15 // without limitation the rights to use, copy, modify, merge, publish,\r
  16 // distribute, sublicense, and/or sell copies of the Software, and to\r
  17 // permit persons to whom the Software is furnished to do so, subject to\r
  18 // the following conditions:\r
  19 // \r
  20 // The above copyright notice and this permission notice shall be\r
  21 // included in all copies or substantial portions of the Software.\r
  22 // \r
  23 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,\r
  24 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\r
  25 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND\r
  26 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE\r
  27 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION\r
  28 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION\r
  29 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\r
  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                 internal AbstractTransaction ActiveTransaction {\r
 134                         get {\r
 135                                 // recoursively return parent transaction when nesting will\r
 136                                 // be implemented\r
 137                                 return _connection != null ? this : null;\r
 138                         }\r
 139                 }\r
 140 \r
 141         private int convertIsolationLevel(IsolationLevel isolationLevel)\r
 142         {\r
 143             if (isolationLevel == IsolationLevel.Unspecified)\r
 144                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_NONE;\r
 145             if (isolationLevel == IsolationLevel.ReadCommitted)\r
 146                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_READ_COMMITTED;\r
 147             if (isolationLevel == IsolationLevel.ReadUncommitted)\r
 148                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_READ_UNCOMMITTED;\r
 149             if (isolationLevel == IsolationLevel.RepeatableRead)\r
 150                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_REPEATABLE_READ;\r
 151             if (isolationLevel == IsolationLevel.Serializable)\r
 152                 return vmw.@internal.sql.ConnectionUtils__Finals.TRANSACTION_SERIALIZABLE;\r
 153 \r
 154             throw new NotSupportedException("The Isolation level '" + isolationLevel + "' is not supported");\r
 155         }\r
 156     }\r
 157 }