Legger til indeks for henholdsvis opplysninger_id og opplysing_id i o…

…pplysninger_opplysning tabellen. Lager transaksjon per kandidat vi sletter. Co-authored-by: Richard André Martinsen <[email protected]>
navikt · Jan 14, 2025 · 3f8ba2a · 3f8ba2a
1 parent 2a08d4d
commit 3f8ba2a
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 13 deletions.
diff --git a/...r/src/main/kotlin/no/nav/dagpenger/behandling/mediator/jobber/SlettFjernetOpplysninger.kt b/...r/src/main/kotlin/no/nav/dagpenger/behandling/mediator/jobber/SlettFjernetOpplysninger.kt
@@ -18,8 +18,8 @@ internal object SlettFjernetOpplysninger {
             period = 15.minutes.inWholeMilliseconds,
             action = {
                 try {
-                    if (System.getenv("NAIS_CLUSTER_NAME") == "skrudd-av") {
-                        vaktmesterRepository.slettOpplysninger(antall = 10)
+                    if (System.getenv("NAIS_CLUSTER_NAME") == "DEV-GCP") {
+                        vaktmesterRepository.slettOpplysninger(antall = 1)
                     } else {
                         logger.info { "Sletting av fjernet opplysninger er skrudd av" }
                     }

diff --git a/...src/main/kotlin/no/nav/dagpenger/behandling/mediator/repository/VaktmesterPostgresRepo.kt b/...src/main/kotlin/no/nav/dagpenger/behandling/mediator/repository/VaktmesterPostgresRepo.kt
@@ -1,7 +1,6 @@
 package no.nav.dagpenger.behandling.mediator.repository
 
 import kotliquery.Session
-import kotliquery.TransactionalSession
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import kotliquery.using
@@ -21,9 +20,10 @@ internal class VaktmesterPostgresRepo {
     fun slettOpplysninger(antall: Int = 1): List<UUID> {
         val slettet = mutableListOf<UUID>()
         using(sessionOf(dataSource)) { session ->
-            session.transaction { tx ->
-                tx.medLås(låsenøkkel) {
-                    hentAlleOpplysningerSomErFjernet(tx, antall).forEach { kandidat ->
+            val kandidater = hentAlleOpplysningerSomErFjernet(session, antall)
+            kandidater.forEach { kandidat ->
+                session.transaction { tx ->
+                    tx.medLås(låsenøkkel) {
                         withLoggingContext(
                             "behandlingId" to kandidat.behandlingId.toString(),
                             "opplysningerId" to kandidat.opplysningerId.toString(),
@@ -42,7 +42,7 @@ internal class VaktmesterPostgresRepo {
                                 }
                                 slettet.add(opplysningId)
                             }
-                            logger.info { "Slettet ${kandidat.opplysninger().size} opplysninger " }
+                            logger.info { "Slettet ${kandidat.opplysninger().size} opplysninger" }
                         }
                     }
                 }
@@ -64,10 +64,10 @@ internal class VaktmesterPostgresRepo {
     }
 
     private fun hentAlleOpplysningerSomErFjernet(
-        tx: TransactionalSession,
+        session: Session,
         antall: Int,
     ): List<Kandidater> {
-        val kandidater = hentOpplysningerIder(tx, antall)
+        val kandidater = hentOpplysningerIder(session, antall)
 
         //language=PostgreSQL
         val query =
@@ -81,7 +81,7 @@ internal class VaktmesterPostgresRepo {
 
         val opplysninger =
             kandidater.onEach { kandidat ->
-                tx.run(
+                session.run(
                     queryOf(
                         query,
                         mapOf("opplysninger_id" to kandidat.opplysningerId),
@@ -97,7 +97,7 @@ internal class VaktmesterPostgresRepo {
     }
 
     private fun hentOpplysningerIder(
-        tx: TransactionalSession,
+        session: Session,
         antall: Int,
     ): List<Kandidater> {
         //language=PostgreSQL
@@ -112,7 +112,7 @@ internal class VaktmesterPostgresRepo {
             """.trimIndent()
 
         val opplysningerIder =
-            tx.run(
+            session.run(
                 queryOf(
                     test,
                     mapOf("antall" to antall),

diff --git a/mediator/src/main/resources/db/migration/V36__INDEKS_OPPLYSNINGER_OPPLYSNING_ID.sql b/mediator/src/main/resources/db/migration/V36__INDEKS_OPPLYSNINGER_OPPLYSNING_ID.sql
@@ -0,0 +1,2 @@
+CREATE INDEX idx_opplysninger_opplysning_id ON opplysninger_opplysning (opplysning_id);
+CREATE INDEX idx_opplysninger_opplysninger_id ON opplysninger_opplysning (opplysninger_id);
diff --git a/mediator/src/test/kotlin/no/nav/dagpenger/behandling/db/PostgresMigrationTest.kt b/mediator/src/test/kotlin/no/nav/dagpenger/behandling/db/PostgresMigrationTest.kt
@@ -10,7 +10,7 @@ class PostgresMigrationTest {
     fun `Migration scripts are applied successfully`() {
         withCleanDb {
             val migrations = runMigration()
-            migrations shouldBeExactly 34
+            migrations shouldBeExactly 35
         }
     }
 }
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		CREATE INDEX idx_opplysninger_opplysning_id ON opplysninger_opplysning (opplysning_id);
		CREATE INDEX idx_opplysninger_opplysninger_id ON opplysninger_opplysning (opplysninger_id);