CrdtNodeRepository class

Methods

count(DatabaseSession session, {WhereExpressionBuilder<CrdtNodeTable>? where, int? limit, Transaction? transaction}) → Future<int>

Counts the number of rows matching the where expression. If omitted, will return the count of all rows in the table.

delete(DatabaseSession session, List<CrdtNode> rows, {OrderByBuilder<CrdtNodeTable>? orderBy, OrderByListBuilder<CrdtNodeTable>? orderByList, Transaction? transaction, bool noReturn = false}) → Future<List<CrdtNode>>

Deletes all CrdtNodes in the list and returns the deleted rows.

deleteRow(DatabaseSession session, CrdtNode row, {Transaction? transaction}) → Future<CrdtNode>

Deletes a single CrdtNode.

deleteWhere(DatabaseSession session, {required WhereExpressionBuilder<CrdtNodeTable> where, OrderByBuilder<CrdtNodeTable>? orderBy, OrderByListBuilder<CrdtNodeTable>? orderByList, Transaction? transaction, bool noReturn = false}) → Future<List<CrdtNode>>

Deletes all rows matching the where expression.

find(DatabaseSession session, {WhereExpressionBuilder<CrdtNodeTable>? where, int? limit, int? offset, OrderByBuilder<CrdtNodeTable>? orderBy, OrderByListBuilder<CrdtNodeTable>? orderByList, Transaction? transaction, LockMode? lockMode, LockBehavior? lockBehavior}) → Future<List<CrdtNode>>

Returns a list of CrdtNodes matching the given query parameters.

findById(DatabaseSession session, int id, {Transaction? transaction, LockMode? lockMode, LockBehavior? lockBehavior}) → Future<CrdtNode?>

Finds a single CrdtNode by its id or null if no such row exists.

findFirstRow(DatabaseSession session, {WhereExpressionBuilder<CrdtNodeTable>? where, int? offset, OrderByBuilder<CrdtNodeTable>? orderBy, OrderByListBuilder<CrdtNodeTable>? orderByList, Transaction? transaction, LockMode? lockMode, LockBehavior? lockBehavior}) → Future<CrdtNode?>

Returns the first matching CrdtNode matching the given query parameters.

insert(DatabaseSession session, List<CrdtNode> rows, {Transaction? transaction, bool ignoreConflicts = false, bool noReturn = false}) → Future<List<CrdtNode>>

Inserts all CrdtNodes in the list and returns the inserted rows.

insertRow(DatabaseSession session, CrdtNode row, {Transaction? transaction}) → Future<CrdtNode>

Inserts a single CrdtNode and returns the inserted row.

lockRows(DatabaseSession session, {required WhereExpressionBuilder<CrdtNodeTable> where, required LockMode lockMode, required Transaction transaction, LockBehavior lockBehavior = _isd.LockBehavior.wait}) → Future<void>

Acquires row-level locks on CrdtNode rows matching the where expression.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

update(DatabaseSession session, List<CrdtNode> rows, {ColumnSelections<CrdtNodeTable>? columns, Transaction? transaction, bool noReturn = false}) → Future<List<CrdtNode>>

Updates all CrdtNodes in the list and returns the updated rows. If columns is provided, only those columns will be updated. Defaults to all columns. This is an atomic operation, meaning that if one of the rows fails to update, none of the rows will be updated.

updateById(DatabaseSession session, int id, {required ColumnValueListBuilder<CrdtNodeUpdateTable> columnValues, Transaction? transaction}) → Future<CrdtNode?>

Updates a single CrdtNode by its id with the specified columnValues. Returns the updated row or null if no row with the given id exists.

updateRow(DatabaseSession session, CrdtNode row, {ColumnSelections<CrdtNodeTable>? columns, Transaction? transaction}) → Future<CrdtNode>

Updates a single CrdtNode. The row needs to have its id set. Optionally, a list of columns can be provided to only update those columns. Defaults to all columns.

updateWhere(DatabaseSession session, {required ColumnValueListBuilder<CrdtNodeUpdateTable> columnValues, required WhereExpressionBuilder<CrdtNodeTable> where, int? limit, int? offset, OrderByBuilder<CrdtNodeTable>? orderBy, OrderByListBuilder<CrdtNodeTable>? orderByList, Transaction? transaction, bool noReturn = false}) → Future<List<CrdtNode>>

Updates all CrdtNodes matching the where expression with the specified columnValues. Returns the list of updated rows.

upsert(DatabaseSession session, List<CrdtNode> rows, {required ColumnSelections<CrdtNodeTable> conflictColumns, ColumnSelections<CrdtNodeTable>? updateColumns, WhereExpressionBuilder<CrdtNodeTable>? updateWhere, Transaction? transaction, bool noReturn = false}) → Future<List<CrdtNode>>

Upserts all CrdtNodes in the list and returns the resulting rows.

upsertRow(DatabaseSession session, CrdtNode row, {required ColumnSelections<CrdtNodeTable> conflictColumns, ColumnSelections<CrdtNodeTable>? updateColumns, WhereExpressionBuilder<CrdtNodeTable>? updateWhere, Transaction? transaction}) → Future<CrdtNode?>

Upserts a single CrdtNode and returns the resulting row.

watch(DatabaseSession session, {WhereExpressionBuilder<CrdtNodeTable>? where, int? limit, int? offset, OrderByBuilder<CrdtNodeTable>? orderBy, OrderByListBuilder<CrdtNodeTable>? orderByList, Duration? throttle = const Duration(milliseconds: 30), Iterable<Table>? alsoTriggerOnTables}) → Stream<List<CrdtNode>>

Emits CrdtNodes matching the given query parameters every time the source tables are modified.