From 50a3198a17527c3517ca944a8ca4b69a3849643b Mon Sep 17 00:00:00 2001 From: Mikael Bjerga <6940327+bjerga@users.noreply.github.com> Date: Mon, 29 Jan 2024 10:17:41 +0100 Subject: [PATCH] Bump Exposed til 0.46.0 (#406) --- db/gradle.properties | 2 +- .../inntektsmelding/db/AapenImRepo.kt | 11 +++-- .../db/ForespoerselRepository.kt | 46 ++++++++++-------- .../db/InntektsmeldingRepository.kt | 47 +++++++++---------- 4 files changed, 57 insertions(+), 49 deletions(-) diff --git a/db/gradle.properties b/db/gradle.properties index 5c97c4c8f..4423e3d6c 100644 --- a/db/gradle.properties +++ b/db/gradle.properties @@ -1,5 +1,5 @@ # Dependency versions -exposedVersion=0.45.0 +exposedVersion=0.46.0 flywayVersion=10.6.0 hikariVersion=5.1.0 postgresqlVersion=42.7.1 diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/AapenImRepo.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/AapenImRepo.kt index 6b36bc8f5..21a12bf61 100644 --- a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/AapenImRepo.kt +++ b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/AapenImRepo.kt @@ -10,7 +10,7 @@ import org.jetbrains.exposed.sql.Query import org.jetbrains.exposed.sql.SortOrder import org.jetbrains.exposed.sql.and import org.jetbrains.exposed.sql.insert -import org.jetbrains.exposed.sql.select +import org.jetbrains.exposed.sql.selectAll import org.jetbrains.exposed.sql.transactions.transaction import org.jetbrains.exposed.sql.update import java.util.UUID @@ -42,7 +42,9 @@ class AapenImRepo(private val db: Database) { transaction(db) { AapenInntektsmeldingEntitet.update( where = { - (AapenInntektsmeldingEntitet.id eqSubQuery hentNyesteImQuery(aapenId).adjustSlice { slice(AapenInntektsmeldingEntitet.id) }) and + val nyesteImIdQuery = hentNyesteImQuery(aapenId).adjustSelect { select(AapenInntektsmeldingEntitet.id) } + + (AapenInntektsmeldingEntitet.id eqSubQuery nyesteImIdQuery) and AapenInntektsmeldingEntitet.journalpostId.isNull() } ) { @@ -55,8 +57,7 @@ class AapenImRepo(private val db: Database) { private fun hentNyesteImQuery(aapenId: UUID): Query = AapenInntektsmeldingEntitet - .select { - AapenInntektsmeldingEntitet.aapenId eq aapenId - } + .selectAll() + .where { AapenInntektsmeldingEntitet.aapenId eq aapenId } .orderBy(AapenInntektsmeldingEntitet.opprettet, SortOrder.DESC) .limit(1) diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/ForespoerselRepository.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/ForespoerselRepository.kt index 1e15b41d3..3670e93ce 100644 --- a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/ForespoerselRepository.kt +++ b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/ForespoerselRepository.kt @@ -6,7 +6,7 @@ import no.nav.helsearbeidsgiver.inntektsmelding.db.tabell.ForespoerselEntitet import org.jetbrains.exposed.sql.Database import org.jetbrains.exposed.sql.and import org.jetbrains.exposed.sql.insert -import org.jetbrains.exposed.sql.select +import org.jetbrains.exposed.sql.selectAll import org.jetbrains.exposed.sql.transactions.transaction import org.jetbrains.exposed.sql.update import java.time.LocalDateTime @@ -23,7 +23,12 @@ class ForespoerselRepository(private val db: Database) { fun oppdaterOppgaveId(forespoerselId: String, oppgaveId: String) { val requestTimer = requestLatency.labels("oppdaterOppgaveId").startTimer() transaction(db) { - ForespoerselEntitet.update({ (ForespoerselEntitet.forespoerselId eq forespoerselId) and (ForespoerselEntitet.oppgaveId eq null) }) { + ForespoerselEntitet.update( + where = { + (ForespoerselEntitet.forespoerselId eq forespoerselId) and + ForespoerselEntitet.oppgaveId.isNull() + } + ) { it[ForespoerselEntitet.oppgaveId] = oppgaveId } }.also { @@ -34,7 +39,12 @@ class ForespoerselRepository(private val db: Database) { fun oppdaterSakId(forespoerselId: String, sakId: String) { val requestTimer = requestLatency.labels("oppdaterSakId").startTimer() transaction(db) { - ForespoerselEntitet.update({ (ForespoerselEntitet.forespoerselId eq forespoerselId) and (ForespoerselEntitet.sakId eq null) }) { + ForespoerselEntitet.update( + where = { + (ForespoerselEntitet.forespoerselId eq forespoerselId) and + ForespoerselEntitet.sakId.isNull() + } + ) { it[ForespoerselEntitet.sakId] = sakId } }.also { @@ -45,9 +55,9 @@ class ForespoerselRepository(private val db: Database) { fun hentOppgaveId(forespoerselId: UUID): String? { val requestTimer = requestLatency.labels("hentOppgaveId").startTimer() return transaction(db) { - ForespoerselEntitet.select { - ForespoerselEntitet.forespoerselId eq forespoerselId.toString() - } + ForespoerselEntitet + .selectAll() + .where { ForespoerselEntitet.forespoerselId eq forespoerselId.toString() } .firstOrNull(ForespoerselEntitet.oppgaveId) }.also { requestTimer.observeDuration() @@ -57,9 +67,9 @@ class ForespoerselRepository(private val db: Database) { fun hentSakId(forespoerselId: UUID): String? { val requestTimer = requestLatency.labels("hentSakId").startTimer() return transaction(db) { - ForespoerselEntitet.select { - ForespoerselEntitet.forespoerselId eq forespoerselId.toString() - } + ForespoerselEntitet + .selectAll() + .where { ForespoerselEntitet.forespoerselId eq forespoerselId.toString() } .firstOrNull(ForespoerselEntitet.sakId) }.also { requestTimer.observeDuration() @@ -69,10 +79,10 @@ class ForespoerselRepository(private val db: Database) { fun hentOrgnr(forespoerselId: UUID): String? { val requestTimer = requestLatency.labels("hentOrgnr").startTimer() return transaction(db) { - ForespoerselEntitet.let { - it.select { (it.forespoerselId eq forespoerselId.toString()) } - .firstOrNull(it.orgnr) - } + ForespoerselEntitet + .selectAll() + .where { ForespoerselEntitet.forespoerselId eq forespoerselId.toString() } + .firstOrNull(ForespoerselEntitet.orgnr) }.also { requestTimer.observeDuration() } @@ -81,12 +91,10 @@ class ForespoerselRepository(private val db: Database) { fun lagreForespoersel(forespoerselId: String, organisasjonsnummer: String) { val requestTimer = requestLatency.labels("lagreForespoersel").startTimer() transaction(db) { - ForespoerselEntitet.run { - insert { - it[this.forespoerselId] = forespoerselId - it[orgnr] = organisasjonsnummer - it[opprettet] = LocalDateTime.now() - } + ForespoerselEntitet.insert { + it[this.forespoerselId] = forespoerselId + it[orgnr] = organisasjonsnummer + it[opprettet] = LocalDateTime.now() } }.also { requestTimer.observeDuration() diff --git a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/InntektsmeldingRepository.kt b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/InntektsmeldingRepository.kt index 528c00990..740b99460 100644 --- a/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/InntektsmeldingRepository.kt +++ b/db/src/main/kotlin/no/nav/helsearbeidsgiver/inntektsmelding/db/InntektsmeldingRepository.kt @@ -11,7 +11,7 @@ import org.jetbrains.exposed.sql.Query import org.jetbrains.exposed.sql.SortOrder import org.jetbrains.exposed.sql.and import org.jetbrains.exposed.sql.insert -import org.jetbrains.exposed.sql.select +import org.jetbrains.exposed.sql.selectAll import org.jetbrains.exposed.sql.transactions.transaction import org.jetbrains.exposed.sql.update import java.time.LocalDateTime @@ -28,15 +28,13 @@ class InntektsmeldingRepository(private val db: Database) { .labelNames("method") .register() - fun lagreInntektsmelding(forespørselId: String, inntektsmeldingDokument: Inntektsmelding) { + fun lagreInntektsmelding(forespoerselId: String, inntektsmeldingDokument: Inntektsmelding) { val requestTimer = requestLatency.labels("lagreInntektsmelding").startTimer() transaction(db) { - InntektsmeldingEntitet.run { - insert { - it[forespoerselId] = forespørselId - it[dokument] = inntektsmeldingDokument - it[innsendt] = LocalDateTime.now() - } + InntektsmeldingEntitet.insert { + it[this.forespoerselId] = forespoerselId + it[dokument] = inntektsmeldingDokument + it[innsendt] = LocalDateTime.now() } }.also { requestTimer.observeDuration() @@ -46,7 +44,7 @@ class InntektsmeldingRepository(private val db: Database) { fun hentNyeste(forespoerselId: UUID): Inntektsmelding? { val requestTimer = requestLatency.labels("hentNyeste").startTimer() return transaction(db) { - hentNyesteQuery(forespoerselId) + hentNyesteImQuery(forespoerselId) .firstOrNull() ?.getOrNull(InntektsmeldingEntitet.dokument) }.also { @@ -54,11 +52,12 @@ class InntektsmeldingRepository(private val db: Database) { } } - fun hentNyesteEksternEllerInternInntektsmelding(forespørselId: String): Pair? { + fun hentNyesteEksternEllerInternInntektsmelding(forespoerselId: String): Pair? { val requestTimer = requestLatency.labels("hentNyesteInternEllerEkstern").startTimer() return transaction(db) { - InntektsmeldingEntitet.slice(InntektsmeldingEntitet.dokument, InntektsmeldingEntitet.eksternInntektsmelding) - .select { (InntektsmeldingEntitet.forespoerselId eq forespørselId) } + InntektsmeldingEntitet + .select(InntektsmeldingEntitet.dokument, InntektsmeldingEntitet.eksternInntektsmelding) + .where { InntektsmeldingEntitet.forespoerselId eq forespoerselId } .orderBy(InntektsmeldingEntitet.innsendt, SortOrder.DESC) .limit(1) .map { @@ -80,7 +79,9 @@ class InntektsmeldingRepository(private val db: Database) { val antallOppdatert = transaction(db) { InntektsmeldingEntitet.update( where = { - (InntektsmeldingEntitet.id eqSubQuery hentNyesteQuery(forespoerselId).adjustSlice { slice(InntektsmeldingEntitet.id) }) and + val nyesteImIdQuery = hentNyesteImQuery(forespoerselId).adjustSelect { select(InntektsmeldingEntitet.id) } + + (InntektsmeldingEntitet.id eqSubQuery nyesteImIdQuery) and InntektsmeldingEntitet.journalpostId.isNull() } ) { @@ -96,22 +97,20 @@ class InntektsmeldingRepository(private val db: Database) { requestTimer.observeDuration() } - fun lagreEksternInntektsmelding(forespørselId: String, eksternIm: EksternInntektsmelding) { + fun lagreEksternInntektsmelding(forespoerselId: String, eksternIm: EksternInntektsmelding) { transaction(db) { - InntektsmeldingEntitet.run { - insert { - it[forespoerselId] = forespørselId - it[eksternInntektsmelding] = eksternIm - it[innsendt] = LocalDateTime.now() - } + InntektsmeldingEntitet.insert { + it[this.forespoerselId] = forespoerselId + it[eksternInntektsmelding] = eksternIm + it[innsendt] = LocalDateTime.now() } } } - private fun hentNyesteQuery(forespoerselId: UUID): Query = - InntektsmeldingEntitet.select { - (InntektsmeldingEntitet.forespoerselId eq forespoerselId.toString()) and InntektsmeldingEntitet.dokument.isNotNull() - } + private fun hentNyesteImQuery(forespoerselId: UUID): Query = + InntektsmeldingEntitet + .selectAll() + .where { (InntektsmeldingEntitet.forespoerselId eq forespoerselId.toString()) and InntektsmeldingEntitet.dokument.isNotNull() } .orderBy(InntektsmeldingEntitet.innsendt, SortOrder.DESC) .limit(1) }