sqlx4k-arrow/io.github.smyrgeorge.sqlx4k.arrow/ArrowCrudRepository

ArrowCrudRepository

interface ArrowCrudRepository<T> : CrudRepositoryHooks<T> (source)

Interface defining a contract for basic CRUD (Create, Read, Update, Delete) operations on a data source.

This interface abstracts common operations to be implemented for handling entities of type T. Each operation is asynchronous and returns a DbResult, encapsulating either the successful result or an error in case of failure.

Parameters

The type of the entity managed by the repository.

Functions

afterDeleteHook

open suspend fun afterDeleteHook(context: QueryExecutor, entity: T): T

afterInsertHook

open suspend fun afterInsertHook(context: QueryExecutor, entity: T): T

afterUpdateHook

open suspend fun afterUpdateHook(context: QueryExecutor, entity: T): T

aroundQuery

open suspend fun <R> aroundQuery(method: String, statement: Statement, block: suspend () -> R): R

batchInsert

abstract suspend fun batchInsert(context: QueryExecutor, entities: Iterable<T>): DbResult<List<T>>

Inserts multiple entities into the data source using the specified driver context.

batchUpdate

abstract suspend fun batchUpdate(context: QueryExecutor, entities: Iterable<T>): DbResult<List<T>>

Updates multiple entities in the data source using the specified driver context.

delete

abstract suspend fun delete(context: QueryExecutor, entity: T): DbResult<Unit>

Deletes the given entity from the data source using the specified driver context.

insert

abstract suspend fun insert(context: QueryExecutor, entity: T): DbResult<T>

Inserts the given entity into the data source using the specified driver context.

preDeleteHook

open suspend fun preDeleteHook(context: QueryExecutor, entity: T): T

preInsertHook

open suspend fun preInsertHook(context: QueryExecutor, entity: T): T

preUpdateHook

open suspend fun preUpdateHook(context: QueryExecutor, entity: T): T

save

abstract suspend fun save(context: QueryExecutor, entity: T): DbResult<T>

Saves the given entity to the data source using the specified driver context.

update

abstract suspend fun update(context: QueryExecutor, entity: T): DbResult<T>

Updates the given entity in the data source using the specified driver context.