This commit is contained in:
Benjamin Toby
2025-04-23 14:35:42 +01:00
parent 22f4372cbf
commit daad62141e
6 changed files with 63 additions and 6 deletions
+28 -1
View File
@@ -1,4 +1,5 @@
import { ServerlessMysql } from "serverless-mysql";
import debugLog from "../logging/debug-log";
type QueryObject = {
query: string;
@@ -24,7 +25,8 @@ export default async function connDbHandler<ReturnType = any>(
/**
* Array of Values to Sanitize and Inject
*/
values?: QueryObject["values"]
values?: QueryObject["values"],
debug?: boolean
): Promise<Return<ReturnType>> {
try {
if (!conn) throw new Error("No Connection Found!");
@@ -32,6 +34,14 @@ export default async function connDbHandler<ReturnType = any>(
if (typeof query == "string") {
const res = await conn.query(trimQuery(query), values);
if (debug) {
debugLog({
log: res,
addTime: true,
label: "res",
});
}
return JSON.parse(JSON.stringify(res));
} else if (typeof query == "object") {
const resArray = [];
@@ -43,6 +53,15 @@ export default async function connDbHandler<ReturnType = any>(
trimQuery(queryObj.query),
queryObj.values
);
if (debug) {
debugLog({
log: queryObjRes,
addTime: true,
label: "queryObjRes",
});
}
resArray.push(JSON.parse(JSON.stringify(queryObjRes)));
} catch (error: any) {
global.ERROR_CALLBACK?.(
@@ -53,6 +72,14 @@ export default async function connDbHandler<ReturnType = any>(
}
}
if (debug) {
debugLog({
log: resArray,
addTime: true,
label: "resArray",
});
}
return resArray as any;
} else {
return null;