exposed-dao-r2dbc/org.jetbrains.exposed.v1.dao.r2dbc/EntityCache

EntityCache

class EntityCache(transaction: R2dbcTransaction)

Class responsible for the storage of Entity instances in a specific transaction.

Constructors

EntityCache

constructor(transaction: R2dbcTransaction)

Properties

data

val data: ConcurrentHashMap<IdTable<*>, MutableMap<Any, Entity<*>>>

The mapping of IdTables to associated Entity instances (as a mapping of entity id values to entities).

Functions

clear

suspend fun clear(flush: Boolean = true)

Clears this EntityCache of all stored data, including any reference mappings.

clearReferrersCache

fun clearReferrersCache()

Clears this EntityCache of stored data that maps cached parent entities to their referencing child entities.

find

fun <ID : Any, T : Entity<ID>> find(f: EntityClass<ID, T>, id: EntityID<ID>): T?

Searches this EntityCache for an Entity by its EntityID value using its associated EntityClass as the key.

findAll

fun <ID : Any, T : Entity<ID>> findAll(entityClass: EntityClass<ID, T>): List<T>

Gets all Entity instances in this EntityCache that match the associated EntityClass.

flush

suspend fun flush()

Sends all pending inserts and updates for all Entity instances in this EntityCache to the database.

suspend fun flush(tables: Iterable<IdTable<*>>)

Sends all pending inserts and updates for Entity instances in this EntityCache to the database.

getOrPutReferrers

suspend fun <ID : Any, R : Entity<ID>> getOrPutReferrers(sourceId: EntityID<*>, key: Column<*>, refs: suspend () -> SizedIterable<R>): SizedIterable<R>

Returns a SizedIterable containing all child Entity instances that reference the parent entity with the provided sourceId using the specified key column.

getReferrers

fun <R : Entity<*>> getReferrers(sourceId: EntityID<*>, key: Column<*>): SizedIterable<R>?

Returns a SizedIterable containing all child Entity instances that reference the parent entity with the provided sourceId using the specified key column.

remove

fun <ID : Any, T : Entity<ID>> remove(table: IdTable<ID>, o: T)

Removes the specified Entity from this EntityCache using its associated table as the key.

scheduleInsert

fun <ID : Any> scheduleInsert(klass: EntityClass<ID, Entity<ID>>, entity: Entity<ID>)

Stores the specified Entity in this EntityCache as scheduled to be inserted into the database.

scheduleUpdate

fun <ID : Any> scheduleUpdate(klass: EntityClass<ID, Entity<ID>>, entity: Entity<ID>)

Stores the specified Entity in this EntityCache as scheduled to be updated in the database.

store

fun store(o: Entity<*>)

Stores the specified Entity in this cache.