jeep-sqlite
Advanced tools
Comparing version 2.5.0 to 2.5.1
@@ -198,3 +198,6 @@ import initSqlJs from "sql.js"; | ||
try { | ||
this.setIsTransActive(await UtilsSQLite.beginTransaction(this.mDb, true)); | ||
console.log(`&&&&& in jeep database before beginTransaction: ${this.isTransActive()}`); | ||
await UtilsSQLite.beginTransaction(this.mDb, true); | ||
this.setIsTransActive(true); | ||
console.log(`&&&&& in jeep database after beginTransaction: ${this.isTransActive()}`); | ||
return 0; | ||
@@ -204,2 +207,3 @@ } | ||
let msg = `BeginTransaction: ${err.message}`; | ||
console.log(`&&&&& in jeep database begin Transaction Error: ${err.message}`); | ||
return Promise.reject(new Error(`${msg}`)); | ||
@@ -215,3 +219,6 @@ } | ||
try { | ||
this.setIsTransActive(await UtilsSQLite.commitTransaction(this.mDb, true)); | ||
console.log(`&&&&& in jeep database before commitTransaction: ${this.isTransActive()}`); | ||
await UtilsSQLite.commitTransaction(this.mDb, true); | ||
this.setIsTransActive(false); | ||
console.log(`&&&&& in jeep database after commitTransaction: ${this.isTransActive()}`); | ||
return 0; | ||
@@ -221,2 +228,3 @@ } | ||
let msg = `CommitTransaction: ${err.message}`; | ||
console.log(`&&&&& in jeep database commitTransaction Error: ${err.message}`); | ||
return Promise.reject(new Error(`${msg}`)); | ||
@@ -232,3 +240,6 @@ } | ||
try { | ||
this.setIsTransActive(await UtilsSQLite.rollbackTransaction(this.mDb, true)); | ||
console.log(`&&&&& in jeep database before rollbackTransaction: ${this.isTransActive()}`); | ||
await UtilsSQLite.rollbackTransaction(this.mDb, true); | ||
this.setIsTransActive(false); | ||
console.log(`&&&&& in jeep database after rollbackTransaction: ${this.isTransActive()}`); | ||
return 0; | ||
@@ -238,2 +249,3 @@ } | ||
let msg = `RollbackTransaction: ${err.message}`; | ||
console.log(`&&&&& in jeep database rollbackTransaction Error: ${err.message}`); | ||
return Promise.reject(new Error(`${msg}`)); | ||
@@ -255,2 +267,3 @@ } | ||
let initChanges = -1; | ||
console.log(`>>>> in executeSQL: ${sql}, ${transaction} , ${this.isTransactionActive}`); | ||
try { | ||
@@ -271,4 +284,8 @@ initChanges = await UtilsSQLite.dbChanges(this.mDb); | ||
} | ||
if (transaction && this.isTransactionActive) | ||
console.log(`>>>> in executeSQL before commit : ${sql}, ${transaction} , ${this.isTransactionActive}`); | ||
if (transaction && this.isTransactionActive) { | ||
console.log(`>>>> in executeSQL going to commit`); | ||
await this.commitTransaction(); | ||
console.log(`>>>> in executeSQL after commit : ${sql}, ${transaction} , ${this.isTransactionActive}`); | ||
} | ||
const changes = (await UtilsSQLite.dbChanges(this.mDb)) - initChanges; | ||
@@ -300,2 +317,3 @@ return Promise.resolve(changes); | ||
} | ||
console.log(`>>>> in executeSQL end : ${transaction} , ${this.isTransactionActive}`); | ||
} | ||
@@ -381,2 +399,4 @@ } | ||
} | ||
console.log(`>>>> in runSQL: ${statement}, ${transaction} , ${this.isTransactionActive}`); | ||
console.log(`>>>> in runSQL: ${values}, ${transaction} , ${this.isTransactionActive}`); | ||
const retRes = { changes: -1, lastId: -1 }; | ||
@@ -387,2 +407,3 @@ let initChanges = -1; | ||
if (transaction && !this.isTransactionActive) { | ||
console.log(`>>>> in runSQL going to beginTransaction`); | ||
await this.beginTransaction(); | ||
@@ -401,4 +422,7 @@ } | ||
} | ||
if (transaction && this.isTransactionActive) | ||
if (transaction && this.isTransactionActive) { | ||
console.log(`>>>> in runSQL going to commitTransaction`); | ||
await this.commitTransaction(); | ||
console.log(`>>>> in runSQL after commit : ${statement}, ${transaction} , ${this.isTransactionActive}`); | ||
} | ||
const changes = (await UtilsSQLite.dbChanges(this.mDb)) - initChanges; | ||
@@ -413,4 +437,6 @@ retRes.changes = changes; | ||
try { | ||
if (transaction && this.isTransactionActive) | ||
if (transaction && this.isTransactionActive) { | ||
console.log(`>>>> in runSQL going to rollbackTransaction`); | ||
await this.rollbackTransaction(); | ||
} | ||
} | ||
@@ -417,0 +443,0 @@ catch (err) { |
@@ -29,3 +29,4 @@ import { UtilsSQLite } from "./utils-sqlite"; | ||
// start a transaction | ||
mDB.setIsTransActive(await UtilsSQLite.beginTransaction(db, true)); | ||
await UtilsSQLite.beginTransaction(db, true); | ||
mDB.setIsTransActive(true); | ||
} | ||
@@ -42,3 +43,4 @@ catch (err) { | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.rollbackTransaction(db, true)); | ||
await UtilsSQLite.rollbackTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
} | ||
@@ -53,3 +55,4 @@ catch (err) { | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.rollbackTransaction(db, true)); | ||
await UtilsSQLite.rollbackTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
return Promise.reject(new Error(`CreateSchema: ${msg}`)); | ||
@@ -63,3 +66,4 @@ } | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.commitTransaction(db, true)); | ||
await UtilsSQLite.commitTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
return Promise.resolve(changes); | ||
@@ -168,3 +172,4 @@ } | ||
// start a transaction | ||
mDB.setIsTransActive(await UtilsSQLite.beginTransaction(db, true)); | ||
await UtilsSQLite.beginTransaction(db, true); | ||
mDB.setIsTransActive(true); | ||
} | ||
@@ -194,3 +199,4 @@ catch (err) { | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.commitTransaction(db, true)); | ||
await UtilsSQLite.commitTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
changes = (await UtilsSQLite.dbChanges(db)) - initChanges; | ||
@@ -206,3 +212,4 @@ return Promise.resolve(changes); | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.rollbackTransaction(db, true)); | ||
await UtilsSQLite.rollbackTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
return Promise.reject(new Error(`CreateTablesData: ${msg}`)); | ||
@@ -461,3 +468,4 @@ } | ||
// start a transaction | ||
mDB.setIsTransActive(await UtilsSQLite.beginTransaction(db, true)); | ||
await UtilsSQLite.beginTransaction(db, true); | ||
mDB.setIsTransActive(true); | ||
} | ||
@@ -483,3 +491,4 @@ catch (err) { | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.commitTransaction(db, true)); | ||
await UtilsSQLite.commitTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
changes = (await UtilsSQLite.dbChanges(db)) - initChanges; | ||
@@ -495,3 +504,4 @@ return Promise.resolve(changes); | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.rollbackTransaction(db, true)); | ||
await UtilsSQLite.rollbackTransaction(db, true); | ||
mDB.setIsTransActive(false); | ||
return Promise.reject(new Error(`createViews: ${msg}`)); | ||
@@ -498,0 +508,0 @@ } |
@@ -11,6 +11,5 @@ import { UtilsDrop } from "../utils/utils-drop"; | ||
} | ||
const sql = 'BEGIN TRANSACTION;'; | ||
try { | ||
db.exec(sql); | ||
return Promise.resolve(true); | ||
db.exec('BEGIN'); | ||
return Promise.resolve(); | ||
} | ||
@@ -26,6 +25,5 @@ catch (err) { | ||
} | ||
const sql = 'ROLLBACK;'; | ||
try { | ||
db.exec(sql); | ||
return Promise.resolve(false); | ||
db.exec('ROLLBACK'); | ||
return Promise.resolve(); | ||
} | ||
@@ -36,3 +34,3 @@ catch (err) { | ||
} | ||
static async commitTransaction(db, isOpen) { | ||
static commitTransaction(db, isOpen) { | ||
const msg = 'CommitTransaction: '; | ||
@@ -42,8 +40,9 @@ if (!isOpen) { | ||
} | ||
const sql = 'COMMIT;'; | ||
const sql = 'COMMIT'; | ||
try { | ||
db.exec(sql); | ||
return Promise.resolve(false); | ||
return Promise.resolve(); | ||
} | ||
catch (err) { | ||
console.log(`${err.message}`); | ||
return Promise.reject(new Error(`${msg}${err.message}`)); | ||
@@ -50,0 +49,0 @@ } |
@@ -34,11 +34,14 @@ import { UtilsSQLite } from "../utils/utils-sqlite"; | ||
try { | ||
mDB.setIsTransActive(await UtilsSQLite.beginTransaction(mDB.mDb, true)); | ||
await UtilsSQLite.beginTransaction(mDB.mDb, true); | ||
mDB.setIsTransActive(true); | ||
for (const statement of statements) { | ||
await UtilsSQLite.execute(mDB.mDb, statement, false); | ||
} | ||
mDB.setIsTransActive(await UtilsSQLite.commitTransaction(mDB.mDb, true)); | ||
await UtilsSQLite.commitTransaction(mDB.mDb, true); | ||
mDB.setIsTransActive(false); | ||
return Promise.resolve(); | ||
} | ||
catch (err) { | ||
mDB.setIsTransActive(await UtilsSQLite.rollbackTransaction(mDB.mDb, true)); | ||
await UtilsSQLite.rollbackTransaction(mDB.mDb, true); | ||
mDB.setIsTransActive(false); | ||
return Promise.reject(`ExecuteStatementProcess: ${err}`); | ||
@@ -45,0 +48,0 @@ } |
@@ -1,2 +0,2 @@ | ||
import{p as e,b as t}from"./p-afe75585.js";export{s as setNonce}from"./p-afe75585.js";const o=()=>{const t=import.meta.url;const o={};if(t!==""){o.resourcesUrl=new URL(".",t).href}return e(o)};o().then((e=>t([["p-b6434b38",[[1,"jeep-sqlite",{autoSave:[516,"autosave"],typeOrm:[516,"typeorm"],wasmPath:[513,"wasmpath"],pickText:[513,"picktext"],saveText:[513,"savetext"],buttonOptions:[513,"buttonoptions"],innerAutoSave:[32],innerTypeOrm:[32],innerWasmPath:[32],innerPickText:[32],innerSaveText:[32],innerButtonOptions:[32],echo:[64],createConnection:[64],isConnection:[64],closeConnection:[64],open:[64],close:[64],getVersion:[64],beginTransaction:[64],commitTransaction:[64],rollbackTransaction:[64],isTransactionActive:[64],execute:[64],executeSet:[64],run:[64],query:[64],getTableList:[64],isDBExists:[64],isDBOpen:[64],deleteDatabase:[64],isStoreOpen:[64],copyFromAssets:[64],isTableExists:[64],createSyncTable:[64],getSyncDate:[64],setSyncDate:[64],isJsonValid:[64],importFromJson:[64],exportToJson:[64],deleteExportedRows:[64],addUpgradeStatement:[64],isDatabase:[64],getDatabaseList:[64],checkConnectionsConsistency:[64],saveToStore:[64],saveToLocalDisk:[64],getFromLocalDiskToStore:[64],getFromHTTPRequest:[64]}]]]],e))); | ||
import{p as e,b as t}from"./p-afe75585.js";export{s as setNonce}from"./p-afe75585.js";const o=()=>{const t=import.meta.url;const o={};if(t!==""){o.resourcesUrl=new URL(".",t).href}return e(o)};o().then((e=>t([["p-99fcade1",[[1,"jeep-sqlite",{autoSave:[516,"autosave"],typeOrm:[516,"typeorm"],wasmPath:[513,"wasmpath"],pickText:[513,"picktext"],saveText:[513,"savetext"],buttonOptions:[513,"buttonoptions"],innerAutoSave:[32],innerTypeOrm:[32],innerWasmPath:[32],innerPickText:[32],innerSaveText:[32],innerButtonOptions:[32],echo:[64],createConnection:[64],isConnection:[64],closeConnection:[64],open:[64],close:[64],getVersion:[64],beginTransaction:[64],commitTransaction:[64],rollbackTransaction:[64],isTransactionActive:[64],execute:[64],executeSet:[64],run:[64],query:[64],getTableList:[64],isDBExists:[64],isDBOpen:[64],deleteDatabase:[64],isStoreOpen:[64],copyFromAssets:[64],isTableExists:[64],createSyncTable:[64],getSyncDate:[64],setSyncDate:[64],isJsonValid:[64],importFromJson:[64],exportToJson:[64],deleteExportedRows:[64],addUpgradeStatement:[64],isDatabase:[64],getDatabaseList:[64],checkConnectionsConsistency:[64],saveToStore:[64],saveToLocalDisk:[64],getFromLocalDiskToStore:[64],getFromHTTPRequest:[64]}]]]],e))); | ||
//# sourceMappingURL=jeep-sqlite.esm.js.map |
export declare class UtilsSQLite { | ||
static beginTransaction(db: any, isOpen: boolean): Promise<boolean>; | ||
static rollbackTransaction(db: any, isOpen: boolean): Promise<boolean>; | ||
static commitTransaction(db: any, isOpen: boolean): Promise<boolean>; | ||
static beginTransaction(db: any, isOpen: boolean): Promise<void>; | ||
static rollbackTransaction(db: any, isOpen: boolean): Promise<void>; | ||
static commitTransaction(db: any, isOpen: boolean): Promise<void>; | ||
static dbChanges(db: any): Promise<number>; | ||
@@ -6,0 +6,0 @@ static getLastId(db: any): Promise<number>; |
{ | ||
"name": "jeep-sqlite", | ||
"version": "2.5.0", | ||
"version": "2.5.1", | ||
"description": "Browser SQLite Stencil Component", | ||
@@ -34,2 +34,3 @@ "main": "dist/index.cjs.js", | ||
"@types/node": "^16.18.11", | ||
"@types/sql.js": "^1.4.4", | ||
"jest": "^27.5.1", | ||
@@ -36,0 +37,0 @@ "jest-cli": "^27.5.1", |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
7919115
45291
7