Estou tentando criar uma configuração de replicação lógica onde tenho um único banco de dados grande com réplicas de leitura menores ramificadas filtradas em um subid.
Por exemplo, se eu quisesse um subconjunto de itens enviados para ler réplicas de um cliente específico, poderia ter uma tabela no nó de replicação definida por:
CREATE TABLE public.item (
id text PRIMARY KEY,
data text,
customer_id integer
);
Posso ou não ter sub_id
no nó de assinatura (não é um detalhe do disjuntor). No nó de replicação, posso adicionar dados à tabela como quiser até criar a PUBLICAÇÃO assim:
CREATE PUBLICATION customer_items FOR TABLE public.item (
id,
data
) WHERE (customer_id = 3);
Neste ponto, tento algo como
UPDATE public.item SET
customer_id = 3 WHERE
id = 'GLAMDRING';
Recebo o erro SQL state: 42P10
, recebo um erro ou ..:
ERROR: cannot update table "item"
DETAIL: Column used in the publication WHERE expression is not part of the replica identity.
STATEMENT: UPDATE public.item SET
customer_id = $1::integer WHERE
id = 'GLAMDRING';
A questão aqui parece semelhante . Estou recriando a tabela para remover qualquer instrução ALTER TABLE id
, conforme sugerido lá, mas tenho o mesmo resultado.
A maioria dos exemplos que posso encontrar que usam essa função de replicação lógica nunca faz uso da cláusula WHERE. Estou pensando que entendi mal o significado por trás desse recurso ou encontrei um bug/limitação.
Observação: estou ciente de que meu exemplo parece trivial e deve ser resolvido de outra maneira. Esta é uma versão simplificada do meu problema por uma questão de brevidade.
Atualizar
Tentar usar o índice exclusivo, como sugerido, quase me levou até lá.
CREATE UNIQUE INDEX id_customerid_idx ON public.item ((customer_id || id));
Mas quando tento criar uma PUBLICAÇÃO útil..
CREATE PUBLICATION customer_items FOR TABLE public.item (id, data) WHERE (customer_id || id LIKE '3%');
Novo erro:
ERROR: User-defined or built-in mutable functions are not allowed.invalid publication WHERE expression
ERROR: invalid publication WHERE expression
SQL state: 0A000
Detail: User-defined or built-in mutable functions are not allowed.
Character: 377
Talvez meu caso de uso seja um pouco selvagem ou eu precise repensar a lógica do meu aplicativo para trabalhar com essas restrições. Estou sentindo falta de um trabalho óbvio por aqui?