Skip to content

Commit

Permalink
[AMORO-3280] Move the pg upgrade script to the right place (#3281)
Browse files Browse the repository at this point in the history
  • Loading branch information
klion26 authored Oct 18, 2024
1 parent 63b355d commit ca07ab0
Show file tree
Hide file tree
Showing 2 changed files with 25 additions and 39 deletions.
39 changes: 0 additions & 39 deletions amoro-ams/src/main/resources/postgres/upgrade-0.7.0-to-0.7.1.sql

This file was deleted.

25 changes: 25 additions & 0 deletions amoro-ams/src/main/resources/postgres/upgrade.sql
Original file line number Diff line number Diff line change
Expand Up @@ -26,3 +26,28 @@ ALTER TABLE table_blocker ADD UNIQUE KEY uq_prev (catalog_name, db_name, table_n
-- ADD COLUMN table_summary FOR TABLE_RUNTIME
ALTER TABLE table_runtime ADD COLUMN table_summary TEXT;
COMMENT ON COLUMN table_runtime.table_summary IS 'Table summary data';

ALTER TABLE table_runtime RENAME TO table_runtime_backup;
CREATE TABLE table_runtime (LIKE table_runtime_backup INCLUDING ALL)

ALTER TABLE table_runtime ALTER COLUMN optimizing_status optimizing_status_code INT DEFAULT 700;
CREATE INDEX idx_optimizer_status_and_time ON table_runtime(optimizing_status_code, optimizing_status_start_time DESC);

INSERT INTO table_runtime(
table_id,catalog_name, db_name, table_name, current_snapshot_id,current_change_snapshotId, last_optimized_snapshotId,
last_optimized_change_snapshotId, last_major_optimizing_time, last_minor_optimizing_time, last_full_optimizing_time,
optimizing_status_code, optimizing_status_start_time, optimizing_process_id, optimizer_group, table_config,
optimizing_config, pending_input)
SELECT table_id,catalog_name, db_name, table_name, current_snapshot_id,current_change_snapshotId, last_optimized_snapshotId,
last_optimized_change_snapshotId, last_major_optimizing_time, last_minor_optimizing_time, last_full_optimizing_time,
CASE
WHEN optimizing_status = 'IDLE' THEN 700
WHEN optimizing_status = 'PENDING' THEN 600
WHEN optimizing_status = 'PLANNING' THEN 500
WHEN optimizing_status = 'COMMITTING' THEN 400
WHEN optimizing_status = 'MINOR_OPTIMIZING' THEN 300
WHEN optimizing_status = 'MAJOR_OPTIMIZING' THEN 200
WHEN optimizing_status = 'FULL_OPTIMIZING' THEN 100
END,
optimizing_status_start_time, optimizing_process_id, optimizer_group, table_config, optimizing_config, pending_input
FROM table_runtime_backup;

0 comments on commit ca07ab0

Please sign in to comment.