torsten/yourpart3
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor syncDatabase function to improve orphaned entry cleanup for knowledge and notification, ensuring data integrity and consistent logging.

Browse Source
This commit is contained in:
Torsten Schulz (local)
2025-12-18 15:20:09 +01:00
parent c1f22246ea
commit 31c23a0c40
1 changed files with 27 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
backend/utils/syncDatabase.js
View File

@@ -82,35 +82,35 @@ const syncDatabase = async () => {
console.log(`✅ ${deletedCount2} verwaiste stock Einträge entfernt`); console.log(`✅ ${deletedCount2} verwaiste stock Einträge entfernt`);
} }
// Cleanup knowledge mit ungültigen character_id oder product_id // Cleanup knowledge mit ungültigen character_id oder product_id
const result3 = await sequelize.query(` const result3 = await sequelize.query(`
DELETE FROM falukant_data.knowledge DELETE FROM falukant_data.knowledge
WHERE character_id NOT IN ( WHERE character_id NOT IN (
SELECT id FROM falukant_data.character SELECT id FROM falukant_data.character
) OR product_id NOT IN ( ) OR product_id NOT IN (
SELECT id FROM falukant_type.product SELECT id FROM falukant_type.product
); );
`); `);
const deletedCount3 = result3[1] || 0; const deletedCount3 = result3[1] || 0;
if (deletedCount3 > 0) { if (deletedCount3 > 0) {
console.log(`✅ ${deletedCount3} verwaiste knowledge Einträge entfernt`); console.log(`✅ ${deletedCount3} verwaiste knowledge Einträge entfernt`);
} }
// Cleanup notification mit ungültigen user_id // Cleanup notification mit ungültigen user_id
const result4 = await sequelize.query(` const result4 = await sequelize.query(`
DELETE FROM falukant_log.notification DELETE FROM falukant_log.notification
WHERE user_id NOT IN ( WHERE user_id NOT IN (
SELECT id FROM falukant_data.falukant_user SELECT id FROM falukant_data.falukant_user
); );
`); `);
const deletedCount4 = result4[1] || 0; const deletedCount4 = result4[1] || 0;
if (deletedCount4 > 0) { if (deletedCount4 > 0) {
console.log(`✅ ${deletedCount4} verwaiste notification Einträge entfernt`); console.log(`✅ ${deletedCount4} verwaiste notification Einträge entfernt`);
} }
if (deletedCount1 === 0 && deletedCount2 === 0 && deletedCount3 === 0 && deletedCount4 === 0) { if (deletedCount1 === 0 && deletedCount2 === 0 && deletedCount3 === 0 && deletedCount4 === 0) {
console.log("✅ Keine verwaisten Einträge gefunden"); console.log("✅ Keine verwaisten Einträge gefunden");
} }
} catch (e) { } catch (e) {
console.warn('⚠️ Konnte verwaiste Einträge nicht bereinigen:', e?.message || e); console.warn('⚠️ Konnte verwaiste Einträge nicht bereinigen:', e?.message || e);
} }