-// Mono.Data.SqliteClient data access components for .Net\r
-// Derived from ByteFX.Data\r
-// With permission from Reggie Burnett to relicense under MIT/X11\r
-\r
-using System;\r
-using System.Data;\r
-\r
-namespace Mono.Data.SqliteClient\r
-{\r
- /// <summary>\r
- /// Represents a SQL transaction to be made in a Sqlite database. This class cannot be inherited.\r
- /// </summary>\r
- public sealed class SqliteTransaction : IDbTransaction\r
- {\r
- private IsolationLevel _level;\r
- private SqliteConnection _conn;\r
- private bool _open;\r
-\r
- internal SqliteTransaction() \r
- {\r
- _open = true;\r
- }\r
-\r
- #region Properties\r
-\r
- /// <summary>\r
- /// Gets the <see cref="SqliteConnection"/> object associated with the transaction, or a null reference (Nothing in Visual Basic) if the transaction is no longer valid.\r
- /// </summary>\r
- public IDbConnection Connection\r
- {\r
- get { return _conn; } \r
- set { _conn = (SqliteConnection)value; }\r
- }\r
-\r
- /// <summary>\r
- /// Specifies the <see cref="IsolationLevel"/> for this transaction.\r
- /// </summary>\r
- public IsolationLevel IsolationLevel \r
- {\r
- get { return _level; }\r
- set { _level = value; }\r
- }\r
-\r
- #endregion\r
-\r
- void System.IDisposable.Dispose() \r
- {\r
- }\r
-\r
- /// <summary>\r
- /// Commits the database transaction.\r
- /// </summary>\r
- public void Commit()\r
- {\r
- if (_conn == null || _conn.State != ConnectionState.Open)\r
- throw new InvalidOperationException("Connection must be valid and open to commit transaction");\r
- if (!_open)\r
- throw new InvalidOperationException("Transaction has already been committed or is not pending");\r
- try \r
- {\r
- SqliteCommand cmd = _conn.CreateCommand();\r
- cmd.CommandText = "COMMIT";\r
- cmd.ExecuteNonQuery();\r
- _open = false;\r
- }\r
- catch (Exception ex) \r
- {\r
- throw ex;\r
- }\r
- }\r
-\r
- /// <summary>\r
- /// Overloaded. Rolls back a transaction from a pending state.\r
- /// </summary>\r
- public void Rollback()\r
- {\r
- if (_conn == null || _conn.State != ConnectionState.Open)\r
- throw new InvalidOperationException("Connection must be valid and open to commit transaction");\r
- if (!_open)\r
- throw new InvalidOperationException("Transaction has already been rolled back or is not pending");\r
- try \r
- {\r
- SqliteCommand cmd = _conn.CreateCommand();\r
- cmd.CommandText = "COMMIT";\r
- cmd.ExecuteNonQuery();\r
- _open = false;\r
- }\r
- catch (Exception ex) \r
- {\r
- throw ex;\r
- }\r
- }\r
- }\r
-}\r
+//
+// Mono.Data.SqliteClient.SqliteTransaction.cs
+//
+// Mono.Data.SqliteClient data access components for .Net
+// Derived from ByteFX.Data
+// With permission from Reggie Burnett to relicense under MIT/X11
+//
+// 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.
+//
+
+using System;
+using System.Data;
+#if NET_2_0
+using System.Data.Common;
+#endif
+
+namespace Mono.Data.SqliteClient
+{
+ public sealed class SqliteTransaction :
+#if NET_2_0
+ DbTransaction
+#else
+ IDbTransaction
+#endif
+ {
+
+ #region Fields
+
+ private IsolationLevel _isolationLevel;
+ private SqliteConnection _connection;
+ private bool _open;
+
+ #endregion
+
+ #region Contructors and destructors
+
+ internal SqliteTransaction()
+ {
+ _open = true;
+ }
+
+#if !NET_2_0
+ void System.IDisposable.Dispose()
+ {
+ }
+#endif
+
+ #endregion
+
+ #region Public Properties
+
+#if NET_2_0
+ protected override DbConnection DbConnection
+#else
+ public IDbConnection Connection
+#endif
+ {
+ get { return _connection; }
+#if !NET_2_0
+ set { _connection = (SqliteConnection)value; }
+#endif
+ }
+
+#if NET_2_0
+ override
+#endif
+ public IsolationLevel IsolationLevel
+ {
+ get { return _isolationLevel; }
+#if !NET_2_0
+ set { _isolationLevel = value; }
+#endif
+ }
+
+#if NET_2_0
+ internal void SetConnection (DbConnection conn)
+ {
+ _connection = (SqliteConnection)conn;
+ }
+
+ internal void SetIsolationLevel (IsolationLevel level)
+ {
+ _isolationLevel = level;
+ }
+#endif
+
+ #endregion
+
+ #region Public Methods
+
+#if NET_2_0
+ override
+#endif
+ public void Commit()
+ {
+ if (_connection == null || _connection.State != ConnectionState.Open)
+ throw new InvalidOperationException("Connection must be valid and open to commit transaction");
+ if (!_open)
+ throw new InvalidOperationException("Transaction has already been committed or is not pending");
+ try
+ {
+ SqliteCommand cmd = (SqliteCommand)_connection.CreateCommand();
+ cmd.CommandText = "COMMIT";
+ cmd.ExecuteNonQuery();
+ _open = false;
+ }
+ catch (Exception ex)
+ {
+ throw ex;
+ }
+ }
+
+#if NET_2_0
+ override
+#endif
+ public void Rollback()
+ {
+ if (_connection == null || _connection.State != ConnectionState.Open)
+ throw new InvalidOperationException("Connection must be valid and open to commit transaction");
+ if (!_open)
+ throw new InvalidOperationException("Transaction has already been rolled back or is not pending");
+ try
+ {
+ SqliteCommand cmd = (SqliteCommand)_connection.CreateCommand();
+ cmd.CommandText = "ROLLBACK";
+ cmd.ExecuteNonQuery();
+ _open = false;
+ }
+ catch (Exception ex)
+ {
+ throw ex;
+ }
+ }
+
+ #endregion
+ }
+}
projects / mono.git / blobdiff