camel-component-sql 0.5.8

pub mod config;
pub mod consumer;
pub mod endpoint;
pub mod headers;
pub mod producer;
pub mod query;
pub(crate) mod utils;

use camel_component_api::CamelError;
use camel_component_api::UriConfig;
use camel_component_api::{Component, Endpoint};

pub use config::{SqlEndpointConfig, SqlGlobalConfig, SqlOutputType};

pub struct SqlComponent {
    config: Option<SqlGlobalConfig>,
}

impl SqlComponent {
    pub fn new() -> Self {
        Self { config: None }
    }

    pub fn with_config(config: SqlGlobalConfig) -> Self {
        Self {
            config: Some(config),
        }
    }

    pub fn with_optional_config(config: Option<SqlGlobalConfig>) -> Self {
        Self { config }
    }
}

impl Default for SqlComponent {
    fn default() -> Self {
        Self::new()
    }
}

impl Component for SqlComponent {
    fn scheme(&self) -> &str {
        "sql"
    }

    fn create_endpoint(&self, uri: &str) -> Result<Box<dyn Endpoint>, CamelError> {
        let mut config = SqlEndpointConfig::from_uri(uri)?;
        if let Some(ref global_config) = self.config {
            config.apply_defaults(global_config);
        }
        config.resolve_defaults();
        Ok(Box::new(endpoint::SqlEndpoint::new(
            uri.to_string(),
            config,
        )))
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use camel_component_api::Component;

    #[test]
    fn test_component_scheme() {
        let c = SqlComponent::new();
        assert_eq!(c.scheme(), "sql");
    }

    #[test]
    fn test_component_creates_endpoint() {
        let c = SqlComponent::new();
        let ep = c.create_endpoint("sql:select 1?db_url=postgres://localhost/test");
        assert!(ep.is_ok());
    }

    #[test]
    fn test_component_rejects_wrong_scheme() {
        let c = SqlComponent::new();
        let ep = c.create_endpoint("redis://localhost");
        assert!(ep.is_err());
    }

    #[test]
    fn test_endpoint_uri() {
        let c = SqlComponent::new();
        let ep = c
            .create_endpoint("sql:select 1?db_url=postgres://localhost/test")
            .unwrap();
        assert_eq!(ep.uri(), "sql:select 1?db_url=postgres://localhost/test");
    }

    #[test]
    fn test_component_with_global_config() {
        let global = SqlGlobalConfig::default().with_max_connections(20);
        let c = SqlComponent::with_config(global);
        // Verify the component can create endpoints with global config applied
        assert_eq!(c.scheme(), "sql");
        let ep = c.create_endpoint("sql:select 1?db_url=postgres://localhost/test");
        assert!(ep.is_ok());
    }

    #[test]
    fn test_global_config_applied_to_endpoint() {
        // Verify that when URI does NOT set pool params, global config fills them in.
        // Tests the same logic as create_endpoint: from_uri + apply_defaults + resolve_defaults.
        let global = SqlGlobalConfig::default()
            .with_max_connections(20)
            .with_min_connections(3)
            .with_idle_timeout_secs(600)
            .with_max_lifetime_secs(3600);
        let mut cfg =
            config::SqlEndpointConfig::from_uri("sql:select 1?db_url=postgres://localhost/test")
                .unwrap();
        cfg.apply_defaults(&global);
        cfg.resolve_defaults();
        assert_eq!(cfg.max_connections, Some(20));
        assert_eq!(cfg.min_connections, Some(3));
        assert_eq!(cfg.idle_timeout_secs, Some(600));
        assert_eq!(cfg.max_lifetime_secs, Some(3600));
    }

    #[test]
    fn test_uri_param_wins_over_global_config() {
        // Verify that URI-set pool params are NOT overridden by global config.
        let global = SqlGlobalConfig::default()
            .with_max_connections(20)
            .with_min_connections(3);
        let mut cfg = config::SqlEndpointConfig::from_uri(
            "sql:select 1?db_url=postgres://localhost/test&maxConnections=99&minConnections=7",
        )
        .unwrap();
        cfg.apply_defaults(&global);
        cfg.resolve_defaults();
        assert_eq!(cfg.max_connections, Some(99)); // URI wins
        assert_eq!(cfg.min_connections, Some(7)); // URI wins
    }
}