Struct SQLiteQueryBuilder 

pub struct SQLiteQueryBuilder {
    pub db_path: PathBuf,
    pub table_name: String,
    pub sql_select: Option<String>,
    pub sql_where: Option<String>,
    pub sql_params: Vec<String>,
    pub sql_order_by: Option<String>,
    pub sql_limit: Option<i64>,
    pub column_adapters: BTreeMap<String, SQLiteColumnAdapter>,
    /* private fields */
}

A lazy query builder for SQLite tables, allowing SQL pushdown optimizations for commands like length, select, first, and last.

Fields

db_path: PathBuf

table_name: String

sql_select: Option<String>

sql_where: Option<String>

sql_params: Vec<String>

sql_order_by: Option<String>

sql_limit: Option<i64>

column_adapters: BTreeMap<String, SQLiteColumnAdapter>

Implementations

impl SQLiteQueryBuilder

pub fn new(db_path: PathBuf, table_name: String, signals: Signals) -> Self

pub fn with_select(self, select: String) -> Self

pub fn with_where(self, where_clause: String, params: Vec<String>) -> Self

pub fn with_order_by(self, order_by: String) -> Self

pub fn with_limit(self, limit: i64) -> Self

pub fn with_column_adapter( self, column_name: String, adapter: SQLiteColumnAdapter, ) -> Self

pub fn with_unix_millis_datetime_column(self, column_name: String) -> Self

Register a datetime adapter for a column containing Unix epoch milliseconds.

pub fn with_millis_duration_column(self, column_name: String) -> Self

Register a duration adapter for a column containing milliseconds.

pub fn project_output_columns(&self, columns: &[String]) -> Option<Self>

Projects a subset of output columns from the current SELECT list.

This is used by filter pushdowns (for example, history | select command) where Nushell refers to post-alias output names, but the underlying SQLite table may have different source column names.

Example:

• current projection: command_line as command, duration_ms as duration
• requested output: command
• rewritten projection: command_line as command

If a requested output name cannot be mapped unambiguously to the existing projection, this returns None so callers can safely fall back to non-pushdown behavior.

This method intentionally does not parse full SQL grammar; it relies on a small, conservative parser that is sufficient for projections we generate internally.

pub fn build_sql(&self) -> String

pub fn execute(&self, call_span: Span) -> Result<PipelineData, ShellError>

pub fn count(&self, call_span: Span) -> Result<i64, ShellError>

Trait Implementations

impl Clone for SQLiteQueryBuilder

fn clone(&self) -> SQLiteQueryBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CustomValue for SQLiteQueryBuilder

fn clone_value(&self, span: Span) -> Value

Custom Clone implementation

fn type_name(&self) -> String

The friendly type name to show for the custom value, e.g. in describe and in error messages. This does not have to be the same as the name of the struct or enum, but conventionally often is.

fn to_base_value(&self, span: Span) -> Result<Value, ShellError>

Converts the custom value to a base nushell value.

fn as_any(&self) -> &dyn Any

Any representation used to downcast object to its original type

fn as_mut_any(&mut self) -> &mut dyn Any

Any representation used to downcast object to its original type (mutable reference)

fn follow_path_int( &self, _self_span: Span, index: usize, path_span: Span, optional: bool, ) -> Result<Value, ShellError>

Follow cell path by numeric index (e.g. rows).

fn follow_path_string( &self, _self_span: Span, column_name: String, path_span: Span, _optional: bool, _: Casing, ) -> Result<Value, ShellError>

Follow cell path by string key (e.g. columns).

fn is_iterable(&self) -> bool

👎Deprecated since 0.111.1:

will be replaced by a new custom-value iterator system next release; avoid new uses unless you need current behavior

Returns true if this custom value should be iterable (like a list) when used with commands like each, where, etc.

fn partial_cmp(&self, _other: &Value) -> Option<Ordering>

ordering with other value (see std::cmp::PartialOrd)

fn operation( &self, lhs_span: Span, operator: Operator, op: Span, right: &Value, ) -> Result<Value, ShellError>

Definition of an operation between the object that implements the trait and another Value.

fn save( &self, path: Spanned<&Path>, value_span: Span, save_span: Span, ) -> Result<(), ShellError>

Save custom value to disk.

fn notify_plugin_on_drop(&self) -> bool

For custom values in plugins: return true here if you would like to be notified when all copies of this custom value are dropped in the engine.

fn memory_size(&self) -> usize

Returns an estimate of the memory size used by this CustomValue in bytes

impl Debug for SQLiteQueryBuilder

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SQLiteQueryBuilder

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SQLiteQueryBuilder

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.