From 4da2f9f9a684473aa8f47e2d67a70a702c3f5e3a Mon Sep 17 00:00:00 2001 From: sairajzero Date: Tue, 21 Mar 2023 23:56:53 +0530 Subject: [PATCH 1/3] Update checksum-db.js --- debug/checksum-db.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/debug/checksum-db.js b/debug/checksum-db.js index e893653..ce182ee 100644 --- a/debug/checksum-db.js +++ b/debug/checksum-db.js @@ -26,9 +26,9 @@ function listTables() { function checksumTable(table) { return new Promise((resolve, reject) => { - DB.query("CHECKSUM TABLE " + table).then(result => { + DB.query("CHECKSUM TABLE ??", [table]).then(result => { let checksum = result[0].Checksum; - DB.query("SELECT COUNT(*) AS rec_count FROM " + table) + DB.query("SELECT COUNT(*) AS rec_count FROM ??", [table]) .then(result => resolve({ table, rec_count: result[0].rec_count, checksum })) .catch(error => reject(error)) }).catch(error => reject(error)) From 4aa6b16766c45c7488e0966438e78905e16dbb13 Mon Sep 17 00:00:00 2001 From: sairajzero Date: Thu, 23 Mar 2023 02:15:00 +0530 Subject: [PATCH 2/3] Bug fix --- src/backup/sync.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/backup/sync.js b/src/backup/sync.js index 087233f..313e2d8 100644 --- a/src/backup/sync.js +++ b/src/backup/sync.js @@ -139,7 +139,7 @@ function getTableHashes(table) { //columns let columns = result.map(r => r["Field"]).sort(); //select statement - let statement = "SELECT CEIL(id/?) as group_id"; + let statement = "SELECT CEIL(id/?) as group_id,"; let query_values = [HASH_N_ROW]; //aggregate column values let col_aggregate = columns.map(c => "IFNULL(CRC32(??), 0)").join('+'); From e099035869918c176ebd04fc0747895318a0a239 Mon Sep 17 00:00:00 2001 From: sairajzero Date: Thu, 23 Mar 2023 02:23:43 +0530 Subject: [PATCH 3/3] Bug fix --- src/backup/slave.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/backup/slave.js b/src/backup/slave.js index fd860d2..315e101 100644 --- a/src/backup/slave.js +++ b/src/backup/slave.js @@ -316,7 +316,7 @@ function deleteTableData(data) { data.forEach(r => r.t_name in delete_needed ? delete_needed[r.t_name].push(r.id) : delete_needed[r.t_name] = [r.id]); let queries = []; for (let table in delete_needed) - queries.push("DELETE FROM ?? WHERE id IN (?)", [table, delete_needed[table]]); + queries.push(["DELETE FROM ?? WHERE id IN (?)", [table, delete_needed[table]]]); DB.transaction(queries).then(_ => resolve(true)).catch(error => reject(error)); }) }