forsøk på optimalisering av sql

navikt · Nov 21, 2023 · 4bc23be · 4bc23be
1 parent e20dffa
commit 4bc23be
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/...sorgsopptjening/bestem/pensjonsopptjening/persongrunnlag/repository/PersongrunnlagRepo.kt b/...sorgsopptjening/bestem/pensjonsopptjening/persongrunnlag/repository/PersongrunnlagRepo.kt
@@ -80,13 +80,24 @@ class PersongrunnlagRepo(
     fun finnNesteUprosesserte(): PersongrunnlagMelding.Mottatt? {
         return jdbcTemplate.query(
 //            """select m.*, ms.statushistorikk from melding m join melding_status ms on m.id = ms.id where (ms.status->>'type' = 'Klar') or (ms.status->>'type' = 'Retry' and (ms.status->>'karanteneTil')::timestamptz < (:now)::timestamptz) fetch first row only for no key update of m skip locked""",
+            /*
             """select m.*, ms.statushistorikk 
                | from melding m 
                | join (select * from melding_status
                |       where (status->>'type' = 'Klar') or (status->>'type' = 'Retry')) ms on m.id = ms.id 
                | where (ms.status->>'type' = 'Klar') 
                | or (ms.status->>'type' = 'Retry' and (ms.status->>'karanteneTil')::timestamptz < (:now)::timestamptz) 
                | fetch first row only for no key update of m skip locked""".trimMargin(),
+             */
+            """ SELECT mms.*, m.id as m_id2
+                  | FROM (SELECT *, ms.statushistorikk, ms.status as ms_status, (ms.status->>'karanteneTil') as karanteneTil, m.id as m_id1
+                  |        FROM melding m,
+                  |             (SELECT * FROM melding_status WHERE (status->>'type' = 'Klar') OR (status->>'type' = 'Retry')) ms
+                  |        WHERE ms.id = m.id) mms,
+                  |        melding m
+                  |  WHERE karanteneTil is null or (karanteneTil)::timestamptz < (:now)::timestamptz
+                  |    AND m.id = mms.m_id1
+                  | FETCH FIRST ROW ONLY FOR NO KEY UPDATE OF m SKIP LOCKED""".trimMargin(),
             mapOf(
                 "now" to Instant.now(clock).toString()
             ),

diff --git a/src/main/resources/db/migration/V12__indekser.sql b/src/main/resources/db/migration/V12__indekser.sql
@@ -0,0 +1 @@
+create index godskriv_opptjening_status_1 on godskriv_opptjening_status ((status->>'type'),(status->>'karanteneTil'));
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		create index godskriv_opptjening_status_1 on godskriv_opptjening_status ((status->>'type'),(status->>'karanteneTil'));