diff --git a/src/db/databaseManager.js b/src/db/databaseManager.js index c2dd203..2168aa0 100644 --- a/src/db/databaseManager.js +++ b/src/db/databaseManager.js @@ -234,29 +234,6 @@ class DatabaseManager { await this.pool.query( 'ALTER TABLE heartbeat.heartbeat_events ADD CONSTRAINT chk_room_id_len CHECK (char_length(room_id) > 0 AND char_length(room_id) <= 50)' ); - - const parts = await this.pool.query( - ` - SELECT c.relname AS partition - FROM pg_inherits i - JOIN pg_class c ON c.oid = i.inhrelid - JOIN pg_class p ON p.oid = i.inhparent - JOIN pg_namespace n ON n.oid = p.relnamespace - WHERE n.nspname = 'heartbeat' - AND p.relname = 'heartbeat_events' - ORDER BY c.relname - ` - ); - - for (const row of parts.rows ?? []) { - const name = row?.partition; - if (!name) continue; - await this.pool.query( - `ALTER TABLE heartbeat.${this.escapeIdentifier(name)} - ALTER COLUMN room_id TYPE varchar(50) - USING room_id::text` - ); - } } async ensureIpColumnVarchar() { @@ -284,29 +261,6 @@ class DatabaseManager { ALTER COLUMN ip TYPE varchar(21) USING ip::text` ); - - const parts = await this.pool.query( - ` - SELECT c.relname AS partition - FROM pg_inherits i - JOIN pg_class c ON c.oid = i.inhrelid - JOIN pg_class p ON p.oid = i.inhparent - JOIN pg_namespace n ON n.oid = p.relnamespace - WHERE n.nspname = 'heartbeat' - AND p.relname = 'heartbeat_events' - ORDER BY c.relname - ` - ); - - for (const row of parts.rows ?? []) { - const name = row?.partition; - if (!name) continue; - await this.pool.query( - `ALTER TABLE heartbeat.${this.escapeIdentifier(name)} - ALTER COLUMN ip TYPE varchar(21) - USING ip::text` - ); - } } escapeIdentifier(id) {