Method execute_transaction

src/query/extended.rs:5669–5695

(
        framed: &mut Framed<T, crate::protocol::PostgresCodec>,
        db: &Arc<DbHandler>,
        session: &Arc<SessionState>,
        query: &str,
    )

    }
    
    async fn execute_transaction<T>(
        framed: &mut Framed<T, crate::protocol::PostgresCodec>,
        db: &Arc<DbHandler>,
        session: &Arc<SessionState>,
        query: &str,
    ) -> Result<(), PgSqliteError>
    where
        T: tokio::io::AsyncRead + tokio::io::AsyncWrite + Unpin,
    {
        if query_starts_with_ignore_case(query, "BEGIN")
            || query_starts_with_ignore_case(query, "START") {
            db.begin_with_session(&session.id).await?;
            framed.send(BackendMessage::CommandComplete { tag: "BEGIN".to_string() }).await
                .map_err(PgSqliteError::Io)?;
        } else if query_starts_with_ignore_case(query, "COMMIT")
            || query_starts_with_ignore_case(query, "END") {
            db.commit_with_session(&session.id).await?;
            framed.send(BackendMessage::CommandComplete { tag: "COMMIT".to_string() }).await
                .map_err(PgSqliteError::Io)?;
        } else if query_starts_with_ignore_case(query, "ROLLBACK") {
            db.rollback_with_session(&session.id).await?;
            framed.send(BackendMessage::CommandComplete { tag: "ROLLBACK".to_string() }).await
                .map_err(PgSqliteError::Io)?;
        }
        
        Ok(())
    }
    
    async fn execute_generic<T>(
        framed: &mut Framed<T, crate::protocol::PostgresCodec>,