Transaction control methods
(&self, session_id: &Uuid)
| 2144 | |
| 2145 | /// Transaction control methods |
| 2146 | pub async fn begin_with_session(&self, session_id: &Uuid) -> Result<(), PgSqliteError> { |
| 2147 | self.connection_manager.execute_with_session(session_id, |conn| { |
| 2148 | conn.execute("BEGIN", [])?; |
| 2149 | Ok(()) |
| 2150 | }) |
| 2151 | } |
| 2152 | |
| 2153 | pub async fn commit(&self, session_id: &Uuid) -> Result<(), PgSqliteError> { |
| 2154 | // Execute the commit on the current session |