n0m/PawSQLite-Node-Adapter
n0m/PawSQLite-Node-Adapter
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: n0m:fe4936c7f84cdaecc7207c67688eba0ef217421d
Branches Tags
n0m:master
..
compare: n0m:35de9497888e6f11e8736c4fd2f7783717090237
Branches Tags
n0m:master

No commits in common. "fe4936c7f84cdaecc7207c67688eba0ef217421d" and "35de9497888e6f11e8736c4fd2f7783717090237" have entirely different histories.
fe4936c7f8 ... 35de949788

3 changed files with 3 additions and 51 deletions
Show Stats Expand all files Collapse all files

26
cjs/pawsqlite-node-adapter.js
View File

@ -153,41 +153,17 @@ class QueryWrapper {
execute(db) {
if (this.isAnyOf("INSERT", "UPDATE", "DELETE")) {
return this.executeRun(db);
} else if (this.isAnyOf("PRAGMA")) {
return this.executeGet(db);
} else {
return this.executeAll(db);
}
}
executeGet(db) {
return new Promise((resolve, reject) => {
const self = this;
(0,_log_mjs__WEBPACK_IMPORTED_MODULE_2__.log)(this.sql);
db.get(this.sql, ...this.args, function (err, row) {
if (err) {
reject(_node_adapter_error_mjs__WEBPACK_IMPORTED_MODULE_0__.NodeAdapterError.from(err));
return;
}
const result = {};
if (row) {
result.rows = [row];
}
resolve(_response_wrapper_mjs__WEBPACK_IMPORTED_MODULE_1__.ResponseWrapper.success(result));
});
});
}
executeRun(db) {
return new Promise((resolve, reject) => {
const self = this;
(0,_log_mjs__WEBPACK_IMPORTED_MODULE_2__.log)(this.sql);
db.get(this.sql, ...this.args, function (err) {
db.run(this.sql, ...this.args, function (err) {
if (err) {
reject(_node_adapter_error_mjs__WEBPACK_IMPORTED_MODULE_0__.NodeAdapterError.from(err));
return;

2
cjs/pawsqlite-node-adapter.js.map
View File

File diff suppressed because one or more lines are too long

26
src/query_wrapper.mjs
View File

@ -22,41 +22,17 @@ export class QueryWrapper {
execute(db) {
if (this.isAnyOf("INSERT", "UPDATE", "DELETE")) {
return this.executeRun(db);
} else if (this.isAnyOf("PRAGMA")) {
return this.executeGet(db);
} else {
return this.executeAll(db);
}
}
executeGet(db) {
return new Promise((resolve, reject) => {
const self = this;
log(this.sql);
db.get(this.sql, ...this.args, function (err, row) {
if (err) {
reject(NodeAdapterError.from(err));
return;
}
const result = {};
if (row) {
result.rows = [row];
}
resolve(ResponseWrapper.success(result));
});
});
}
executeRun(db) {
return new Promise((resolve, reject) => {
const self = this;
log(this.sql);
db.get(this.sql, ...this.args, function (err) {
db.run(this.sql, ...this.args, function (err) {
if (err) {
reject(NodeAdapterError.from(err));
return;