diff --git a/backend/sql/05_exchange.sql b/backend/sql/05_exchange.sql index 5e45f54..617a797 100644 --- a/backend/sql/05_exchange.sql +++ b/backend/sql/05_exchange.sql @@ -1,124 +1,135 @@ --- 切换到目标数据库 -\c postgres; +-- ========================================================= +-- exchange.sql 🏛️ +-- 无物化视图 | 超可视提示 | 可重复执行 +-- PostgreSQL 17.4+ 👍 +-- ========================================================= +-- 1️⃣ 开始 🚀 DO $$ BEGIN + RAISE NOTICE '🚀============ exchange 部署开始 ============🚀'; +END $$; + +-- 2️⃣ 连接目标库 +\c postgres; + +-- 3️⃣ 表结构 ----------------------------------- +DO $$ +BEGIN + -- exchange 主表 IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'exchange') THEN - CREATE TABLE exchange ( - id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, + CREATE TABLE exchange ( + id UUID DEFAULT gen_random_uuid() PRIMARY KEY, deleted BOOLEAN NOT NULL DEFAULT FALSE, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP ); CREATE TRIGGER update_exchange_updated_at - BEFORE UPDATE ON "exchange" - FOR EACH ROW - EXECUTE FUNCTION update_data_modified_column(); - - RAISE NOTICE 'created exchange table and trigger'; + BEFORE UPDATE ON exchange + FOR EACH ROW EXECUTE FUNCTION update_data_modified_column(); + RAISE NOTICE '1️⃣✅ exchange 主表已创建'; ELSE - RAISE NOTICE 'exchange table already exists'; + RAISE NOTICE '1️⃣⏩ exchange 主表已存在,跳过'; END IF; + -- exchange_name IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'exchange_name') THEN CREATE TABLE exchange_name ( - id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, + id UUID DEFAULT gen_random_uuid() PRIMARY KEY, exchange_id UUID NOT NULL, name VARCHAR NOT NULL, deleted BOOLEAN NOT NULL DEFAULT FALSE, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP ); - CREATE TRIGGER update_name_updated_at - BEFORE UPDATE ON "exchange_name" - FOR EACH ROW - EXECUTE FUNCTION update_data_modified_column(); - - RAISE NOTICE 'created exchange_name table and trigger'; + CREATE TRIGGER update_exchange_name_updated_at + BEFORE UPDATE ON exchange_name + FOR EACH ROW EXECUTE FUNCTION update_data_modified_column(); + RAISE NOTICE '2️⃣✅ exchange_name 子表已创建'; ELSE - RAISE NOTICE 'exchange_name table already exists'; + RAISE NOTICE '2️⃣⏩ exchange_name 子表已存在,跳过'; END IF; + -- exchange_short_name IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'exchange_short_name') THEN CREATE TABLE exchange_short_name ( - id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, + id UUID DEFAULT gen_random_uuid() PRIMARY KEY, exchange_id UUID NOT NULL, short_name VARCHAR NOT NULL, deleted BOOLEAN NOT NULL DEFAULT FALSE, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP ); - CREATE TRIGGER update_short_name_updated_at - BEFORE UPDATE ON "exchange_short_name" - FOR EACH ROW - EXECUTE FUNCTION update_data_modified_column(); - - RAISE NOTICE 'created exchange_short_name table and trigger'; + CREATE TRIGGER update_exchange_short_name_updated_at + BEFORE UPDATE ON exchange_short_name + FOR EACH ROW EXECUTE FUNCTION update_data_modified_column(); + RAISE NOTICE '3️⃣✅ exchange_short_name 子表已创建'; ELSE - RAISE NOTICE 'exchange_short_name table already exists'; + RAISE NOTICE '3️⃣⏩ exchange_short_name 子表已存在,跳过'; END IF; + -- exchange_code IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'exchange_code') THEN CREATE TABLE exchange_code ( - id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, + id UUID DEFAULT gen_random_uuid() PRIMARY KEY, exchange_id UUID NOT NULL, code VARCHAR NOT NULL, deleted BOOLEAN NOT NULL DEFAULT FALSE, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP ); - CREATE TRIGGER update_code_updated_at - BEFORE UPDATE ON "exchange_code" - FOR EACH ROW - EXECUTE FUNCTION update_data_modified_column(); - - RAISE NOTICE 'created exchange_code table and trigger'; + CREATE TRIGGER update_exchange_code_updated_at + BEFORE UPDATE ON exchange_code + FOR EACH ROW EXECUTE FUNCTION update_data_modified_column(); + RAISE NOTICE '4️⃣✅ exchange_code 子表已创建'; ELSE - RAISE NOTICE 'exchange_code table already exists'; + RAISE NOTICE '4️⃣⏩ exchange_code 子表已存在,跳过'; END IF; END $$; +-- 4️⃣ 视图 ------------------------------------ DO $$ DECLARE view_exists BOOLEAN; BEGIN - -- 检查视图是否已存在 SELECT EXISTS ( SELECT 1 FROM information_schema.views WHERE table_name = 'exchange_info_view' ) INTO view_exists; - -- 若视图存在,先删除(避免字段名冲突) IF view_exists THEN DROP VIEW exchange_info_view; - RAISE NOTICE '已删除旧视图 exchange_info_view'; + RAISE NOTICE '4️⃣♻️ 已删除旧视图 exchange_info_view'; END IF; - -- 重新创建视图(无冲突风险) - CREATE VIEW exchange_info_view AS - SELECT + CREATE OR REPLACE VIEW exchange_info_view AS + SELECT u.id AS exchange_id, - n.name AS name, - sn.short_name AS short_name, - c.code AS code, - u.deleted AS deleted - FROM - exchange u - JOIN - exchange_name n ON u.id = n.exchange_id AND n.deleted = FALSE - JOIN - exchange_short_name sn ON u.id = sn.exchange_id AND sn.deleted = FALSE - JOIN - exchange_code c ON u.id = c.exchange_id AND c.deleted = FALSE - WHERE - u.deleted = FALSE; + n.name, + sn.short_name, + c.code, + u.deleted + FROM exchange u + JOIN exchange_name n ON u.id = n.exchange_id AND n.deleted = FALSE + JOIN exchange_short_name sn ON u.id = sn.exchange_id AND sn.deleted = FALSE + JOIN exchange_code c ON u.id = c.exchange_id AND c.deleted = FALSE + WHERE u.deleted = FALSE; - IF view_exists THEN - RAISE NOTICE '视图 exchange_info_view 已更新(删除旧视图后重建)'; - ELSE - RAISE NOTICE '视图 exchange_info_view 已创建'; - END IF; + RAISE NOTICE '4️⃣✅ exchange_info_view 已创建/更新'; EXCEPTION WHEN OTHERS THEN - RAISE NOTICE '处理视图时发生错误: %', SQLERRM; + RAISE NOTICE '4️⃣❌ 处理视图时发生错误: %', SQLERRM; END $$; + +-- 5️⃣ 性能索引 ------------------------------------------------ +CREATE INDEX IF NOT EXISTS idx_exchange_name_exchange_id_deleted ON exchange_name(exchange_id, deleted); +CREATE INDEX IF NOT EXISTS idx_exchange_short_name_exchange_id_deleted ON exchange_short_name(exchange_id, deleted); +CREATE INDEX IF NOT EXISTS idx_exchange_code_exchange_id_deleted ON exchange_code(exchange_id, deleted); + +RAISE NOTICE '5️⃣✅ 全部索引已确保存在'; + +-- 6️⃣ 完成 🎉 +DO $$ +BEGIN + RAISE NOTICE '🎉============ exchange 部署完成 ============🎉'; +END $$; \ No newline at end of file