Struct HttpQueryRepository

pub struct HttpQueryRepository { /* private fields */ }

HTTP implementation of QueryRepository

Implementations

impl HttpQueryRepository

pub fn new(http_provider: Arc<dyn HttpProviderSafe>) -> Self

Create a new HTTP query repository

Trait Implementations

impl QueryRepository for HttpQueryRepository

fn execute_dataset_query<'life0, 'async_trait>( &'life0 self, query: DatasetQuery, ) -> Pin<Box<dyn Future<Output = RepositoryResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a dataset query

fn execute_raw_query<'life0, 'async_trait>( &'life0 self, query: Value, ) -> Pin<Box<dyn Future<Output = RepositoryResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a raw query (JSON format)

fn execute_pivot_query<'life0, 'async_trait>( &'life0 self, query: Value, ) -> Pin<Box<dyn Future<Output = RepositoryResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a pivot query

fn export_query<'life0, 'life1, 'async_trait>( &'life0 self, format: &'life1 str, _query: Value, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Export query results

fn execute_native<'life0, 'life1, 'async_trait>( &'life0 self, database_id: DatabaseId, sql: &'life1 str, parameters: Option<HashMap<String, Value>>, ) -> Pin<Box<dyn Future<Output = RepositoryResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a native SQL query

fn execute_native_query<'life0, 'async_trait>( &'life0 self, database_id: i32, query: NativeQuery, ) -> Pin<Box<dyn Future<Output = RepositoryResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a native query object

fn execute_mbql<'life0, 'life1, 'async_trait>( &'life0 self, database_id: DatabaseId, mbql: &'life1 Value, ) -> Pin<Box<dyn Future<Output = RepositoryResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute an MBQL query

fn save_query<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 Query, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Query>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a query

fn get_query<'life0, 'async_trait>( &'life0 self, id: i32, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Query>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a saved query

fn list_queries<'life0, 'async_trait>( &'life0 self, pagination: Option<PaginationParams>, filters: Option<QueryFilterParams>, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Vec<Query>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List saved queries

fn update_query<'life0, 'life1, 'async_trait>( &'life0 self, id: i32, query: &'life1 Query, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Query>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update a saved query

fn delete_query<'life0, 'async_trait>( &'life0 self, id: i32, ) -> Pin<Box<dyn Future<Output = RepositoryResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a saved query

fn get_metadata<'life0, 'async_trait>( &'life0 self, database_id: DatabaseId, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get query metadata (schema, tables, columns)

fn validate_query<'life0, 'life1, 'async_trait>( &'life0 self, database_id: DatabaseId, query_type: QueryType, query: &'life1 Value, ) -> Pin<Box<dyn Future<Output = RepositoryResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Validate a query without executing

fn get_execution_history<'life0, 'async_trait>( &'life0 self, query_id: Option<i32>, limit: Option<u32>, ) -> Pin<Box<dyn Future<Output = RepositoryResult<Vec<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get query execution history