This commit is contained in:
vipg
2025-11-25 12:57:49 +08:00
parent 29f134c3e5
commit 1ccbc3c6d3

View File

@@ -1,28 +1,41 @@
-- 切换到目标数据库 -- =========================================================
\c postgres; -- user.sql 👤
-- 无物化视图 | 超可视提示 | 可重复执行
-- PostgreSQL 17.4+ 👍
-- =========================================================
-- 1⃣ 开始 🚀
DO $$ DO $$
BEGIN BEGIN
RAISE NOTICE '🚀============ user 部署开始 ============🚀';
END $$;
-- 2⃣ 连接目标库
\c postgres;
-- 3⃣ 表结构 -----------------------------------
DO $$
BEGIN
-- user 主表(关键字,双引号包裹)
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'user') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'user') THEN
CREATE TABLE "user" ( -- user是关键字用双引号包裹 CREATE TABLE "user" (
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
); );
CREATE TRIGGER update_user_updated_at CREATE TRIGGER update_user_updated_at
BEFORE UPDATE ON "user" BEFORE UPDATE ON "user"
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column(); RAISE NOTICE '1⃣✅ user 主表已创建';
RAISE NOTICE 'created user table and trigger';
ELSE ELSE
RAISE NOTICE 'user table already exists'; RAISE NOTICE '1⃣⏩ user 主表已存在,跳过';
END IF; END IF;
-- user_account
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'user_account') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'user_account') THEN
CREATE TABLE user_account ( CREATE TABLE user_account (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
user_id UUID NOT NULL, user_id UUID NOT NULL,
account VARCHAR NOT NULL, account VARCHAR NOT NULL,
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
@@ -30,18 +43,17 @@ BEGIN
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_user_account_updated_at CREATE TRIGGER update_user_account_updated_at
BEFORE UPDATE ON "user_account" BEFORE UPDATE ON user_account
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column(); RAISE NOTICE '2⃣✅ user_account 子表已创建';
RAISE NOTICE 'created user_account table and trigger';
ELSE ELSE
RAISE NOTICE 'user_account table already exists'; RAISE NOTICE '2⃣⏩ user_account 子表已存在,跳过';
END IF; END IF;
-- user_password
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'user_password') THEN IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'user_password') THEN
CREATE TABLE user_password ( CREATE TABLE user_password (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL, id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
user_id UUID NOT NULL, user_id UUID NOT NULL,
password VARCHAR NOT NULL, password VARCHAR NOT NULL,
deleted BOOLEAN NOT NULL DEFAULT FALSE, deleted BOOLEAN NOT NULL DEFAULT FALSE,
@@ -49,55 +61,53 @@ BEGIN
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
); );
CREATE TRIGGER update_user_password_updated_at CREATE TRIGGER update_user_password_updated_at
BEFORE UPDATE ON "user_password" BEFORE UPDATE ON user_password
FOR EACH ROW FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
EXECUTE FUNCTION update_data_modified_column(); RAISE NOTICE '3⃣✅ user_password 子表已创建';
RAISE NOTICE 'created user_password table and trigger';
ELSE ELSE
RAISE NOTICE 'user_password table already exists'; RAISE NOTICE '3⃣⏩ user_password 子表已存在,跳过';
END IF; END IF;
END $$; END $$;
-- 4⃣ 视图 ------------------------------------
DO $$ DO $$
DECLARE DECLARE
view_exists BOOLEAN; view_exists BOOLEAN;
BEGIN BEGIN
-- 检查视图是否已存在
SELECT EXISTS ( SELECT EXISTS (
SELECT 1 FROM information_schema.views SELECT 1 FROM information_schema.views
WHERE table_name = 'user_info_view' WHERE table_name = 'user_info_view'
) INTO view_exists; ) INTO view_exists;
-- 若视图存在,先删除(避免字段名冲突)
IF view_exists THEN IF view_exists THEN
DROP VIEW user_info_view; DROP VIEW user_info_view;
RAISE NOTICE '已删除旧视图 user_info_view'; RAISE NOTICE '4⃣♻ 已删除旧视图 user_info_view';
END IF; END IF;
-- 创建或更新视图
CREATE OR REPLACE VIEW user_info_view AS CREATE OR REPLACE VIEW user_info_view AS
SELECT SELECT
u.id AS user_id, u.id AS user_id,
ua.account AS account, ua.account,
up.password AS password, up.password
u.deleted AS deleted FROM "user" u
FROM JOIN user_account ua ON u.id = ua.user_id AND ua.deleted = FALSE
"user" u JOIN user_password up ON u.id = up.user_id AND up.deleted = FALSE
JOIN WHERE u.deleted = FALSE;
user_account ua ON u.id = ua.user_id
JOIN
user_password up ON u.id = up.user_id
WHERE
u.deleted = FALSE;
-- 根据视图是否已存在输出不同提示 RAISE NOTICE '4⃣✅ user_info_view 已创建/更新';
IF view_exists THEN
RAISE NOTICE '视图 user_info_view 已更新(删除旧视图后重建)';
ELSE
RAISE NOTICE '视图 user_info_view 已创建';
END IF;
EXCEPTION EXCEPTION
WHEN OTHERS THEN WHEN OTHERS THEN
RAISE NOTICE '处理视图时发生错误: %', SQLERRM; RAISE NOTICE '4⃣❌ 处理视图时发生错误: %', SQLERRM;
END $$; END $$;
-- 5⃣ 性能索引 ------------------------------------------------
CREATE INDEX IF NOT EXISTS idx_user_account_user_id_deleted ON user_account(user_id, deleted);
CREATE INDEX IF NOT EXISTS idx_user_password_user_id_deleted ON user_password(user_id, deleted);
RAISE NOTICE '5⃣✅ 全部索引已确保存在';
-- 6⃣ 完成 🎉
DO $$
BEGIN
RAISE NOTICE '🎉============ user 部署完成 ============🎉';
END $$;