added option to explicitly and manually manage database transactions (begin, commit, rollback)

Author: fernandocode

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ionic-database-builder",
-  "version": "0.0.10",
+  "version": "0.0.11",
   "description": "Extended library from database-builder to assist in creating and maintaining SQL commands. Allowing integrate execute commands with SQLite ('@ionic-native/sqlite'), Web Sql, etc. Through the interface injection 'DatabaseCreatorContract' returning an implementation of 'DatabaseObject'.",
   "main": "index.js",
   "scripts": {

src/database.module.ts

@@ -49,8 +49,6 @@ export class DatabaseModule {
         providers: Provider[],
         databaseMigrationContract?: Type<DatabaseMigrationContract>
     ): ModuleWithProviders {
-        console.log("databaseMigrationContract:");
-        console.log(databaseMigrationContract);
         if (databaseMigrationContract) {
             providers.push({
                 provide: DatabaseMigrationContract,

src/test/mapper.spec.ts

@@ -104,9 +104,35 @@ describe('Mapper', () => {
         const database: Database = TestBed.get(Database);
         database.crud().then(crud => {
             const result = crud.insert(Cliente, clienteToSave).compile();
-            expect(result.params.toString()).toEqual([1, 'Razão', 'Apelido', false, 2, 3].toString());
+            expect(result.params.toString()).toEqual([
+                clienteToSave.id, clienteToSave.razaoSocial, clienteToSave.apelido,
+                clienteToSave.desativo, clienteToSave.cidade.id, clienteToSave.classificacao.id
+            ].toString());
             expect(result.query).toEqual('INSERT INTO Cliente (id, razaoSocial, apelido, desativo, cidade_id, classificacao_id) VALUES (?, ?, ?, ?, ?, ?)');
         });
     }));
 
+    it('Test transaction mapper insert T', async(() => {
+        const database: Database = TestBed.get(Database);
+        let rollback = () => {
+            database.rollbackTransaction().then().catch();
+        }
+        database.beginTransaction().then(crud => {
+            try {
+                const result = crud.insert(Cliente, clienteToSave).compile();
+                expect(result.params.toString()).toEqual([
+                    clienteToSave.id, clienteToSave.razaoSocial, clienteToSave.apelido,
+                    clienteToSave.desativo, clienteToSave.cidade.id, clienteToSave.classificacao.id
+                ].toString());
+                expect(result.query).toEqual('INSERT INTO Cliente (id, razaoSocial, apelido, desativo, cidade_id, classificacao_id) VALUES (?, ?, ?, ?, ?, ?)');
+                database.commitTransaction().then(x => {
+                    expect(x).toEqual(true);
+                }).catch(rollback);
+            }
+            catch (e) {
+                rollback();
+            }
+        });
+    }));
+
 });

src/utils/buildable-database-manager.ts

@@ -57,12 +57,37 @@ export abstract class BuildableDatabaseManager extends DatabaseManager {
         });
     }
 
+    public beginTransaction(): Promise<Crud> {
+        return new Promise((resolve, reject) => {
+            this.sql("BEGIN TRANSACTION").then(r => {
+                this.crud().then(crud => {
+                    resolve(crud);
+                }).catch(reject);
+            }).catch(reject);
+        });
+    }
+
+    public commitTransaction(): Promise<boolean> {
+        return new Promise((resolve, reject) => {
+            this.sql("COMMIT").then(r => {
+                resolve(true);
+            }).catch(reject);
+        });
+    }
+
+    public rollbackTransaction(): Promise<boolean> {
+        return new Promise((resolve, reject) => {
+            this.sql("ROLLBACK").then(r => {
+                resolve(true);
+            }).catch(reject);
+        });
+    }
+
     public crud(): Promise<Crud> {
         return new Promise((resolve, reject) => {
             this.databaseInstance().then(database => {
                 resolve(new Crud(database, this._mapper, this.enableLog));
-            })
-                .catch(reject);
+            }).catch(reject);
         });
     }
 
@@ -78,7 +103,7 @@ export abstract class BuildableDatabaseManager extends DatabaseManager {
                         resolve(cursor);
                     });
             })
-                .catch(reject);
+            .catch(reject);
         });
     }