Method execute

src/query/query_handler.rs:47–59

(&self, sql: &str)

    }
    
    async fn execute(&self, sql: &str) -> Result<DbResponse, PgSqliteError> {
        match self {
            QueryHandlerImpl::Direct(db) => {
                db.execute(sql).await
            },
            QueryHandlerImpl::Routed(router) => {
                // For routed queries, we need the session state to determine transaction status
                let session = SessionState::new("temp".to_string(), "temp".to_string());
                router.execute_query(sql, &session).await
                    .map_err(|e| PgSqliteError::Protocol(e.to_string()))
            }
        }
    }
    
    async fn get_schema_type(&self, table: &str, column: &str) -> Result<Option<String>, PgSqliteError> {
        match self {