kandra-runtime/io.kandra.runtime.repository/KandraSuspendRepository

KandraSuspendRepository

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

Coroutine-friendly repository for performing CRUD operations on a ScyllaDB table.

All write operations delegate to BatchEngine (which wraps blocking driver calls); wrap in withContext(Dispatchers.IO) when needed in production.

Parameters

the entity type annotated with @ScyllaTable

Constructors

KandraSuspendRepository

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

Functions

append

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

decrement

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

delete

suspend fun delete(entity: T)

deleteAll

suspend fun deleteAll(entities: List<T>)

deleteBy

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

deleteById

suspend fun deleteById(vararg keyValues: Any)

exists

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

find

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

findActive

suspend fun findActive(): List<T>

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

findAll

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

findById

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

findPage

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

increment

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

put

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

raw

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

rawQuery

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

remove

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

save

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

saveAll

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

saveIfNotExists

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

saveWithNulls

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

update

suspend fun update(old: T, new: T)

updateForce

suspend fun updateForce(entity: T)