postgresql为源强制结束任务-九游平台

清理源库逻辑复制槽

1. drs使用的复制槽名可在drs任务同步日志页面查看“create replication slot[复制槽名] successfully by replication connection.”日志找到。
2. 使用对应drs任务的源数据库连接用户，登录该同步任务的源数据库。
3. 查询同步任务选择的database对应的所有复制槽信息。

   select slot_name from pg_replication_slots where database = 'database';

   其中database为drs同步任务中选择同步的database。

4. 如果查询结果中包含该drs任务使用的复制槽名，并且复制槽状态为未使用（查询结果中active='f'），执行如下语句，删除对应的逻辑复制槽。

   select * from pg_drop_replication_slot('slot_name');

   其中slot_name为1中查询的复制槽名称。

5. 执行如下语句，查询逻辑复制槽是否成功删除。

   select slot_name from pg_replication_slots where slot_name = 'slot_name';

   查询结果为空表示drs同步任务对应的逻辑复制槽已成功删除。

同步序列值

如果未同步序列对象或者目标库为gaussdb，可忽略此节。

1. 使用高权限账号（需要具有所有序列的usage权限）连接对应drs任务同步的源数据库，执行如下语句。

   select 'select pg_catalog.setval('||quote_literal(quote_ident(n.nspname)||'.'||quote_ident(c.relname))||', '||nextval(c.oid)||');' as sqls from pg_class c join pg_namespace n on c.relnamespace=n.oid where c.relkind = 's' and n.nspname !~'^pg_' and n.nspname<>'information_schema' and not (c.relname='hwdrs_ddl_info_id_seq' and n.nspname='public') order by n.nspname, c.relname;

   查询结果为需要在目标数据库中执行的sql语句。

2. 使用对应drs任务的目标数据库的用户连接该任务同步的目标数据库，在目标库中执行步骤1中查询出的sql语句。
3. 在目标库中执行如下语句，检查序列值同步结果。

   select n.nspname, c.relname, nextval(c.oid) from pg_class c join pg_namespace n on c.relnamespace=n.oid where c.relkind = 's' and n.nspname !~'^pg_' and n.nspname<>'information_schema' order by 1,2;

源库无法连接时，重置目标库中的序列值

在某些极端场景下，源数据库可能已经被损坏而无法连接，此时仍需将目标库中与自增或自减列相关联的序列值进行重置。如果源数据可以连接，请忽略此节，参考上节操作即可。

1. 使用对应drs任务的目标数据库测试链接用户，登录该同步任务的目标数据库。
2. 使用如下语句，查询出将nextval作为表列默认值的序列对应的序列值重置sql语句。

   set search_path to ''; select 'select pg_catalog.setval('||quote_literal(quote_ident(s.sequence_schema)||'.'||quote_ident(s.sequence_name))||', (select '||case when s.increment::int<0 then 'min(' else 'max(' end|| quote_ident(c.column_name)||')'||case when s.increment::int<0 then '-1' else ' 1' end||' from '||quote_ident(c.table_schema)||'.'||quote_ident(c.table_name)||'));' as sqls from information_schema.columns c join information_schema.sequences s on (position(quote_literal (quote_ident(s.sequence_schema)||'.'||quote_ident(s.sequence_name))||'::regclass' in c.column_default) > 0) where c.data_type in ('bigint', 'int', 'integer', 'smallint', 'numeric', 'real', 'double precision', 'double') and c.column_default like 'nextval(%%' order by s.sequence_schema, s.sequence_name;

   查询结果为需要在目标数据库中执行的sql语句。

3. 如果源库的版本小于10.0，请忽略此步。如果源库的版本不小于10.0，请在目标库中执行如下语句查询出重置表标识列附加序列的对应序列值的sql语句。

   set search_path to ''; select 'select pg_catalog.setval('||quote_literal(seqname)||', (select '||case when increment::int<0 then 'min(' else 'max(' end||colname||')'||case when increment::int<0 then '-1' else ' 1' end||' from '||tablename||'));' as sqls from (select objid::regclass::text, refobjid::regclass::text, (pg_identify_object(refclassid,refobjid,refobjsubid)).identity, (pg_sequence_parameters(objid)).increment from pg_depend where deptype='i' and refobjsubid>0 and objid in (select c.oid from pg_class c join pg_namespace n on c.relnamespace=n.oid where c.relkind='s' and n.nspname !~ '^pg_' and n.nspname<>'information_schema')) p(seqname,tablename,colname,increment);

   查询结果为需要在目标数据库中执行的sql语句。

4. 在目标库中执行步骤2和步骤3中查询出的sql语句。
5. 在目标库中执行如下语句，检查序列值同步结果。

   select n.nspname, c.relname, nextval(c.oid) from pg_class c join pg_namespace n on c.relnamespace=n.oid where c.relkind = 's' and n.nspname !~'^pg_' and n.nspname<>'information_schema' order by 1,2;