Updates

dsql-app/package-shared/functions/backend/db/runQuery.js

@@ -18,6 +18,8 @@ const serverError = require("../serverError");
 const addDbEntry = require("./addDbEntry");
 const updateDbEntry = require("./updateDbEntry");
 const deleteDbEntry = require("./deleteDbEntry");
+const DB_HANDLER = require("../../../utils/backend/global-db/DB_HANDLER");
+const parseDbResults = require("../parseDbResults");
 
 /** ****************************************************************************** */
 /** ****************************************************************************** */
@@ -31,8 +33,9 @@ const deleteDbEntry = require("./deleteDbEntry");
  * ==============================================================================
  * @param {object} params - An object containing the function parameters.
  * @param {string} params.dbFullName - Database full name. Eg. "datasquire_user_2_test"
- * @param {string|any} params.query - Query string or object
+ * @param {string | any} params.query - Query string or object
  * @param {boolean} [params.readOnly] - Is this operation read only?
+ * @param {boolean} [params.local] - Is this operation read only?
  * @param {import("../../../types").DSQL_DatabaseSchemaType} [params.dbSchema] - Database schema
  * @param {string[]} [params.queryValuesArray] - An optional array of query values if "?" is used in the query string
  * @param {string} [params.tableName] - Table Name
@@ -46,6 +49,7 @@ async function runQuery({
     dbSchema,
     queryValuesArray,
     tableName,
+    local,
 }) {
     /**
      * Declare variables
@@ -85,7 +89,15 @@ async function runQuery({
      */
     try {
         if (typeof query === "string") {
-            if (readOnly) {
+            if (local) {
+                const rawResults = await DB_HANDLER(query, queryValuesArray);
+                result = tableSchema
+                    ? parseDbResults({
+                          unparsedResults: rawResults,
+                          tableSchema,
+                      })
+                    : rawResults;
+            } else if (readOnly) {
                 result = await varReadOnlyDatabaseDbHandler({
                     queryString: query,
                     queryValuesArray,
@@ -120,7 +132,7 @@ async function runQuery({
             switch (action.toLowerCase()) {
                 case "insert":
                     result = await addDbEntry({
-                        dbContext: "Dsql User",
+                        dbContext: local ? "Master" : "Dsql User",
                         paradigm: "Full Access",
                         dbFullName: dbFullName,
                         tableName: table,
@@ -139,7 +151,7 @@ async function runQuery({
 
                 case "update":
                     result = await updateDbEntry({
-                        dbContext: "Dsql User",
+                        dbContext: local ? "Master" : "Dsql User",
                         paradigm: "Full Access",
                         dbFullName: dbFullName,
                         tableName: table,
@@ -153,7 +165,7 @@ async function runQuery({
 
                 case "delete":
                     result = await deleteDbEntry({
-                        dbContext: "Dsql User",
+                        dbContext: local ? "Master" : "Dsql User",
                         paradigm: "Full Access",
                         dbFullName: dbFullName,
                         tableName: table,