MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removing tables and their related table definitions.

This commit is contained in:
mike12345567 2024-07-09 16:33:10 +01:00
parent 6e699a163d
commit 4cb23759a3
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/server/src/sdk/app/tables/internal/sqs.ts
View File

@ -176,9 +176,24 @@ export async function addTable(table: Table) {
export async function removeTable(table: Table) { export async function removeTable(table: Table) {
const db = context.getAppDB() const db = context.getAppDB()
try { try {
const definition = await db.get<SQLiteDefinition>(SQLITE_DESIGN_DOC_ID) let response = await Promise.all([
if (definition.sql?.tables?.[table._id!]) { tablesSdk.getAllInternalTables(),
delete definition.sql.tables[table._id!] db.get<SQLiteDefinition>(SQLITE_DESIGN_DOC_ID),
])
const tables: Table[] = response[0],
definition: SQLiteDefinition = response[1]
const tableIds = tables
.map(tbl => tbl._id!)
.filter(id => !id.includes(table._id!))
let cleanup = false
for (let tableKey of Object.keys(definition.sql?.tables || {})) {
// there are no tables matching anymore
if (!tableIds.find(id => tableKey.includes(id))) {
delete definition.sql.tables[tableKey]
cleanup = true
}
}
if (cleanup) {
await db.put(definition) await db.put(definition)
// make sure SQS is cleaned up, tables removed // make sure SQS is cleaned up, tables removed
await db.sqlDiskCleanup() await db.sqlDiskCleanup()