From bc6ef74c6aa7e36db2933e6757d7e571a23cc668 Mon Sep 17 00:00:00 2001 From: szymonsztuka Date: Tue, 2 Oct 2018 16:49:31 +0100 Subject: [PATCH] CordaPersistence class minor refactoring to align with Enterprise repo. (#4012) --- .../corda/nodeapi/internal/persistence/CordaPersistence.kt | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/node-api/src/main/kotlin/net/corda/nodeapi/internal/persistence/CordaPersistence.kt b/node-api/src/main/kotlin/net/corda/nodeapi/internal/persistence/CordaPersistence.kt index 9bdbeccfcd..e1558971eb 100644 --- a/node-api/src/main/kotlin/net/corda/nodeapi/internal/persistence/CordaPersistence.kt +++ b/node-api/src/main/kotlin/net/corda/nodeapi/internal/persistence/CordaPersistence.kt @@ -38,7 +38,8 @@ enum class TransactionIsolationLevel { /** * The JDBC constant value of the same name but prefixed with TRANSACTION_ defined in [java.sql.Connection]. */ - val jdbcValue: Int = java.sql.Connection::class.java.getField("TRANSACTION_$name").get(null) as Int + val jdbcString = "TRANSACTION_$name" + val jdbcValue: Int = java.sql.Connection::class.java.getField(jdbcString).get(null) as Int } private val _contextDatabase = InheritableThreadLocal() @@ -63,6 +64,7 @@ class CordaPersistence( HibernateConfiguration(schemas, databaseConfig, attributeConverters, jdbcUrl) } } + val entityManagerFactory get() = hibernateConfig.sessionFactoryForRegisteredSchemas data class Boundary(val txId: UUID, val success: Boolean)