kandra-runtime/io.kandra.runtime.repository/KandraRepository

KandraRepository

class KandraRepository<T : Any>(session: CqlSession, schema: TableSchema, entityClass: KClass<T>, batchEngine: BatchEngine)

Blocking repository for performing CRUD operations on a ScyllaDB table.

Parameters

the entity type annotated with @ScyllaTable

Constructors

KandraRepository

constructor(session: CqlSession, schema: TableSchema, entityClass: KClass<T>, batchEngine: BatchEngine)

Functions

append

fun <V> append(entity: T, field: KProperty1<T, Collection<V>?>, values: Collection<V>, consistency: KandraConsistency? = null)

decrement

fun decrement(field: KProperty1<T, Long?>, partitionKeys: Map<String, Any>, by: Long = 1, consistency: KandraConsistency? = null)

delete

fun delete(entity: T)

deleteAll

fun deleteAll(entities: List<T>)

deleteBy

fun deleteBy(block: QueryContext.() -> Unit)

deleteById

fun deleteById(vararg keyValues: Any)

exists

fun exists(block: QueryContext.() -> Unit): Boolean

find

fun find(block: QueryContext.() -> Unit): T?

findActive

fun findActive(): List<T>

Returns all rows not yet soft-deleted. Requires @SoftDelete(markerProperty = "...") on T — throws KandraSchemaException otherwise.

findAll

fun findAll(limit: Int? = null, block: QueryContext.() -> Unit): List<T>

findById

fun findById(vararg idValues: Any, consistency: KandraConsistency? = null): T?

findPage

fun findPage(pageSize: Int, pageToken: String? = null, block: QueryContext.() -> Unit = {}): KandraPage<T>

increment

fun increment(field: KProperty1<T, Long?>, partitionKeys: Map<String, Any>, by: Long = 1, consistency: KandraConsistency? = null)

put

fun <K, V> put(entity: T, field: KProperty1<T, Map<K, V>?>, entries: Map<K, V>, consistency: KandraConsistency? = null)

raw

fun raw(cql: String, vararg params: Any?): List<Row>

rawQuery

fun rawQuery(query: KandraRawQuery): List<Row>

remove

fun <V> remove(entity: T, field: KProperty1<T, Collection<V>?>, values: Collection<V>, consistency: KandraConsistency? = null)

save

fun save(entity: T, ttlSeconds: Int? = null, timestampMicros: Long? = null, consistency: KandraConsistency? = null)

saveAll

fun saveAll(entities: List<T>, useBatch: Boolean = true)

saveIfNotExists

fun saveIfNotExists(entity: T, serialConsistency: KandraConsistency = KandraConsistency.LOCAL_SERIAL): Boolean

saveWithNulls

fun saveWithNulls(entity: T, ttlSeconds: Int? = null)

update

fun update(old: T, new: T)

updateForce

fun updateForce(entity: T)