kandra-runtime/io.kandra.runtime/StatementBuilder

StatementBuilder

class StatementBuilder(session: CqlSession, codec: KandraCodec = KandraCodec.default, debugConfig: DebugConfig = DebugConfig(), consistencyConfig: ConsistencyConfig = ConsistencyConfig(), cacheSize: Int = 1000)

Builds BoundStatement instances for all CRUD operations.

Prepared statements are cached in a bounded LRU cache keyed by CQL string. Idempotency is set per statement type — SELECT and DELETE are idempotent; plain INSERT and collection mutations are not (to prevent duplicate writes on retry).

Constructors

StatementBuilder

constructor(session: CqlSession, codec: KandraCodec = KandraCodec.default, debugConfig: DebugConfig = DebugConfig(), consistencyConfig: ConsistencyConfig = ConsistencyConfig(), cacheSize: Int = 1000)

Functions

appendToCollection

fun appendToCollection(schema: TableSchema, keyValues: List<Any>, columnName: String, values: Any, consistency: KandraConsistency? = null): BoundStatement

counterUpdate

fun counterUpdate(schema: TableSchema, columnName: String, partitionKeys: Map<String, Any>, delta: Long, consistency: KandraConsistency? = null): BoundStatement

deleteById

fun deleteById(schema: TableSchema, vararg idValues: Any): BoundStatement

deleteByPartitionKeys

fun deleteByPartitionKeys(schema: TableSchema, vararg keyValues: Any): BoundStatement

deleteLookup

fun deleteLookup(lookup: LookupTableSchema, indexValue: Any): BoundStatement

existsQuery

fun existsQuery(schema: TableSchema, whereCql: String, values: List<Any?>): BoundStatement

insertLookup

fun insertLookup(lookup: LookupTableSchema, entity: Any): BoundStatement

insertPrimary

fun insertPrimary(schema: TableSchema, entity: Any, ttlSeconds: Int? = null, ifNotExists: Boolean = false, timestampMicros: Long? = null, consistency: KandraConsistency? = null): BoundStatement

insertPrimaryWithNulls

fun insertPrimaryWithNulls(schema: TableSchema, entity: Any, ttlSeconds: Int? = null, ifNotExists: Boolean = false, timestampMicros: Long? = null, consistency: KandraConsistency? = null): BoundStatement

Same as insertPrimary but binds null as actual null (creates tombstones). Use when the caller explicitly wants to clear optional columns.

removeFromCollection

fun removeFromCollection(schema: TableSchema, keyValues: List<Any>, columnName: String, values: Any, consistency: KandraConsistency? = null): BoundStatement

selectById

fun selectById(schema: TableSchema, vararg idValues: Any, consistency: KandraConsistency? = null): BoundStatement

selectByLookup

fun selectByLookup(lookup: LookupTableSchema, value: Any, consistency: KandraConsistency? = null): BoundStatement

selectByPartitionKeyIn

fun selectByPartitionKeyIn(schema: TableSchema, ids: List<Any>, consistency: KandraConsistency? = null): BoundStatement