MCPcopy Create free account
hub / github.com/erans/pgsqlite / commit

Method commit

src/session/db_handler.rs:2153–2165  ·  view source on GitHub ↗
(&self, session_id: &Uuid)

Source from the content-addressed store, hash-verified

2151 }
2152
2153 pub async fn commit(&self, session_id: &Uuid) -> Result<(), PgSqliteError> {
2154 // Execute the commit on the current session
2155 self.connection_manager.execute_with_session(session_id, |conn| {
2156 conn.execute("COMMIT", [])?;
2157 Ok(())
2158 })?;
2159
2160 // Force all other connections to refresh their WAL view (WAL mode only)
2161 // This ensures committed data is visible to all other sessions
2162 self.connection_manager.refresh_all_other_connections(session_id)?;
2163
2164 Ok(())
2165 }
2166
2167 pub async fn commit_with_session(&self, session_id: &Uuid) -> Result<(), PgSqliteError> {
2168 self.commit(session_id).await

Callers 15

test_sqlite.pyFile · 0.80
commit_with_sessionMethod · 0.80
store_type_mappingsMethod · 0.80
create_enum_typeMethod · 0.80
add_enum_valueMethod · 0.80
drop_enum_typeMethod · 0.80
test_drift_type_mismatchFunction · 0.80

Calls 3

execute_with_sessionMethod · 0.45
executeMethod · 0.45