strips/foundation
2
0
Fork 0
mirror of https://github.com/GayPizzaSpecifications/foundation.git synced 2026-04-02 04:40:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Persistent Store Improvements

Browse Source 
- Fix bug where find() would return Unit while still performing the operational.
- Add a getAll() function for fetching all entities of a specific type.
- Close persistent stores on plugin disable.
This commit is contained in:
Kenneth Endfinger
2021-12-22 21:11:16 -05:00
parent 5f6a663cb3
commit 9533dd5e4f
4 changed files with 33 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/persist/PersistentStore.kt
View File

@@ -2,21 +2,31 @@ package cloud.kubelet.foundation.core.persist
import cloud.kubelet.foundation.core.FoundationCorePlugin
import jetbrains.exodus.entitystore.Entity
import jetbrains.exodus.entitystore.EntityIterable
import jetbrains.exodus.entitystore.PersistentEntityStores
import jetbrains.exodus.entitystore.StoreTransaction
class PersistentStore(corePlugin: FoundationCorePlugin, fileStoreName: String) : AutoCloseable {
private val fileStorePath = corePlugin.pluginDataPath.resolve("persistence/${fileStoreName}")
internal val entityStore = PersistentEntityStores.newInstance(fileStorePath.toFile())
private val entityStore = PersistentEntityStores.newInstance(fileStorePath.toFile())
fun transact(block: (StoreTransaction) -> Unit) = entityStore.executeInTransaction(block)
fun <R> transact(block: (StoreTransaction) -> R): R {
var result: R? = null
entityStore.executeInTransaction { tx ->
result = block(tx)
}
return result!!
}
fun create(entityTypeName: String, populate: Entity.() -> Unit) = transact { tx ->
val entity = tx.newEntity(entityTypeName)
populate(entity)
}
fun <T> find(entityTypeName: String, propertyName: String, value: Comparable<T>) =
fun getAll(entityTypeName: String) =
transact { tx -> tx.getAll(entityTypeName) }
fun <T> find(entityTypeName: String, propertyName: String, value: Comparable<T>): EntityIterable =
transact { tx -> tx.find(entityTypeName, propertyName, value) }
override fun close() {