diff --git a/database/src/main/postgres/flows/V1.9.8__get_flow_partitionings.sql b/database/src/main/postgres/flows/V0.2.0.58__get_flow_partitionings.sql similarity index 100% rename from database/src/main/postgres/flows/V1.9.8__get_flow_partitionings.sql rename to database/src/main/postgres/flows/V0.2.0.58__get_flow_partitionings.sql diff --git a/database/src/main/postgres/runs/V1.9.9__get_partitioning_main_flow.sql b/database/src/main/postgres/runs/V0.2.0.30__get_partitioning_main_flow.sql similarity index 100% rename from database/src/main/postgres/runs/V1.9.9__get_partitioning_main_flow.sql rename to database/src/main/postgres/runs/V0.2.0.30__get_partitioning_main_flow.sql diff --git a/database/src/main/postgres/runs/V1.9.12__get_partitioning.sql b/database/src/main/postgres/runs/V0.2.0.31__get_partitioning.sql similarity index 100% rename from database/src/main/postgres/runs/V1.9.12__get_partitioning.sql rename to database/src/main/postgres/runs/V0.2.0.31__get_partitioning.sql diff --git a/database/src/test/scala/za/co/absa/atum/database/flows/GetFlowPartitioningsIntegrationTests.scala b/database/src/test/scala/za/co/absa/atum/database/flows/GetFlowPartitioningsIntegrationTests.scala index 904cd42b9..0a9745ce8 100644 --- a/database/src/test/scala/za/co/absa/atum/database/flows/GetFlowPartitioningsIntegrationTests.scala +++ b/database/src/test/scala/za/co/absa/atum/database/flows/GetFlowPartitioningsIntegrationTests.scala @@ -34,7 +34,7 @@ class GetFlowPartitioningsIntegrationTests extends DBTestSuite { |{ | "version": 1, | "keys": ["keyA", "keyB", "keyC"], - | "keysToValues": { + | "keysToValuesMap": { | "keyA": "valueA", | "keyB": "valueB", | "keyC": "valueC" @@ -48,7 +48,7 @@ class GetFlowPartitioningsIntegrationTests extends DBTestSuite { |{ | "version": 1, | "keys": ["keyA", "keyB"], - | "keysToValues": { + | "keysToValuesMap": { | "keyA": "valueA", | "keyB": "valueB" | } @@ -61,7 +61,7 @@ class GetFlowPartitioningsIntegrationTests extends DBTestSuite { |{ | "version": 1, | "keys": ["keyD", "keyE", "keyF"], - | "keysToValues": { + | "keysToValuesMap": { | "keyD": "valueD", | "keyE": "valueE", | "keyF": "valueF" diff --git a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala index 21d623126..e0612b456 100644 --- a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala +++ b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningCheckpointsIntegrationTests.scala @@ -38,7 +38,7 @@ class GetPartitioningCheckpointsIntegrationTests extends DBTestSuite { |{ | "version": 1, | "keys": ["keyX", "keyY", "keyZ"], - | "keysToValues": { + | "keysToValuesMap": { | "keyX": "value1", | "keyZ": "value3", | "keyY": "value2" diff --git a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningIntegrationTests.scala b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningIntegrationTests.scala index 6d2ac96ca..0296598a8 100644 --- a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningIntegrationTests.scala +++ b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningIntegrationTests.scala @@ -30,7 +30,7 @@ class GetPartitioningIntegrationTests extends DBTestSuite { |{ | "version":1, | "keys":["key1","key2","key3","key4"], - | "keysToValues":{ + | "keysToValuesMap":{ | "key1":"valueX", | "key2":"valueY", | "key3":"valueZ", @@ -46,7 +46,7 @@ class GetPartitioningIntegrationTests extends DBTestSuite { |{ | "version":1, | "keys":["key1","key2","key3","key4"], - | "keysToValues":{ + | "keysToValuesMap":{ | "key1":"valueX", | "key2":"valueX", | "key3":"valueX", @@ -91,7 +91,7 @@ class GetPartitioningIntegrationTests extends DBTestSuite { assert { val retrievedPartitioningAsJson = Json.fromString(row.getJsonB("o_partitioning").get.value) val expectedPartitioningAsJson = Json.fromString(partitioning1Value) - retrievedPartitioningAsJson \\ "keysToValues" == expectedPartitioningAsJson \\ "keysToValues" && + retrievedPartitioningAsJson \\ "keysToValuesMap" == expectedPartitioningAsJson \\ "keysToValuesMap" && retrievedPartitioningAsJson \\ "keys" == expectedPartitioningAsJson \\ "keys" } assert(row.getString("author").contains("Fantômas")) diff --git a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMainFlowIntegrationTests.scala b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMainFlowIntegrationTests.scala index ed2f9d5a0..2042cf146 100644 --- a/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMainFlowIntegrationTests.scala +++ b/database/src/test/scala/za/co/absa/atum/database/runs/GetPartitioningMainFlowIntegrationTests.scala @@ -28,7 +28,7 @@ class GetPartitioningMainFlowIntegrationTests extends DBTestSuite { |{ | "version": 1, | "keys": ["keyX", "keyY", "keyZ"], - | "keysToValues": { + | "keysToValuesMap": { | "keyX": "value1", | "keyZ": "value3", | "keyY": "value2" @@ -42,7 +42,7 @@ class GetPartitioningMainFlowIntegrationTests extends DBTestSuite { |{ | "version": 1, | "keys": ["key1", "key3", "key2", "key4"], - | "keysToValues": { + | "keysToValuesMap": { | "key1": "valueX", | "key2": "valueY", | "key3": "valueZ", diff --git a/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowPartitionings.scala b/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowPartitionings.scala index 7e3555c9c..a5206ff3d 100644 --- a/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowPartitionings.scala +++ b/server/src/main/scala/za/co/absa/atum/server/api/database/flows/functions/GetFlowPartitionings.scala @@ -69,7 +69,7 @@ object GetFlowPartitionings { case Left(decodingFailure) => Left(decodingFailure) case Right(partitioningForDB) => val partitioningDTO = partitioningForDB.keys.map { key => - PartitionDTO(key, partitioningForDB.keysToValues(key)) + PartitionDTO(key, partitioningForDB.keysToValuesMap(key)) } resultsToPartitioningWithIdDTOs(tail, acc :+ PartitioningWithIdDTO(head.id, partitioningDTO, head.author)) } diff --git a/server/src/main/scala/za/co/absa/atum/server/api/repository/PartitioningRepositoryImpl.scala b/server/src/main/scala/za/co/absa/atum/server/api/repository/PartitioningRepositoryImpl.scala index 8ca576a35..1f2505375 100644 --- a/server/src/main/scala/za/co/absa/atum/server/api/repository/PartitioningRepositoryImpl.scala +++ b/server/src/main/scala/za/co/absa/atum/server/api/repository/PartitioningRepositoryImpl.scala @@ -128,7 +128,7 @@ class PartitioningRepositoryImpl ( error => ZIO.fail(GeneralDatabaseError(s"Failed to decode JSON: $error")), partitioningForDB => { val partitioningDTO: PartitioningDTO = partitioningForDB.keys.map { key => - PartitionDTO(key, partitioningForDB.keysToValues(key)) + PartitionDTO(key, partitioningForDB.keysToValuesMap(key)) } ZIO.succeed(PartitioningWithIdDTO(id, partitioningDTO, author)) } diff --git a/server/src/test/scala/za/co/absa/atum/server/api/TestData.scala b/server/src/test/scala/za/co/absa/atum/server/api/TestData.scala index e36e0d615..7ac7ed79a 100644 --- a/server/src/test/scala/za/co/absa/atum/server/api/TestData.scala +++ b/server/src/test/scala/za/co/absa/atum/server/api/TestData.scala @@ -56,7 +56,7 @@ trait TestData { |{ | "version": 1, | "keys": ["key1", "key2"], - | "keysToValues": { + | "keysToValuesMap": { | "key1": "val1", | "key2": "val2" | }