From a7a2c226220a884db0dcd9143c52dde9663fbc10 Mon Sep 17 00:00:00 2001
From: sairajzero <sairaj0630@gmail.com>
Date: Thu, 2 Sep 2021 04:58:33 +0530
Subject: [PATCH] Update database.js

- Bug Fixed: Added commit to end a transaction
---
 src/database.js | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

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