Struct ImportQuery 

pub struct ImportQuery { /* private fields */ }

Builder for constructing Exasol IMPORT SQL statements.

The ImportQuery builder allows you to configure all aspects of an IMPORT statement including the target table, columns, CSV format options, and error handling.

Multi-file Import

For parallel imports, use with_files() instead of at_address() and file_name():

use exarrow_rs::query::import::{ImportQuery, ImportFileEntry};

let entries = vec![
    ImportFileEntry::new("10.0.0.5:8563".to_string(), "001.csv".to_string(), None),
    ImportFileEntry::new("10.0.0.6:8563".to_string(), "002.csv".to_string(), None),
];

let query = ImportQuery::new("my_table")
    .with_files(entries)
    .build();

Implementations

impl ImportQuery

pub fn new(table: &str) -> Self

Create a new ImportQuery builder for the specified table.

Arguments

• table - The name of the target table to import into

pub fn schema(self, schema: &str) -> Self

Set the target schema for the import.

Arguments

• schema - The schema name

pub fn columns(self, cols: Vec<&str>) -> Self

Set the columns to import into.

If not specified, all columns in the table will be used.

Arguments

• cols - List of column names

pub fn at_address(self, addr: &str) -> Self

Set the HTTP address to import from.

Arguments

• addr - HTTP address in “host:port” format

pub fn with_public_key(self, fingerprint: &str) -> Self

Set the public key fingerprint for TLS verification.

When set, HTTPS will be used and the PUBLIC KEY clause will be added.

Arguments

• fingerprint - SHA-256 fingerprint of the server’s public key

pub fn file_name(self, name: &str) -> Self

Set the file name for the import.

Arguments

• name - File name (default “001.csv”)

pub fn column_separator(self, sep: char) -> Self

Set the column separator character.

Arguments

• sep - Separator character (default ‘,’)

pub fn column_delimiter(self, delim: char) -> Self

Set the column delimiter character for quoting.

Arguments

• delim - Delimiter character (default ‘“’)

pub fn row_separator(self, sep: RowSeparator) -> Self

Set the row separator.

Arguments

• sep - Row separator (default LF)

pub fn encoding(self, enc: &str) -> Self

Set the character encoding.

Arguments

• enc - Encoding name (default “UTF-8”)

pub fn skip(self, rows: u32) -> Self

Set the number of header rows to skip.

Arguments

• rows - Number of rows to skip (default 0)

pub fn null_value(self, val: &str) -> Self

Set a custom NULL value representation.

Arguments

• val - String representing NULL values in the CSV

pub fn trim(self, trim: TrimMode) -> Self

Set the trim mode for imported values.

Arguments

• trim - Trim mode to apply

pub fn compressed(self, compression: Compression) -> Self

Set the compression type for the import file.

This affects the file extension in the generated SQL.

Arguments

• compression - Compression type

pub fn reject_limit(self, limit: u32) -> Self

Set the reject limit for error handling.

Arguments

• limit - Maximum number of invalid rows before the import fails

pub fn with_files(self, entries: Vec<ImportFileEntry>) -> Self

Set multiple file entries for parallel import.

This method enables multi-file IMPORT statements where each file has its own AT/FILE clause with a unique internal address.

Arguments

• entries - Vector of file entries with addresses and file names

Note

When using with_files(), the at_address() and file_name() methods are ignored and should not be called.

pub fn build(&self) -> String

Build the complete IMPORT SQL statement.

Returns

The generated IMPORT SQL statement as a string.

Trait Implementations

impl Clone for ImportQuery

fn clone(&self) -> ImportQuery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ImportQuery

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

Formats the value using the given formatter.