new onTransaction method

README.md

@@ -19,7 +19,7 @@ tns plugin add [email protected]
 `@nativescript/core?`
 
 ```bash
-tns plugin add nativescript-sqlite-access@1.1.0
+tns plugin add nativescript-sqlite-access@1.2.0
 ```
 The command above automatically installs the necessary files, as well as stores nativescript-sqlite-access as a dependency in your project's package.json file.
 

demo/app/tests/insert.spec.ts

@@ -34,7 +34,7 @@ describe("#insert()", () => {
 
 	describe("Transaction", () => {
 		describe("Commit", () => {
-			it("shoould committed the insert", () => {
+			it("should committed the insert", () => {
 				database.beginTransact();
 				const insertedId = database.insert(databaseTables.PERSONS, {
 					name: "Power Ranger"
@@ -44,7 +44,7 @@ describe("#insert()", () => {
 			});
 		});
 		describe("Roollback", () => {
-			it("shoould rollback the inserts", async () => {
+			it("should rollback the inserts", async () => {
 				database.beginTransact();
 				database.insert(databaseTables.PERSONS, {
 					name: "Power Ranger 1"
@@ -57,14 +57,56 @@ describe("#insert()", () => {
 				});
 				database.rollback();
 
-				const resutls = await database.select(`SELECT COUNT(*) account FROM ${databaseTables.PERSONS}`)
+				const results = await database.select(`SELECT name FROM ${databaseTables.PERSONS}`)
 					.process() as Array<Record<string, unknown>>;
 
 				expect(
-					resutls.filter( p => [ "Power Ranger 1", "Power Ranger 2", "Power Ranger 3" ].includes(p.name as string))
+					results.filter( p => [ "Power Ranger 1", "Power Ranger 2", "Power Ranger 3" ].includes(p.name as string))
 				).to.deep.equal([]);
 			});
 		});
+		describe("onTransaction", () => {
+			it("should commit the inserts", async () => {
+				database.onTransaction(() => {
+					database.insert(databaseTables.PERSONS, {
+						name: "Power Ranger commit1"
+					});
+					database.insert(databaseTables.PERSONS, {
+						name: "Power Ranger commit2"
+					});
+					database.insert(databaseTables.PERSONS, {
+						name: "Power Ranger commit3"
+					});
+				});
+
+				const results = await database.select<Array<Record<string, unknown>>>(`SELECT name FROM ${databaseTables.PERSONS}`)
+					.process();
+
+				expect(
+					results.map( p => p.name)
+				).to.deep.equal([ "Power Ranger", "Power Ranger commit1", "Power Ranger commit2", "Power Ranger commit3" ]);
+			});
+			it("should throw on rollback", async () => {
+				expect(
+					() => database.onTransaction(() => {
+						database.insert(databaseTables.PERSONS, {
+							name: "Power Ranger rollback1"
+						});
+						database.insert(databaseTables.PERSONS, {
+							name: "Power Ranger rollback2"
+						});
+
+						database.insert(databaseTables.PERSONS, {
+							_id: "Power Ranger rollback3"
+						});
+
+						database.insert(databaseTables.PERSONS, {
+							name: "Power Ranger rollback3"
+						});
+					})
+				).to.throws()
+			});
+		});
 	});
 
 	after(() => {

src/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "nativescript-sqlite-access",
-	"version": "1.1.0",
+	"version": "1.2.0",
 	"description": "NativeScript plugin to access and manage sqlite data on Android & iOS",
 	"main": "sqlite-access",
 	"typings": "index.d.ts",

src/sqlite-access.android.d.ts

@@ -33,6 +33,7 @@ declare class SqliteAccess implements IDatabase {
     rollback(): void;
     close(): void;
     isClose(): boolean;
+    onTransaction<T>(callback: () => T): T;
 }
 export declare function DbBuilder(dbName: string, options?: DbCreationOptions): SqliteAccess;
 export * from "./sqlite-access.common";

src/sqlite-access.android.ts

@@ -25,6 +25,7 @@ class SqliteAccess implements IDatabase {
 	 */
 	constructor(private db: android.database.sqlite.SQLiteDatabase, private returnType: ReturnType) { }
 
+
 	/**
 	 * Insert a row into table with the values (key = columns and values = columns value)
 	 *
@@ -214,6 +215,19 @@ class SqliteAccess implements IDatabase {
 	isClose(): boolean {
 		return this.db === null;
 	}
+
+	onTransaction<T>(callback: () => T): T {
+		try {
+			this.beginTransact();
+			const result: T  = callback();
+			this.commit();
+
+			return result;
+		} catch (error) {
+			this.rollback();
+			throw error;
+		}
+	}
 }
 
 /** private function