初始化

sql/init-pg-hba.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+# 添加 pg_hba 复制访问规则（在 docker-entrypoint 初始化后执行）
+echo "host replication all 0.0.0.0/0 md5" >> "$PGDATA/pg_hba.conf"

sql/init-replication.sql

@@ -0,0 +1,12 @@
+-- 创建复制用户（在 Host1 主库上运行）
+DO $$
+BEGIN
+  IF NOT EXISTS (SELECT FROM pg_catalog.pg_roles WHERE rolname = 'replicator') THEN
+    CREATE ROLE replicator WITH REPLICATION LOGIN PASSWORD 'Bjang09@686^*^';
+  END IF;
+END
+$$;
+
+-- 创建复制槽（用于主从复制）
+SELECT pg_create_physical_replication_slot('replication_slot_slave')
+WHERE NOT EXISTS (SELECT 1 FROM pg_replication_slots WHERE slot_name = 'replication_slot_slave');

sql/init.sql

@@ -0,0 +1,34 @@
+-- 红动未来 - 初始化数据库和扩展
+CREATE EXTENSION IF NOT EXISTS vector;
+
+-- 为各微服务创建数据库
+SELECT 'CREATE DATABASE admin_go'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'admin_go')\gexec
+SELECT 'CREATE DATABASE ai_agent'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'ai_agent')\gexec
+SELECT 'CREATE DATABASE assets'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'assets')\gexec
+SELECT 'CREATE DATABASE cid'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'cid')\gexec
+SELECT 'CREATE DATABASE customer_server'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'customer_server')\gexec
+SELECT 'CREATE DATABASE data_engine'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'data_engine')\gexec
+SELECT 'CREATE DATABASE erp'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'erp')\gexec
+SELECT 'CREATE DATABASE media'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'media')\gexec
+SELECT 'CREATE DATABASE model_gateway'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'model_gateway')\gexec
+SELECT 'CREATE DATABASE orders'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'orders')\gexec
+SELECT 'CREATE DATABASE oss'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'oss')\gexec
+SELECT 'CREATE DATABASE prompts_core'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'prompts_core')\gexec
+SELECT 'CREATE DATABASE rag'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'rag')\gexec
+SELECT 'CREATE DATABASE shop_user_trade'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'shop_user_trade')\gexec
+SELECT 'CREATE DATABASE video_factory'
+WHERE NOT EXISTS (SELECT FROM pg_database WHERE datname = 'video_factory')\gexec