This commit is contained in:
Tben
2023-07-08 06:47:57 +01:00
parent 5215c06b18
commit 4452c04924
5 changed files with 29 additions and 15 deletions
-3
View File
@@ -133,9 +133,6 @@ async function addDb({ dbFullName, tableName, data, tableSchema, duplicateColumn
const query = `INSERT INTO \`${tableName}\` (${insertKeysArray.join(",")}) VALUES (${insertValuesArray.map(() => "?").join(",")})`;
const queryValuesArray = insertValuesArray;
console.log("DSQL: Query =>", query);
console.log("DSQL: Query Values =>", queryValuesArray);
const newInsert = await handler({
queryString: query,
database: dbFullName,
+5
View File
@@ -35,3 +35,8 @@ module.exports = dsqlEngine;
////////////////////////////////////////
////////////////////////////////////////
////////////////////////////////////////
exports.add = dsqlEngine.db.add;
exports.update = dsqlEngine.db.update;
exports.delete = dsqlEngine.db.delete;
exports.query = dsqlEngine.db.query;
+4 -2
View File
@@ -18,7 +18,7 @@ const parseDbResults = require("./parseDbResults");
*
* @returns {Promise<object[]|null>}
*/
module.exports = async function handler({ queryString, queryValuesArray, database, tableSchema, dbHost, dbUsername, dbPassword, encryptionKey, encryptionSalt }) {
async function handler({ queryString, queryValuesArray, database, tableSchema, dbHost, dbUsername, dbPassword, encryptionKey, encryptionSalt }) {
const mysql = require("serverless-mysql")({
config: {
host: dbHost,
@@ -89,4 +89,6 @@ module.exports = async function handler({ queryString, queryValuesArray, databas
console.log("\x1b[31mDSQL Database Handler No results returned\x1b[0m =>", results);
return null;
}
};
}
module.exports = handler;