Struct MockQueryRepository

pub struct MockQueryRepository { /* private fields */ }

Mock implementation of QueryRepository for testing

Implementations

impl MockQueryRepository

pub fn new() -> Self

Create a new mock query repository

pub fn set_should_fail(&mut self, should_fail: bool)

Set whether operations should fail

pub async fn add_query(&self, query: Query)

Add a mock query

pub async fn set_execution_result(&self, result: QueryResult)

Set mock execution result

Trait Implementations

impl Default for MockQueryRepository

fn default() -> Self

Returns the “default value” for a type.

impl QueryRepository for MockQueryRepository

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