This commit is contained in:
Benjamin Toby
2025-04-23 14:27:27 +01:00
parent 2ad17ae682
commit 18cbf9b2f4
8 changed files with 64 additions and 3 deletions
+1
View File
@@ -45,6 +45,7 @@ function apiPost(_a) {
tableName,
dbContext,
forceLocal,
debug,
});
if (debug) {
(0, debug_log_1.default)({
+2 -1
View File
@@ -12,9 +12,10 @@ type Param = {
encryptionKey?: string;
encryptionSalt?: string;
forceLocal?: boolean;
debug?: boolean;
};
/**
* Add a db Entry Function
*/
export default function addDbEntry({ dbContext, paradigm, dbFullName, tableName, data, tableSchema, duplicateColumnName, duplicateColumnValue, update, encryptionKey, encryptionSalt, forceLocal, }: Param): Promise<any>;
export default function addDbEntry({ dbContext, paradigm, dbFullName, tableName, data, tableSchema, duplicateColumnName, duplicateColumnValue, update, encryptionKey, encryptionSalt, forceLocal, debug, }: Param): Promise<any>;
export {};
+26 -1
View File
@@ -19,11 +19,12 @@ const updateDbEntry_1 = __importDefault(require("./updateDbEntry"));
const encrypt_1 = __importDefault(require("../../dsql/encrypt"));
const conn_db_handler_1 = __importDefault(require("../../../utils/db/conn-db-handler"));
const check_if_is_master_1 = __importDefault(require("../../../utils/check-if-is-master"));
const debug_log_1 = __importDefault(require("../../../utils/logging/debug-log"));
/**
* Add a db Entry Function
*/
function addDbEntry(_a) {
return __awaiter(this, arguments, void 0, function* ({ dbContext, paradigm, dbFullName, tableName, data, tableSchema, duplicateColumnName, duplicateColumnValue, update, encryptionKey, encryptionSalt, forceLocal, }) {
return __awaiter(this, arguments, void 0, function* ({ dbContext, paradigm, dbFullName, tableName, data, tableSchema, duplicateColumnName, duplicateColumnValue, update, encryptionKey, encryptionSalt, forceLocal, debug, }) {
var _b, _c, _d;
/**
* Initialize variables
@@ -31,6 +32,13 @@ function addDbEntry(_a) {
const isMaster = forceLocal
? true
: (0, check_if_is_master_1.default)({ dbContext, dbFullName });
if (debug) {
(0, debug_log_1.default)({
log: isMaster,
addTime: true,
label: "isMaster",
});
}
const DB_CONN = isMaster
? global.DSQL_DB_CONN
: global.DSQL_FULL_ACCESS_DB_CONN || global.DSQL_DB_CONN;
@@ -159,6 +167,23 @@ function addDbEntry(_a) {
.map(() => "?")
.join(",")})`;
const queryValuesArray = insertValuesArray;
if (debug) {
(0, debug_log_1.default)({
log: DB_CONN,
addTime: true,
label: "DB_CONN",
});
(0, debug_log_1.default)({
log: query,
addTime: true,
label: "query",
});
(0, debug_log_1.default)({
log: queryValuesArray,
addTime: true,
label: "queryValuesArray",
});
}
const newInsert = yield (0, conn_db_handler_1.default)(DB_CONN, query, queryValuesArray);
/**
* Return statement
+1
View File
@@ -106,6 +106,7 @@ function runQuery(_a) {
duplicateColumnName,
duplicateColumnValue,
tableSchema,
debug,
});
if (!(result === null || result === void 0 ? void 0 : result.insertId)) {
error = "Couldn't insert data";