storm-core/com.zxhhyj.storm.crud

Package-level declarations

Types

RowBuilder

class RowBuilder

Builds a row of column-value pairs for SQL INSERT or UPDATE operations.

TransactionScopeImpl

class TransactionScopeImpl(database: DatabaseOperations) : TransactionScope

Default implementation of TransactionScope that delegates SQL execution to a DatabaseOperations.

Functions

batchInsert

suspend fun <T, E : Table<T>> DatabaseOperations.batchInsert(table: E, rows: List<Map<String, *>>): Long

Batch-inserts a list of pre-built row maps into table using a single parameterised statement. This is the only Map-based row entry point kept in the public API — it exists for the case where the source data is already in Map form (e.g. JSON-parsed, or transferred from another table) and you want one round-trip instead of N. For ordinary row construction, prefer the typed insert DSL.

delete

fun DatabaseOperations.delete(table: Table<*>): DeleteBuilder<*, *>

Returns a DeleteBuilder targeting table.

deleteAll

suspend fun DatabaseOperations.deleteAll(table: Table<*>): Long

Deletes all rows from table and returns the number of affected rows.

deleteWhere

suspend fun <T, E : Table<T>> DatabaseOperations.deleteWhere(table: E, condition: () -> ConditionalExpression): Long

Deletes rows from table matching where and returns the affected row count.

form

fun <T, E : Table<T>> DatabaseOperations.form(table: E): FormBuilder<T, E>

Alias for query.

insert

suspend fun <T, E : Table<T>> DatabaseOperations.insert(table: E, builder: RowBuilder.() -> Unit): Long

Inserts a row built by builder into table and returns the row-id.

query

fun <T, E : Table<T>> DatabaseOperations.query(table: E): FormBuilder<T, E>

Starts a query builder for table.

querySingle

suspend fun <T> DatabaseOperations.querySingle(table: Table<T>, where: () -> ConditionalExpression): QueryBuilder.ResultSet?

Queries a single result row matching where from table, or null if none found.

suspendTransaction

suspend fun <T> DatabaseOperations.~~suspendTransaction~~(block: suspend TransactionScope.() -> T): T

Executes block inside a suspend transaction. Rolls back on any exception or cancellation.

update

fun DatabaseOperations.update(table: Table<*>): UpdateBuilder<*, *>

Returns an UpdateBuilder targeting table.

updateAll

suspend fun DatabaseOperations.updateAll(table: Table<*>, builder: RowBuilder.() -> Unit): Long

Updates all rows in table with values from builder and returns the affected row count.

upsert

fun <T, E : Table<T>> DatabaseOperations.upsert(table: E): UpsertBuilder<T, E>

Starts an UPSERT builder for table — insert a row, or update the existing row on conflict. The conflict target must be set with UpsertBuilder.onConflict before calling UpsertBuilder.execute.