RanchiMall/exchangemarket
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update database.js

Browse Source 
- Bug Fixed: Added commit to end a transaction
This commit is contained in:
sairajzero 2021-09-02 04:58:33 +05:30
parent 3eb9499713
commit a7a2c22622
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/database.js
View File

@ -33,7 +33,7 @@ function Database(user, password, dbname, host = 'localhost') {
Object.defineProperty(db, "TxQuery", { Object.defineProperty(db, "TxQuery", {
value: (queries) => new Promise((resolve, reject) => { value: (queries) => new Promise((resolve, reject) => {
db.connect.then(conn => { db.connect.then(conn => {
conn.beginTransaction((err) => { conn.beginTransaction(err => {
if (err) if (err)
conn.rollback(() => { conn.rollback(() => {
conn.release(); conn.release();
@ -42,8 +42,17 @@ function Database(user, password, dbname, host = 'localhost') {
else { else {
(function queryFn(result) { (function queryFn(result) {
if (!queries.length) { if (!queries.length) {
conn.release(); conn.commit(err => {
resolve(result); if (err)
conn.rollback(() => {
conn.release();
reject(err);
});
else {
conn.release();
resolve(result);
}
});
} else { } else {
let q_i = queries.shift(); let q_i = queries.shift();
const callback = function(err, res) { const callback = function(err, res) {