kandra-runtime/io.kandra.runtime/QueryExecutor

QueryExecutor

class QueryExecutor(session: CqlSession, schema: TableSchema, statementBuilder: StatementBuilder, codec: KandraCodec = KandraCodec.default, debugConfig: DebugConfig = DebugConfig())

Translates QueryContext predicates into CQL SELECT statements and decodes results.

Lookup predicates trigger a two-step query:

Query the lookup table for the primary table's full key (partition + clustering columns).
Query the primary table by that full key.

@SecondaryIndex predicates query the primary table directly (no two-step needed). A WARN is logged each time a secondary index query executes.

IN on a single-column partition key is supported — a DEBUG message is logged since it causes scatter-gather across partitions (legitimate but worth tracking).

Constructors

QueryExecutor

constructor(session: CqlSession, schema: TableSchema, statementBuilder: StatementBuilder, codec: KandraCodec = KandraCodec.default, debugConfig: DebugConfig = DebugConfig())

Functions

exists

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

existsSuspend

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

find

fun <T : Any> find(entityClass: KClass<T>, block: QueryContext.() -> Unit): T?

findActive

fun <T : Any> findActive(entityClass: KClass<T>): List<T>

findActiveSuspend

suspend fun <T : Any> findActiveSuspend(entityClass: KClass<T>): List<T>

findAll

fun <T : Any> findAll(entityClass: KClass<T>, block: QueryContext.() -> Unit): List<T>

findAllSuspend

suspend fun <T : Any> findAllSuspend(entityClass: KClass<T>, block: QueryContext.() -> Unit): List<T>

findById

fun <T : Any> findById(entityClass: KClass<T>, vararg idValues: Any, consistency: KandraConsistency? = null): T?

findByIdSuspend

suspend fun <T : Any> findByIdSuspend(entityClass: KClass<T>, vararg idValues: Any, consistency: KandraConsistency? = null): T?

findPage

fun <T : Any> findPage(entityClass: KClass<T>, pageSize: Int, pageToken: String?, block: QueryContext.() -> Unit): KandraPage<T>

findPageSuspend

suspend fun <T : Any> findPageSuspend(entityClass: KClass<T>, pageSize: Int, pageToken: String?, block: QueryContext.() -> Unit): KandraPage<T>

findSuspend

suspend fun <T : Any> findSuspend(entityClass: KClass<T>, block: QueryContext.() -> Unit): T?

raw

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

rawQuery

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

rawQuerySuspend

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

rawSuspend

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