Correct prepared statement.

navikt · Dec 19, 2024 · 07eeb89 · 07eeb89
1 parent 14eb3c6
commit 07eeb89
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/main/kotlin/db/migration/V168__dvh_pesys_fix_migrated_anker.kt b/src/main/kotlin/db/migration/V168__dvh_pesys_fix_migrated_anker.kt
@@ -13,14 +13,15 @@ class V168__dvh_pesys_fix_migrated_anker : BaseJavaMigration() {
             """
                 update klage.kafka_event
                     set json_payload = ?
+                    and status_id = ?
                     where id = ?
             """.trimIndent()
         )
 
         context.connection.createStatement().use { select ->
             select.executeQuery(
                 """
-                    select ke.id, ke.json_payload, ke.status_id
+                    select ke.id, ke.json_payload
                     from klage.kafka_event ke
                     where ke.type = 'STATS_DVH'
                       and ke.kilde_referanse in (
@@ -59,8 +60,8 @@ class V168__dvh_pesys_fix_migrated_anker : BaseJavaMigration() {
                         }
 
                         preparedStatement.setString(1, ourJacksonObjectMapper().writeValueAsString(modifiedVersion))
-                        preparedStatement.setObject(2, kafkaEventId)
-                        preparedStatement.setObject(3,"IKKE_SENDT")
+                        preparedStatement.setObject(2,"IKKE_SENDT")
+                        preparedStatement.setObject(3, kafkaEventId)
 
                         preparedStatement.executeUpdate()
                     }