Capacitor driver additional connection options

docs/connection-options.md

@@ -209,6 +209,12 @@ See [SSL options](https://github.com/mysqljs/mysql#ssl-options).
 
 * `driver` - The capacitor-sqlite instance. For example, `new SQLiteConnection(CapacitorSQLite)`.
 
+* `encrypted` - Set to true for database encryption
+
+* `mode` - Set the mode for database encryption: "no-encryption" | "encryption" | "secret" | "newsecret"
+
+* `version` - Database version
+
 * `journalMode` - The SQLite journal mode (optional)
 
 ## `cordova` connection options

src/driver/capacitor/CapacitorConnectionOptions.ts

@@ -9,15 +9,30 @@ export interface CapacitorConnectionOptions extends BaseConnectionOptions {
      */
     readonly type: "capacitor";
 
+    /**
+     * The capacitor-sqlite instance. For example, `new SQLiteConnection(CapacitorSQLite)`.
+     */
+    readonly driver: any;
+
     /**
      * Database name (capacitor-sqlite will add the suffix `SQLite.db`)
      */
     readonly database: string;
 
     /**
-     * The capacitor-sqlite instance. For example, `new SQLiteConnection(CapacitorSQLite)`.
+     * Set to true for database encryption
      */
-    readonly driver: any;
+    readonly encrypted?: boolean;
+
+    /**
+     * Set the mode for database encryption
+     */
+    readonly mode?: "no-encryption" | "encryption" | "secret" | "newsecret";
+
+    /**
+     * Database version
+     */
+    readonly version?: number;
 
     /**
      * The SQLite journal mode (optional)

src/driver/capacitor/CapacitorDriver.ts

@@ -74,22 +74,33 @@ export class CapacitorDriver extends AbstractSqliteDriver {
      * Creates connection with the database.
      */
     protected async createDatabaseConnection() {
+        const isDatabaseEncryted = this.options.encrypted || false;
+        const databaseMode = this.options.mode || "no-encryption";
+        const databaseVersion =
+            typeof this.options.version === "undefined"
+                ? 1
+                : this.options.version;
         const connection = await this.sqlite.createConnection(
             this.options.database,
-            false,
-            "no-encryption",
-            1
+            isDatabaseEncryted,
+            databaseMode,
+            databaseVersion
         );
         await connection.open();
 
         // we need to enable foreign keys in sqlite to make sure all foreign key related features
         // working properly. this also makes onDelete to work with sqlite.
-        await connection.query(`PRAGMA foreign_keys = ON`, []);
-
-        if (this.options.journalMode) {
-            await connection.query(`PRAGMA journal_mode = ?`, [
-                this.options.journalMode,
-            ]);
+        await connection.query(`PRAGMA foreign_keys = ON`);
+
+        if (
+            this.options.journalMode &&
+            ["DELETE", "TRUNCATE", "PERSIST", "MEMORY", "WAL", "OFF"].indexOf(
+                this.options.journalMode
+            ) !== -1
+        ) {
+            await connection.query(
+                `PRAGMA journal_mode = ${this.options.journalMode}`
+            );
         }
 
         return connection;