diff --git a/dist/package-shared/utils/db/conn-db-handler.d.ts b/dist/package-shared/utils/db/conn-db-handler.d.ts index d97332f..d770791 100644 --- a/dist/package-shared/utils/db/conn-db-handler.d.ts +++ b/dist/package-shared/utils/db/conn-db-handler.d.ts @@ -13,11 +13,11 @@ export default function connDbHandler( /** * ServerlessMySQL Connection Object */ -conn: ServerlessMysql, +conn?: ServerlessMysql, /** * String Or `QueryObject` Array */ -query: QueryObject["query"] | QueryObject[], +query?: QueryObject["query"] | QueryObject[], /** * Array of Values to Sanitize and Inject */ diff --git a/dist/package-shared/utils/db/conn-db-handler.js b/dist/package-shared/utils/db/conn-db-handler.js index be6b918..34fde60 100644 --- a/dist/package-shared/utils/db/conn-db-handler.js +++ b/dist/package-shared/utils/db/conn-db-handler.js @@ -30,6 +30,10 @@ query, values) { return __awaiter(this, void 0, void 0, function* () { try { + if (!conn) + throw new Error("No Connection Found!"); + if (!query) + throw new Error("Query String Required!"); if (typeof query == "string") { const res = yield conn.query(trimQuery(query), values); return JSON.parse(JSON.stringify(res)); @@ -43,6 +47,7 @@ values) { resArray.push(JSON.parse(JSON.stringify(queryObjRes))); } catch (error) { + console.log(`connDbHandler Query Error: ${error.message}`); resArray.push(null); } } @@ -53,10 +58,11 @@ values) { } } catch (error) { + console.log(`connDbHandler Error: ${error.message}`); return null; } finally { - conn.end(); + conn === null || conn === void 0 ? void 0 : conn.end(); } }); } diff --git a/package-shared/utils/db/conn-db-handler.ts b/package-shared/utils/db/conn-db-handler.ts index 637df4a..1d9d8ff 100644 --- a/package-shared/utils/db/conn-db-handler.ts +++ b/package-shared/utils/db/conn-db-handler.ts @@ -16,17 +16,20 @@ export default async function connDbHandler( /** * ServerlessMySQL Connection Object */ - conn: ServerlessMysql, + conn?: ServerlessMysql, /** * String Or `QueryObject` Array */ - query: QueryObject["query"] | QueryObject[], + query?: QueryObject["query"] | QueryObject[], /** * Array of Values to Sanitize and Inject */ values?: QueryObject["values"] ): Promise> { try { + if (!conn) throw new Error("No Connection Found!"); + if (!query) throw new Error("Query String Required!"); + if (typeof query == "string") { const res = await conn.query(trimQuery(query), values); return JSON.parse(JSON.stringify(res)); @@ -41,7 +44,8 @@ export default async function connDbHandler( queryObj.values ); resArray.push(JSON.parse(JSON.stringify(queryObjRes))); - } catch (error) { + } catch (error: any) { + console.log(`connDbHandler Query Error: ${error.message}`); resArray.push(null); } } @@ -50,10 +54,11 @@ export default async function connDbHandler( } else { return null; } - } catch (error) { + } catch (error: any) { + console.log(`connDbHandler Error: ${error.message}`); return null; } finally { - conn.end(); + conn?.end(); } } diff --git a/package.json b/package.json index 1f446db..d2b32bc 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@moduletrace/datasquirel", - "version": "3.6.6", + "version": "3.6.7", "description": "Cloud-based SQL data management tool", "main": "dist/index.js", "bin": {