From 4d85a695057570f050183b859d3e047194f5afc9 Mon Sep 17 00:00:00 2001 From: Benjamin Toby Date: Thu, 6 Aug 2026 13:42:18 +0100 Subject: [PATCH] Bugfix: fix db-update return --- dist/lib/mariadb/db-update.js | 23 ++--------------------- package.json | 2 +- src/lib/mariadb/db-update.ts | 25 ++----------------------- 3 files changed, 5 insertions(+), 45 deletions(-) diff --git a/dist/lib/mariadb/db-update.js b/dist/lib/mariadb/db-update.js index 5fde08a..42a248f 100644 --- a/dist/lib/mariadb/db-update.js +++ b/dist/lib/mariadb/db-update.js @@ -65,33 +65,14 @@ export default async function DbUpdate({ table, data, query, targetId, config, } let updated_sql = ``; let updated_sql_values = []; updated_sql += `SELECT * FROM ${quoteIdentifier(table)} ${whereClause}`; - updated_sql_values = [...updated_sql_values, ...sqlQueryObj.values]; - updated_sql += ` AND `; - for (let i = 0; i < keys.length; i++) { - const key = keys[i]; - if (!key) - continue; - if (key == "updated_at") - continue; - const isLast = i == keys.length - 1; - updated_sql += ` ${quoteIdentifier(key)}=?`; - updated_sql_values.push(finalData[key] ?? null); - if (!isLast) { - updated_sql += ` AND `; - } - } + updated_sql_values = [...sqlQueryObj.values]; const updated_res = await dbHandler({ query: updated_sql, values: updated_sql_values, config, }); - const affected_rows = updated_res.payload?.length; return { - ...res, - success: Boolean(affected_rows), - insert_return: { - affected_rows, - }, + ...updated_res, debug: { sqlObj, }, diff --git a/package.json b/package.json index 5180160..09ac364 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@moduletrace/bun-mariadb", - "version": "1.0.13", + "version": "1.0.14", "description": "Schema-driven MariaDB manager for Bun", "author": "Benjamin Toby", "license": "MIT", diff --git a/src/lib/mariadb/db-update.ts b/src/lib/mariadb/db-update.ts index a4ff941..f4647aa 100644 --- a/src/lib/mariadb/db-update.ts +++ b/src/lib/mariadb/db-update.ts @@ -113,22 +113,7 @@ export default async function DbUpdate< let updated_sql_values: any[] = []; updated_sql += `SELECT * FROM ${quoteIdentifier(table)} ${whereClause}`; - updated_sql_values = [...updated_sql_values, ...sqlQueryObj.values]; - updated_sql += ` AND `; - for (let i = 0; i < keys.length; i++) { - const key = keys[i]; - if (!key) continue; - if (key == "updated_at") continue; - - const isLast = i == keys.length - 1; - - updated_sql += ` ${quoteIdentifier(key)}=?`; - updated_sql_values.push(finalData[key] ?? null); - - if (!isLast) { - updated_sql += ` AND `; - } - } + updated_sql_values = [...sqlQueryObj.values]; const updated_res = await dbHandler({ query: updated_sql, @@ -136,14 +121,8 @@ export default async function DbUpdate< config, }); - const affected_rows = updated_res.payload?.length; - return { - ...res, - success: Boolean(affected_rows), - insert_return: { - affected_rows, - }, + ...updated_res, debug: { sqlObj, },