pg数据库的备份和恢复以及sql脚本错误的解决方法

Posted 2022-12-16 福大大架构师每日一题

1.备份单库单表的数据，以insert语句的方式

pg_dump -h IP -p 端口 -U 用户名 -t 表名 --inserts –f  dbname.sql  数据库名

pg_dump -h 172.16.11.111 -p 58477 -U postgres -t data_device --inserts –f  dbname.sql  rcdb

2.脚本报错ERROR: relation “ev” does not exist

SQL 状态: 42P01

CREATE SEQUENCE IF NOT EXISTS public.ev_id_seq
    INCREMENT 1
    START 1
    MINVALUE 1
    MAXVALUE 2147483647
    CACHE 1
    OWNED BY ev.id;

改成

CREATE SEQUENCE IF NOT EXISTS public.ev_id_seq
    INCREMENT 1
    START 1
    MINVALUE 1
    MAXVALUE 2147483647
    CACHE 1;

3.xorm的pg脚本报错pq: syntax error at or near “Type”

--
-- Data for Name: enum_ev; Type: TABLE DATA; Schema: public; Owner: postgres
--

INSERT INTO public.enum_ev VALUES (2, 'converse', '逆行', 1);

去掉注释，改成

INSERT INTO public.enum_ev VALUES (2, 'converse', '逆行', 1);

4.xorm的pg脚本报错pq: unterminated dollar-quoted string at or near "$BODY$

DECLARE
time_column_name text"
解决方案是不要用ImportFile方法，而是用xorm的Exec方法。

						_, err = daopg.NewEngine().Exec(`CREATE OR REPLACE FUNCTION public.auto_insert_into_vd()
    RETURNS trigger
    LANGUAGE 'plpgsql'
    COST 100
    VOLATILE NOT LEAKPROOF
AS $BODY$
DECLARE
    time_column_name 	text ;			-- 父表中用于分区的时间字段的名称[必须首先初始化!!]
    curMM 		varchar(8);		-- 'YYYYMMDD'字串,用做分区子表的后缀
    isExist 		boolean;		-- 分区子表,是否已存在
    startTime 		text;
    endTime		text;
    strSQL  		text;
    
BEGIN
    -- 调用前,必须首先初始化(时间字段名):time_column_name [直接从调用参数中获取!!]
    time_column_name := TG_ARGV[0];
   
    -- 判断对应分区表 是否已经存在?
    EXECUTE 'SELECT $1.'||time_column_name INTO strSQL USING NEW;
    curMM := to_char( strSQL::timestamp , 'YYYYMMDD' );
    select count(*) INTO isExist from pg_class where relname = (TG_RELNAME||'_'||curMM);
 
    -- 若不存在, 则插入前需 先创建子分区
    IF ( isExist = false ) THEN  
        -- 创建子分区表
        startTime := curMM||' 00:00:00.000';
        endTime := to_char( startTime::timestamp + interval '1 day', 'YYYY-MM-DD HH24:MI:SS.MS');
        strSQL := 'CREATE TABLE IF NOT EXISTS '||TG_RELNAME||'_'||curMM||
                  ' ( CHECK('||time_column_name||'>='''|| startTime ||''' AND '
                             ||time_column_name||'< '''|| endTime ||''' )
                          ) INHERITS ('||TG_RELNAME||') ;'  ;  
        EXECUTE strSQL;
 
        -- 创建索引
        strSQL := 'CREATE INDEX '||TG_RELNAME||'_'||curMM||'_INDEX_'||time_column_name||' ON '
                  ||TG_RELNAME||'_'||curMM||' ('||time_column_name||');' ;
        EXECUTE strSQL;
       
    END IF;
 
    -- 插入数据到子分区!
    strSQL := 'INSERT INTO '||TG_RELNAME||'_'||curMM||' SELECT $1.*' ;
    EXECUTE strSQL USING NEW;
    RETURN NULL; 
END
$BODY$`)