@magieno/sqlite-client
Advanced tools
Comparing version 3.45.1-build1 to 3.45.1-build1-with-extension-support
@@ -29,4 +29,4 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
} | ||
executeSql(sqlStatement, bindParameters = [], returnValue = ReturnValueEnum.ResultRows, rowMode = RowModeEnum.Array) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
executeSql(sqlStatement_1) { | ||
return __awaiter(this, arguments, void 0, function* (sqlStatement, bindParameters = [], returnValue = ReturnValueEnum.ResultRows, rowMode = RowModeEnum.Array) { | ||
return this.db.exec({ | ||
@@ -33,0 +33,0 @@ sql: sqlStatement, |
@@ -23,4 +23,4 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
} | ||
executeSql(sqlStatement, bindParameters = [], returnValue = ReturnValueEnum.ResultRows, rowMode = RowModeEnum.Array) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
executeSql(sqlStatement_1) { | ||
return __awaiter(this, arguments, void 0, function* (sqlStatement, bindParameters = [], returnValue = ReturnValueEnum.ResultRows, rowMode = RowModeEnum.Array) { | ||
return this.proxy.executeSql(sqlStatement, bindParameters, returnValue, rowMode); | ||
@@ -27,0 +27,0 @@ }); |
@@ -16,3 +16,2 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
const log = (...args) => console.log(...args); | ||
const error = (...args) => console.error(...args); | ||
class SqliteClientWorker { | ||
@@ -40,6 +39,11 @@ constructor() { | ||
const uniqueId = createDatabaseMessage.uniqueId; | ||
const errorHandler = (error) => { | ||
console.error(error); | ||
this.postBackMessageToMainThread(new CreateDatabaseResultMessage(uniqueId, error)); | ||
return; | ||
}; | ||
try { | ||
const sqlite3 = yield sqlite3InitModule({ | ||
print: log, | ||
printErr: error, | ||
printErr: errorHandler, | ||
}); | ||
@@ -57,4 +61,3 @@ switch (createDatabaseMessage.options.type) { | ||
catch (err) { | ||
error(err.name, err.message); | ||
this.postBackMessageToMainThread(new CreateDatabaseResultMessage(uniqueId, err)); | ||
errorHandler(err); | ||
} | ||
@@ -69,4 +72,3 @@ break; | ||
catch (err) { | ||
error(err.name, err.message); | ||
this.postBackMessageToMainThread(new CreateDatabaseResultMessage(uniqueId, err)); | ||
errorHandler(err); | ||
} | ||
@@ -86,4 +88,3 @@ break; | ||
catch (err) { | ||
error(err.name, err.message); | ||
this.postBackMessageToMainThread(new CreateDatabaseResultMessage(uniqueId, err)); | ||
errorHandler(err); | ||
} | ||
@@ -94,4 +95,3 @@ break; | ||
catch (err) { | ||
error(err.name, err.message); | ||
this.postBackMessageToMainThread(new CreateDatabaseResultMessage(uniqueId, err)); | ||
errorHandler(err); | ||
} | ||
@@ -98,0 +98,0 @@ }); |
@@ -5,2 +5,8 @@ import { SqliteClientOptions } from "./types/sqlite-client.options"; | ||
import { RowModeEnum } from "./enums/row-mode.enum"; | ||
export * from "./adapters/adapters"; | ||
export * from "./enums/enums"; | ||
export * from "./interfaces/interfaces"; | ||
export * from "./messages/messages"; | ||
export * from "./proxies/proxies"; | ||
export * from "./types/types"; | ||
export declare class SqliteClient { | ||
@@ -7,0 +13,0 @@ private readonly options; |
@@ -15,2 +15,9 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
import { InWorkerSqliteAdapter } from "./adapters/in-worker.sqlite-adapter"; | ||
import { SqliteClientExtension } from "./sqlite-client-extension"; | ||
export * from "./adapters/adapters"; | ||
export * from "./enums/enums"; | ||
export * from "./interfaces/interfaces"; | ||
export * from "./messages/messages"; | ||
export * from "./proxies/proxies"; | ||
export * from "./types/types"; | ||
export class SqliteClient { | ||
@@ -27,2 +34,3 @@ constructor(options) { | ||
this.adapter = new InWorkerSqliteAdapter(this.options); | ||
SqliteClientExtension.registerWorkerPath(this.options.sqliteWorkerPath); | ||
break; | ||
@@ -38,4 +46,4 @@ default: | ||
} | ||
executeSql(sqlStatement, bindParameters = [], returnValue = ReturnValueEnum.ResultRows, rowMode = RowModeEnum.Array) { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
executeSql(sqlStatement_1) { | ||
return __awaiter(this, arguments, void 0, function* (sqlStatement, bindParameters = [], returnValue = ReturnValueEnum.ResultRows, rowMode = RowModeEnum.Array) { | ||
if (this.adapter === undefined) { | ||
@@ -48,2 +56,3 @@ throw new Error("You need to call `init` before calling `executeSql`."); | ||
} | ||
SqliteClientExtension.register(); | ||
//# sourceMappingURL=sqlite-client.js.map |
{ | ||
"name": "@magieno/sqlite-client", | ||
"version": "3.45.1-build1", | ||
"version": "3.45.1-build1-with-extension-support", | ||
"description": "SQLite Client is a wrapper for Sqlite on Wasm that uses the Origin Private File System to persist the sqlite database file.", | ||
@@ -52,3 +52,3 @@ "keywords": [ | ||
"rollup-plugin-typescript2": "^0.34.1", | ||
"typescript": "^5.0.4" | ||
"typescript": "^5.4.3" | ||
}, | ||
@@ -55,0 +55,0 @@ "files": [ |
Sorry, the diff of this file is too big to display
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
1017103
86
27427