diff --git a/crates/s3select-query/src/instance.rs b/crates/s3select-query/src/instance.rs index 2523e9f6..3ecac61c 100644 --- a/crates/s3select-query/src/instance.rs +++ b/crates/s3select-query/src/instance.rs @@ -108,7 +108,7 @@ pub async fn make_rustfsms(input: Arc, is_test: bool) } pub async fn make_rustfsms_with_components( - input: Arc, + input: Arc, is_test: bool, func_manager: Arc, parser: Arc, diff --git a/crates/s3select-query/src/lib.rs b/crates/s3select-query/src/lib.rs index 9f1686da..4fab1772 100644 --- a/crates/s3select-query/src/lib.rs +++ b/crates/s3select-query/src/lib.rs @@ -20,9 +20,9 @@ pub mod instance; pub mod metadata; pub mod sql; -use std::sync::{Arc, LazyLock}; use rustfs_s3select_api::{QueryResult, server::dbms::DatabaseManagerSystem}; use s3s::dto::SelectObjectContentInput; +use std::sync::{Arc, LazyLock}; use crate::{ execution::{factory::SqlQueryExecutionFactory, scheduler::local::LocalScheduler}, @@ -46,7 +46,7 @@ static GLOBAL_COMPONENTS: LazyLock = LazyLock::new(|| { let scheduler = Arc::new(LocalScheduler {}); let query_execution_factory = Arc::new(SqlQueryExecutionFactory::new(optimizer, scheduler)); let default_table_provider = Arc::new(BaseTableProvider::default()); - + GlobalComponents { func_manager, parser, @@ -68,8 +68,9 @@ pub async fn get_global_db( components.parser.clone(), components.query_execution_factory.clone(), components.default_table_provider.clone(), - ).await?; - + ) + .await?; + Ok(Arc::new(db) as Arc) }