MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / commit

Method commit

src/sql-server-util/src/lib.rs:494–501  ·  view source on GitHub ↗

Commit the [`Transaction`].

(mut self)

Source from the content-addressed store, hash-verified

492
493 /// Commit the [`Transaction`].
494 pub async fn commit(mut self) -> Result<(), SqlServerError> {
495 static COMMIT_QUERY: &str = "COMMIT TRANSACTION";
496 // N.B. Mark closed _before_ running the query. This prevents us from
497 // double closing the transaction if this query itself fails.
498 self.closed = true;
499 self.client.simple_query(COMMIT_QUERY).await?;
500 Ok(())
501 }
502}
503
504impl Drop for Transaction<'_> {

Callers 15

get_all_timelinesMethod · 0.45
try_commit_batchFunction · 0.45
process_frontierMethod · 0.45
allocate_system_idMethod · 0.45
initialize_stateMethod · 0.45
initialize_controllerMethod · 0.45
transactMethod · 0.45
webhook_concurrent_swapFunction · 0.45
load_file_hashesMethod · 0.45
load_file_contentsMethod · 0.45
upsert_object_rowsMethod · 0.45

Calls 1

simple_queryMethod · 0.45

Tested by 1

webhook_concurrent_swapFunction · 0.36