fish/asset_assistant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add

Browse Source
This commit is contained in:
vipg
2025-11-25 12:01:38 +08:00
parent e9945d67aa
commit 6f8b1d9b2b
1 changed files with 100 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

201
backend/sql/07_variety.sql
View File

@@ -1,26 +1,29 @@
-- 切换到目标数据库 -- =========================================================
-- variety.sql
-- 服务器一次性部署：原结构 + 性能优化
-- PostgreSQL 17.4+
-- =========================================================
-- 1. 连接目标库（按需改名字）
\c postgres; \c postgres;
-- 2. 表结构 -----------------------------------
DO $$ DO $$
BEGIN BEGIN
-- 创建主表 variety -- variety 主表
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety') THEN
CREATE TABLE variety ( CREATE TABLE variety (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
RAISE NOTICE 'created variety table, trigger and indexes';
ELSE
RAISE NOTICE 'variety table already exists';
END IF; END IF;
-- 创建子表 variety_exchange -- variety_exchange
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_exchange') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_exchange') THEN
CREATE TABLE variety_exchange ( CREATE TABLE variety_exchange (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
variety_id UUID NOT NULL, variety_id UUID NOT NULL,
exchange_id VARCHAR(50) NOT NULL, exchange_id VARCHAR(50) NOT NULL,
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
@@ -28,19 +31,14 @@ BEGIN
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_variety_exchange_updated_at CREATE TRIGGER update_variety_exchange_updated_at
BEFORE UPDATE ON "variety_exchange" BEFORE UPDATE ON variety_exchange
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column();
RAISE NOTICE 'created variety_exchange table, trigger, foreign key and indexes';
ELSE
RAISE NOTICE 'variety_exchange table already exists';
END IF; END IF;
-- 创建子表 variety_name -- variety_name
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_name') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_name') THEN
CREATE TABLE variety_name ( CREATE TABLE variety_name (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
variety_id UUID NOT NULL, variety_id UUID NOT NULL,
name VARCHAR(50) NOT NULL, name VARCHAR(50) NOT NULL,
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
@@ -48,19 +46,14 @@ BEGIN
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_variety_name_updated_at CREATE TRIGGER update_variety_name_updated_at
BEFORE UPDATE ON "variety_name" BEFORE UPDATE ON variety_name
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column();
RAISE NOTICE 'created variety_name table, trigger, foreign key and indexes';
ELSE
RAISE NOTICE 'variety_name table already exists';
END IF; END IF;
-- 创建子表 variety_code -- variety_code
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_code') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_code') THEN
CREATE TABLE variety_code ( CREATE TABLE variety_code (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
variety_id UUID NOT NULL, variety_id UUID NOT NULL,
code VARCHAR(50) NOT NULL, code VARCHAR(50) NOT NULL,
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
@@ -68,108 +61,114 @@ BEGIN
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_variety_code_updated_at CREATE TRIGGER update_variety_code_updated_at
BEFORE UPDATE ON "variety_code" BEFORE UPDATE ON variety_code
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column();
RAISE NOTICE 'created variety_code table, trigger, foreign key and indexes';
ELSE
RAISE NOTICE 'variety_code table already exists';
END IF; END IF;
-- 创建子表 variety_tick -- variety_tick
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_tick') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_tick') THEN
CREATE TABLE variety_tick ( CREATE TABLE variety_tick (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
variety_id UUID NOT NULL, variety_id UUID NOT NULL,
tick NUMERIC(12, 6), tick NUMERIC(12,6),
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_variety_tick_updated_at CREATE TRIGGER update_variety_tick_updated_at
BEFORE UPDATE ON "variety_tick" BEFORE UPDATE ON variety_tick
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column();
RAISE NOTICE 'created variety_tick table, trigger, foreign key and indexes';
ELSE
RAISE NOTICE 'variety_tick table already exists';
END IF; END IF;
-- 创建子表 variety_tick_price -- variety_tick_price
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_tick_price') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_tick_price') THEN
CREATE TABLE variety_tick_price ( CREATE TABLE variety_tick_price (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
variety_id UUID NOT NULL, variety_id UUID NOT NULL,
price NUMERIC(12, 6), price NUMERIC(12,6),
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP, created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_variety_tick_price_updated_at CREATE TRIGGER update_variety_tick_price_updated_at
BEFORE UPDATE ON "variety_tick_price" BEFORE UPDATE ON variety_tick_price
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column();
RAISE NOTICE 'created variety_tick_price table, trigger, foreign key and indexes';
ELSE
RAISE NOTICE 'variety_tick_price table already exists';
END IF; END IF;
END $$; END $$;
-- 3. 视图 --------------------------------------
DO $$ DO $$
DECLARE
view_exists BOOLEAN;
BEGIN BEGIN
-- 检查视图是否已存在 IF EXISTS (SELECT 1 FROM information_schema.views WHERE table_name = 'variety_info_view') THEN
SELECT EXISTS (
SELECT 1 FROM information_schema.views
WHERE table_name = 'variety_info_view'
) INTO view_exists;
-- 若视图存在，先删除（避免字段名冲突）
IF view_exists THEN
DROP VIEW variety_info_view; DROP VIEW variety_info_view;
RAISE NOTICE '已删除旧视图 variety_info_view';
END IF; END IF;
-- 创建或更新视图
CREATE OR REPLACE VIEW variety_info_view AS CREATE OR REPLACE VIEW variety_info_view AS
SELECT SELECT
v.id AS variety_id, v.id AS variety_id,
vn.name AS name, vn.name,
vc.code AS code, vc.code,
-- 调用格式化函数：自动去除尾部多余0
format_numeric_to_original(vt.tick) AS tick, format_numeric_to_original(vt.tick) AS tick,
format_numeric_to_original(vtp.price) AS tick_price, format_numeric_to_original(vtp.price) AS tick_price,
-- 可选：保留原始精度字段（供计算使用）
vt.tick AS tick_original, vt.tick AS tick_original,
vtp.price AS tick_price_original vtp.price AS tick_price_original
FROM FROM variety v
variety v LEFT JOIN variety_name vn ON v.id = vn.variety_id AND vn.deleted = FALSE
LEFT JOIN variety_name vn LEFT JOIN variety_code vc ON v.id = vc.variety_id AND vc.deleted = FALSE
ON v.id = vn.variety_id LEFT JOIN variety_tick vt ON v.id = vt.variety_id AND vt.deleted = FALSE
AND vn.deleted = FALSE LEFT JOIN variety_tick_price vtp ON v.id = vtp.variety_id AND vtp.deleted = FALSE
LEFT JOIN variety_code vc WHERE v.deleted = FALSE;
ON v.id = vc.variety_id END $$;
AND vc.deleted = FALSE
LEFT JOIN variety_tick vt
ON v.id = vt.variety_id
AND vt.deleted = FALSE
LEFT JOIN variety_tick_price vtp
ON v.id = vtp.variety_id
AND vtp.deleted = FALSE
WHERE
v.deleted = FALSE;
-- 根据视图是否已存在输出不同提示 -- 4. 性能优化：索引 -----------------------------------------
IF view_exists THEN CREATE INDEX IF NOT EXISTS idx_variety_exchange_variety_id_deleted ON variety_exchange(variety_id, deleted);
RAISE NOTICE '视图 variety_info_view 已更新（删除旧视图后重建）'; CREATE INDEX IF NOT EXISTS idx_variety_name_variety_id_deleted ON variety_name(variety_id, deleted);
ELSE CREATE INDEX IF NOT EXISTS idx_variety_code_variety_id_deleted ON variety_code(variety_id, deleted);
RAISE NOTICE '视图 variety_info_view 已创建'; CREATE INDEX IF NOT EXISTS idx_variety_tick_variety_id_deleted ON variety_tick(variety_id, deleted);
END IF; CREATE INDEX IF NOT EXISTS idx_variety_tick_price_variety_id_deleted ON variety_tick_price(variety_id, deleted);
EXCEPTION
WHEN OTHERS THEN -- 5. 性能优化：轻量视图 + 物化视图 --------------------------
RAISE NOTICE '处理视图时发生错误: %', SQLERRM; CREATE OR REPLACE VIEW variety_info_view_lean AS
SELECT
v.id AS variety_id,
vn.name,
vc.code,
vt.tick AS tick_original,
vtp.price AS tick_price_original
FROM variety v
LEFT JOIN variety_name vn ON vn.variety_id = v.id AND vn.deleted = FALSE
LEFT JOIN variety_code vc ON vc.variety_id = v.id AND vc.deleted = FALSE
LEFT JOIN variety_tick vt ON vt.variety_id = v.id AND vt.deleted = FALSE
LEFT JOIN variety_tick_price vtp ON vtp.variety_id = v.id AND vtp.deleted = FALSE
WHERE v.deleted = FALSE;
CREATE MATERIALIZED VIEW IF NOT EXISTS variety_info_mv AS
SELECT * FROM variety_info_view_lean;
CREATE UNIQUE INDEX IF NOT EXISTS uq_variety_info_mv ON variety_info_mv(variety_id);
-- 6. 刷新函数 ------------------------------------------------
CREATE OR REPLACE FUNCTION refresh_variety_info_mv()
RETURNS void
LANGUAGE plpgsql
AS $$
BEGIN
REFRESH MATERIALIZED VIEW CONCURRENTLY variety_info_mv;
END;
$$;
-- 7. 首次填充
PERFORM refresh_variety_info_mv();
-- 8. 小贴士 ----------------------------------------------
DO $$
BEGIN
RAISE NOTICE '
=== 部署完成 ===
1. 若从旧库迁数据，可执行：
pg_dump -U old_user -t variety -t variety_* old_db | psql -U new_user -d new_db
2. 刷新物化视图：SELECT refresh_variety_info_mv();
3. 建议 cron 每 15 min 刷新一次：
*/15 * * * * psql -U new_user -d new_db -c "SELECT refresh_variety_info_mv();"
';
END $$; END $$;