CREATETABLEIF NOT EXISTSmtm.local_tables(rel_schematext, rel_nametext,primary key(rel_schema, rel_name));

CREATE OR REPLACEFUNCTIONmtm.alter_sequences() RETURNSbooleanAS

$$

DECLARE

seq_class pg_class%rowtype;

seq_tuple record;

node_idint;

max_nodesint;

new_startint;

alteredboolean := false;

select current_setting('multimaster.max_nodes') into max_nodes;

select id,"allNodes" into node_idfrommtm.get_cluster_state();

FOR seq_classIN

SELECT*FROM pg_classWHEREpg_class.relkind='S'

LOOP

EXECUTE'select * from'||seq_class.relname||';' INTO seq_tuple;

IFseq_tuple.increment_by!= max_nodes THEN

altered := true;

RAISE NOTICE'Altering step for sequence % to %.',seq_tuple.sequence_name, max_nodes;

EXECUTE'ALTER SEQUENCE'||seq_class.relname||' INCREMENT BY'|| max_nodes||';';

END IF;

IF (seq_tuple.last_value % max_nodes)!= node_id THEN

altered := true;

new_start := (seq_tuple.last_value/ max_nodes+1)*max_nodes+ node_id;

RAISE NOTICE'Altering start for sequence % to %.',seq_tuple.sequence_name, new_start;

EXECUTE'ALTER SEQUENCE'||seq_class.relname||' RESTART WITH'|| new_start||';';

END IF;

END LOOP;

IF altered= false THEN

RAISE NOTICE'All found sequnces have proper params.';

END IF;

RETURN true;

END

$$

LANGUAGE plpgsql;

selectmtm.alter_sequences();