fix(db): incorrect error handling when no callback is defined

Partly reverts some changes made for the experimental
transaction export.

Author: thelindat

src/database/rawExecute.ts

@@ -83,8 +83,6 @@ export const rawExecute = async (
       }
     }
   } catch (err: any) {
-    if (!cb) throw new Error(err.message || err);
-
     logError(invokingResource, cb, isPromise, err, query, parameters);
   } finally {
     connection.release();

src/database/rawQuery.ts

@@ -21,7 +21,7 @@ export const rawQuery = async (
   try {
     [query, parameters] = parseArguments(query, parameters);
   } catch (err: any) {
-    return logError(invokingResource, cb, err, isPromise, query, parameters);
+    return logError(invokingResource, cb, isPromise, err, query, parameters);
   }
 
   const connection = await getPoolConnection(connectionId);
@@ -54,8 +54,6 @@ export const rawQuery = async (
       }
     }
   } catch (err: any) {
-    if (!cb) throw new Error(err.message || err);
-
     logError(invokingResource, cb, isPromise, err, query, parameters, true);
   } finally {
     connection.release();

src/database/startTransaction.ts

@@ -1,8 +1,6 @@
 import { getPoolConnection } from './connection';
 import { logError } from '../logger';
 import { CFXCallback, CFXParameters } from '../types';
-import { rawQuery } from './rawQuery';
-import { rawExecute } from './rawExecute';
 
 export const startTransaction = async (
   invokingResource: string,
@@ -17,15 +15,14 @@ export const startTransaction = async (
   let response = false;
 
   try {
-    const connectionId = (conn as any).connection.connectionId;
     await conn.beginTransaction();
 
     const commit = await queries({
       query: (sql: string, values: CFXParameters) => {
-        return rawQuery(null, invokingResource, sql, values, undefined, isPromise, connectionId);
+        return conn.query(sql, values);
       },
       execute: (sql: string, values: CFXParameters) => {
-        return rawExecute(invokingResource, sql, values, undefined, isPromise, connectionId);
+        return conn.execute(sql, values);
       },
     });