This commit is contained in:
vipg
2025-12-19 16:00:06 +08:00
parent 4fdfb60a70
commit 2db865feed

View File

@@ -11,7 +11,7 @@ CREATE EXTENSION IF NOT EXISTS "moddatetime" SCHEMA public;
DO $$ DO $$
BEGIN BEGIN
RAISE NOTICE '🚀============ trading_records 部署开始 ============🚀'; RAISE NOTICE '🚀============ cn_futures_trading_records 部署开始 ============🚀';
END $$; END $$;
-- 2 建表(幂等) -- 2 建表(幂等)
@@ -21,9 +21,9 @@ BEGIN
SELECT 1 SELECT 1
FROM information_schema.tables FROM information_schema.tables
WHERE table_schema = 'public' WHERE table_schema = 'public'
AND table_name = 'trading_records' AND table_name = 'cn_futures_trading_records'
) THEN ) THEN
CREATE TABLE trading_records ( CREATE TABLE cn_futures_trading_records (
id UUID DEFAULT gen_random_uuid() PRIMARY KEY, -- id id UUID DEFAULT gen_random_uuid() PRIMARY KEY, -- id
event_type VARCHAR(40) NOT NULL, -- 事件名称 event_type VARCHAR(40) NOT NULL, -- 事件名称
payload JSONB NOT NULL, -- 数据 payload JSONB NOT NULL, -- 数据
@@ -33,18 +33,18 @@ BEGIN
); );
-- 3 触发器:自动刷新 updated_at -- 3 触发器:自动刷新 updated_at
CREATE TRIGGER trg_trading_records_updated_at CREATE TRIGGER trg_cn_futures_trading_records_updated_at
BEFORE UPDATE ON trading_records BEFORE UPDATE ON trading_records
FOR EACH ROW FOR EACH ROW
EXECUTE FUNCTION moddatetime(updated_at); EXECUTE FUNCTION moddatetime(updated_at);
RAISE NOTICE 'trading_records 表已创建'; RAISE NOTICE 'cn_futures_trading_records 表已创建';
ELSE ELSE
RAISE NOTICE 'trading_records 表已存在,跳过'; RAISE NOTICE 'cn_futures_trading_records 表已存在,跳过';
END IF; END IF;
END $$; END $$;
DO $$ DO $$
BEGIN BEGIN
RAISE NOTICE '============ trading_records 部署完成 ============'; RAISE NOTICE '============ cn_futures_trading_records 部署完成 ============';
END $$; END $$;