Implemented SQLiteDatabase#{begin,end}Transaction().

Author: artob

CHANGELOG.md

@@ -8,6 +8,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [0.1.1] - 2018-11-23
 ### Added
+- `SQLiteDatabase#beginTransaction()` method
+- `SQLiteDatabase#beginTransactionNonExclusive()` method
+- `SQLiteDatabase#endTransaction()` method
 
 ## [0.1.0] - 2018-11-22
 ### Added

README.md

@@ -100,6 +100,9 @@ Reference
 - [`SQLiteDatabase.openOrCreateDatabase()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/openOrCreateDatabase.html)
 - [`SQLiteDatabase#path`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/path.html)
 - [`SQLiteDatabase#version`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/version.html)
+- [`SQLiteDatabase#beginTransaction()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/beginTransaction.html)
+- [`SQLiteDatabase#beginTransactionNonExclusive()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/beginTransactionNonExclusive.html)
+- [`SQLiteDatabase#endTransaction()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/endTransaction.html)
 - [`SQLiteDatabase#execSQL()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/execSQL.html)
 - [`SQLiteDatabase#getPath()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/getPath.html)
 - [`SQLiteDatabase#getVersion()`](https://pub.dartlang.org/documentation/flutter_sqlcipher/latest/sqlite/SQLiteDatabase/getVersion.html)

android/src/main/java/com/github/drydart/flutter_sqlcipher/SQLiteDatabaseMethodHandler.java

@@ -56,6 +56,32 @@ class SQLiteDatabaseMethodHandler implements MethodCallHandler {
         break;
       }
 
+      case "beginTransaction": {
+        final SQLiteDatabase db = this.getDatabaseArgument(call);
+        final String mode = getOptionalArgument(call, "mode", "exclusive");
+        switch (mode) {
+          case "exclusive":
+            db.beginTransaction();
+            break;
+          case "immediate":
+            //db.beginTransactionNonExclusive(); // TODO: this is missing in SQLCipher 3.5.9
+            db.beginTransaction();
+            break;
+          default:
+            assert(false); // unreachable
+            throw new AssertionError();
+        }
+        result.success(null);
+        break;
+      }
+
+      case "endTransaction": {
+        final SQLiteDatabase db = this.getDatabaseArgument(call);
+        db.endTransaction();
+        result.success(null);
+        break;
+      }
+
       case "execSQL": {
         final SQLiteDatabase db = this.getDatabaseArgument(call);
         final String sql = getRequiredArgument(call, "sql");
@@ -90,7 +116,7 @@ class SQLiteDatabaseMethodHandler implements MethodCallHandler {
 
       case "isWriteAheadLoggingEnabled": {
         final SQLiteDatabase db = this.getDatabaseArgument(call);
-        //result.success(db.isWriteAheadLoggingEnabled()); // TODO: this is missing in SQLCipher
+        //result.success(db.isWriteAheadLoggingEnabled()); // TODO: this is missing in SQLCipher 3.5.9
         result.success(false);
         break;
       }
@@ -197,9 +223,16 @@ class SQLiteDatabaseMethodHandler implements MethodCallHandler {
   private static <T> T
   getOptionalArgument(final MethodCall call,
                       final String name) {
+    return getOptionalArgument(call, name, (T)null);
+  }
+
+  private static <T> T
+  getOptionalArgument(final MethodCall call,
+                      final String name,
+                      final T defaultValue) {
     assert(call != null);
     assert(name != null);
 
-    return call.hasArgument(name) ? (T)call.argument(name) : (T)null;
+    return call.hasArgument(name) ? (T)call.argument(name) : defaultValue;
   }
 }

lib/src/database.dart

@@ -126,6 +126,30 @@ abstract class SQLiteDatabase {
   /// This is simply a Dart-idiomatic getter alias for [getVersion()].
   Future<int> get version => getVersion();
 
+  /// Begins a transaction in `EXCLUSIVE` mode.
+  ///
+  /// See: https://developer.android.com/reference/android/database/sqlite/SQLiteDatabase#beginTransaction()
+  Future<void> beginTransaction() {
+    final Map<String, dynamic> request = <String, dynamic>{'id': id, 'mode': 'exclusive'};
+    return _channel.invokeMethod('beginTransaction', request);
+  }
+
+  /// Begins a transaction in `IMMEDIATE` mode.
+  ///
+  /// See: https://developer.android.com/reference/android/database/sqlite/SQLiteDatabase#beginTransactionNonExclusive()
+  Future<void> beginTransactionNonExclusive() {
+    final Map<String, dynamic> request = <String, dynamic>{'id': id, 'mode': 'immediate'};
+    return _channel.invokeMethod('beginTransaction', request);
+  }
+
+  /// Ends a transaction.
+  ///
+  /// See: https://developer.android.com/reference/android/database/sqlite/SQLiteDatabase#endTransaction()
+  Future<void> endTransaction() {
+    final Map<String, dynamic> request = <String, dynamic>{'id': id};
+    return _channel.invokeMethod('endTransaction', request);
+  }
+
   /// Executes a single SQL statement that is *not* a `SELECT` or any other SQL
   /// statement that returns data.
   ///