Struct SqlEndpointConfig 

pub struct SqlEndpointConfig {

    pub db_url: String,
    pub max_connections: Option<u32>,
    pub min_connections: Option<u32>,
    pub idle_timeout_secs: Option<u64>,
    pub max_lifetime_secs: Option<u64>,
    pub query: String,
    pub source_path: Option<String>,
    pub output_type: SqlOutputType,
    pub placeholder: char,
    pub noop: bool,
    pub delay_ms: u64,
    pub initial_delay_ms: u64,
    pub max_messages_per_poll: Option<i32>,
    pub on_consume: Option<String>,
    pub on_consume_failed: Option<String>,
    pub on_consume_batch_complete: Option<String>,
    pub route_empty_result_set: bool,
    pub use_iterator: bool,
    pub expected_update_count: Option<i64>,
    pub break_batch_on_consume_fail: bool,
    pub batch: bool,
    pub use_message_body_for_sql: bool,
}

Configuration for SQL component endpoints.

URI format: sql:<query>?db_url=<url>&param1=val1&param2=val2

The query can be inline SQL or a file reference with file: prefix:

• sql:SELECT * FROM users?db_url=... - inline SQL
• sql:file:/path/to/query.sql?db_url=... - read SQL from file

Fields

db_url: String

Database connection URL (required).

max_connections: Option<u32>

Maximum connections in the pool. None = use global default.

min_connections: Option<u32>

Minimum connections in the pool. None = use global default.

idle_timeout_secs: Option<u64>

Idle timeout in seconds. None = use global default.

max_lifetime_secs: Option<u64>

Maximum connection lifetime in seconds. None = use global default.

query: String

The SQL query (from URI path or file).

source_path: Option<String>

Path to the file containing the SQL query (when using file: prefix).

output_type: SqlOutputType

Output type for query results. Default: SelectList.

placeholder: char

Placeholder character for parameters. Default: ‘#’.

noop: bool

If true, don’t execute the query (dry run). Default: false.

delay_ms: u64

Delay between polls in milliseconds. Default: 500.

initial_delay_ms: u64

Initial delay before first poll in milliseconds. Default: 1000.

max_messages_per_poll: Option<i32>

Maximum messages per poll.

on_consume: Option<String>

SQL to execute after consuming each message.

on_consume_failed: Option<String>

SQL to execute if consumption fails.

on_consume_batch_complete: Option<String>

SQL to execute after consuming a batch.

route_empty_result_set: bool

Route empty result sets. Default: false.

use_iterator: bool

Use iterator for results. Default: true.

expected_update_count: Option<i64>

Expected number of rows affected.

break_batch_on_consume_fail: bool

Break batch on consume failure. Default: false.

batch: bool

Enable batch mode. Default: false.

use_message_body_for_sql: bool

Use message body for SQL. Default: false.

Implementations

impl SqlEndpointConfig

pub fn apply_defaults(&mut self, defaults: &SqlGlobalConfig)

Apply defaults from global config, filling None fields without overriding.

pub fn resolve_defaults(&mut self)

Resolve any remaining None fields with built-in defaults.

Trait Implementations

impl Clone for SqlEndpointConfig

fn clone(&self) -> SqlEndpointConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqlEndpointConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl UriConfig for SqlEndpointConfig

fn scheme() -> &'static str

Returns the URI scheme this config handles (e.g., “timer”, “http”).

fn from_uri(uri: &str) -> Result<Self, CamelError>

Parse a URI string into this configuration.

fn from_components(parts: UriComponents) -> Result<Self, CamelError>

Parse already-extracted URI components into this configuration.

fn validate(self) -> Result<Self, CamelError>

Override to add validation logic after parsing.