mlissner's questions

Estou prestes a entender isso, mas não entendo a correção que preciso. A consulta a seguir leva cerca de um minuto, mais ou menos, para retornar 20 registros:

explain (analyze, buffers)
select "search_docket"."id"
FROM "search_docket"
WHERE "search_docket"."court_id" = 'delctcompl'
ORDER BY "search_docket"."id" desC
LIMIT 20; 
                                                                           QUERY PLAN                                                                            
-----------------------------------------------------------------------------------------------------------------------------------------------------------------
 Limit  (cost=0.56..2791.05 rows=20 width=4) (actual time=74.950..41059.055 rows=20 loops=1)
   Buffers: shared hit=38524709 dirtied=10
   ->  Index Scan Backward using search_docket_pkey on search_docket  (cost=0.56..8837737.95 rows=63342 width=4) (actual time=74.947..41059.022 rows=20 loops=1)
         Filter: ((court_id)::text = 'delctcompl'::text)
         Rows Removed by Filter: 41862720
         Buffers: shared hit=38524709 dirtied=10
 Planning time: 0.450 ms
 Execution time: 41059.233 ms

Inverter a ordem de classificação leva cerca de 60ms:

explain (analyze, buffers)
select "search_docket"."id"
FROM "search_docket"
WHERE "search_docket"."court_id" = 'delctcompl'
ORDER BY "search_docket"."id" asC
LIMIT 20; 
                                                                     QUERY PLAN                                                                      
-----------------------------------------------------------------------------------------------------------------------------------------------------
 Limit  (cost=0.56..2791.05 rows=20 width=4) (actual time=63.701..63.939 rows=20 loops=1)
   Buffers: shared hit=45783
   ->  Index Scan using search_docket_pkey on search_docket  (cost=0.56..8837737.95 rows=63342 width=4) (actual time=63.698..63.933 rows=20 loops=1)
         Filter: ((court_id)::text = 'delctcompl'::text)
         Rows Removed by Filter: 67080
         Buffers: shared hit=45783
 Planning time: 0.426 ms
 Execution time: 63.971 ms

Você pode ver que no primeiro, fica desagradável aqui:

         Rows Removed by Filter: 41862720
         Buffers: shared hit=38524709 dirtied=10

Aqui estão os índices na tabela (omitindo os que não estão relacionados a esta consulta):

Indexes:
    "search_docket_pkey" PRIMARY KEY, btree (id)
    "search_docket_7a46e69c" btree (court_id)
    "search_docket_court_id_2d2438b2594e74ba_like" btree (court_id varchar_pattern_ops)

Pensamentos dispersos:

1. A coluna do tribunal tem cardinalidade muito baixa. Tem cerca de 500 valores em cerca de 50 milhões de linhas.

2. Acho que poderia adicionar um índice descendente em court_id, e talvez isso consertasse, mas isso não parece certo.

3. Talvez eu precise de um índice de várias colunas aqui search_docket.ide search_docket.court_id? Parece desligado.

Existe algo melhor que eu deveria estar fazendo aqui que faria o índice funcionar melhor?

Eu criei uma PUBLICAÇÃO de replicação lógica usando FOR ALL TABLES. Agora percebi que não quero replicar todas as tabelas, afinal. Tentei soltar uma das tabelas da publicação, mas:

mydb=# alter publication replicapublication drop table only migrations;
ERROR:  publication "replicapublication" is defined as FOR ALL TABLES
DETAIL:  Tables cannot be added to or dropped from FOR ALL TABLES publications.

Fiz uma sincronização enorme de centenas de GB e não quero começar de novo com uma nova publicação.

Perguntas: 1. Existe alguma esperança de resgatar esta publicação? 2. Em caso negativo, existe alguma maneira de criar uma nova publicação totalmente sincronizada sem recomeçar com uma sincronização completa?

Obrigado.

Usando a seguinte consulta, consigo exportar duas tabelas, selecionando 500 itens aleatoriamente da primeira:

copy (select * from (
          select 1 + floor(random() * 1040000)::integer as "documentUUID"
          from generate_series(1, 600) g
          group by 1) r
       join "Document" using ("documentUUID")
      inner join "Citation" on ("Document"."citation_id" = "Citation"."citationUUID")
      limit 500) 
to '/tmp/data.sql';

Desejo importar esses dados para meu banco de dados de teste, mas COPY FROMnão consigo lidar com várias importações de tabelas.

Como posso fazer isso funcionar?