From 06abd7e7f1862b2cd3cff21341c92037311f9d6d Mon Sep 17 00:00:00 2001
From: Dries Samyn <dries.samyn@r3.com>
Date: Tue, 9 Jan 2024 15:19:04 +0000
Subject: [PATCH] Remove transactions from StatManager read operations.

---
 .../corda/libs/statemanager/impl/StateManagerImpl.kt   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/libs/state-manager/state-manager-db-impl/src/main/kotlin/net/corda/libs/statemanager/impl/StateManagerImpl.kt b/libs/state-manager/state-manager-db-impl/src/main/kotlin/net/corda/libs/statemanager/impl/StateManagerImpl.kt
index 88f3cca3711..f2296438897 100644
--- a/libs/state-manager/state-manager-db-impl/src/main/kotlin/net/corda/libs/statemanager/impl/StateManagerImpl.kt
+++ b/libs/state-manager/state-manager-db-impl/src/main/kotlin/net/corda/libs/statemanager/impl/StateManagerImpl.kt
@@ -50,7 +50,7 @@ class StateManagerImpl(
         return if (keys.isEmpty()) {
             emptyMap()
         } else {
-            dataSource.connection.transaction { connection ->
+            dataSource.connection.use { connection ->
                 stateRepository.get(connection, keys)
             }.map {
                 it.fromPersistentEntity()
@@ -137,7 +137,7 @@ class StateManagerImpl(
         return if (filters.isEmpty()) {
             emptyMap()
         } else {
-            dataSource.connection.transaction { connection ->
+            dataSource.connection.use { connection ->
                 stateRepository.filterByAll(connection, filters)
             }.map {
                 it.fromPersistentEntity()
@@ -151,7 +151,7 @@ class StateManagerImpl(
         return if (filters.isEmpty()) {
             emptyMap()
         } else {
-            dataSource.connection.transaction { connection ->
+            dataSource.connection.use { connection ->
                 stateRepository.filterByAny(connection, filters)
             }.map {
                 it.fromPersistentEntity()
@@ -165,7 +165,7 @@ class StateManagerImpl(
         intervalFilter: IntervalFilter,
         metadataFilters: Collection<MetadataFilter>
     ): Map<String, State> {
-        return dataSource.connection.transaction { connection ->
+        return dataSource.connection.use { connection ->
             stateRepository.filterByUpdatedBetweenWithMetadataMatchingAll(connection, intervalFilter, metadataFilters)
         }.map {
             it.fromPersistentEntity()
@@ -178,7 +178,7 @@ class StateManagerImpl(
         intervalFilter: IntervalFilter,
         metadataFilters: Collection<MetadataFilter>
     ): Map<String, State> {
-        return dataSource.connection.transaction { connection ->
+        return dataSource.connection.use { connection ->
             stateRepository.filterByUpdatedBetweenWithMetadataMatchingAny(connection, intervalFilter, metadataFilters)
         }.map {
             it.fromPersistentEntity()