Struct AdbcSnowflakeProperties 

pub struct AdbcSnowflakeProperties {

    pub account: String,
    pub username: String,
    pub password: Option<String>,
    pub database: String,
    pub schema: String,
    pub warehouse: String,
    pub table: String,
    pub role: Option<String>,
    pub host: Option<String>,
    pub port: Option<u16>,
    pub protocol: Option<String>,
    pub auth_type: Option<String>,
    pub auth_token: Option<String>,
    pub jwt_private_key_path: Option<String>,
    pub jwt_private_key_pkcs8_value: Option<String>,
    pub jwt_private_key_pkcs8_password: Option<String>,
    pub unknown_fields: HashMap<String, String>,
}

Properties for ADBC Snowflake source connector.

Fields

account: String

The Snowflake account identifier (e.g., “myaccount” or “myaccount.us-east-1”).

username: String

The username for authentication.

password: Option<String>

The password for authentication.

database: String

The name of the database to use.

schema: String

The name of the schema to use.

warehouse: String

The name of the warehouse to use.

table: String

The table name to load (full table).

role: Option<String>

The role to use (optional).

host: Option<String>

The host to connect to (optional, defaults to Snowflake cloud).

port: Option<u16>

The port to connect to (optional).

protocol: Option<String>

The protocol to use (optional, defaults to “https”).

auth_type: Option<String>

The authentication type (optional, defaults to “auth_snowflake”). Possible values: auth_snowflake, auth_oauth, auth_ext_browser, auth_okta, auth_jwt, auth_mfa, auth_pat, auth_wif

auth_token: Option<String>

OAuth token for authentication (when using auth_oauth).

jwt_private_key_path: Option<String>

JWT private key file path (when using auth_jwt).

jwt_private_key_pkcs8_value: Option<String>

jwt_private_key_pkcs8_password: Option<String>

unknown_fields: HashMap<String, String>

Unknown fields for forward compatibility.

Implementations

impl AdbcSnowflakeProperties

pub fn get_arrow_schema(&self) -> ConnectorResult<Schema>

Get the Arrow schema from the Snowflake table. This is used for schema inference when creating tables.

Important: We use a LIMIT 0 query instead of ADBC’s get_table_schema API because get_table_schema may return different types than the actual query results. For example, Snowflake NUMBER columns may be reported as Int64 by get_table_schema but returned as Decimal128 in actual query results. Using a real query ensures consistency between schema inference (used by frontend) and data fetching (used by executor).

The column order in the returned schema matches the column order in the Snowflake table.

impl AdbcSnowflakeProperties

pub fn table_ref(&self) -> String

Qualified table reference used in all generated queries.

pub fn build_select_all_query(&self) -> String

Default full-table select.

fn build_database_builder(&self) -> ConnectorResult<DatabaseBuilder>

Build a database builder from properties.

pub fn create_database(&self) -> ConnectorResult<Database>

Create an ADBC Snowflake database connection. This validates that the driver library is available before attempting connection.

pub fn create_connection( &self, database: &Database, ) -> ConnectorResult<Connection>

Create a connection from the database.

pub fn create_statement( &self, connection: &mut Connection, query: &str, ) -> ConnectorResult<Statement>

Create a statement from the connection and set the SQL query.

pub fn execute_query_with_connection( &self, connection: &mut Connection, query: &str, ) -> ConnectorResult<Vec<RecordBatch>>

Execute a custom query using a provided connection. This is useful for metadata queries needed for split generation while reusing connections.

pub fn execute_query(&self, query: &str) -> ConnectorResult<Vec<RecordBatch>>

Execute a custom query and return the results as a vector of Arrow record batches. This is useful for metadata queries needed for split generation. Creates a new connection for each query - use execute_query_with_connection for better performance.

Trait Implementations

impl Clone for AdbcSnowflakeProperties

fn clone(&self) -> AdbcSnowflakeProperties

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdbcSnowflakeProperties

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AdbcSnowflakeProperties

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EnforceSecret for AdbcSnowflakeProperties

const ENFORCE_SECRET_PROPERTIES: Set<&'static str>

fn enforce_secret<'a>(prop_iter: impl Iterator<Item = &'a str>) -> Result<()>

fn enforce_one(prop: &str) -> Result<()>

impl From<AdbcSnowflakeProperties> for ConnectorProperties

fn from(prop: AdbcSnowflakeProperties) -> ConnectorProperties

Converts to this type from the input type.

impl SourceProperties for AdbcSnowflakeProperties

const SOURCE_NAME: &'static str = ADBC_SNOWFLAKE_CONNECTOR

type Split = AdbcSnowflakeSplit

type SplitEnumerator = AdbcSnowflakeSplitEnumerator

type SplitReader = AdbcSnowflakeSplitReader

fn init_from_pb_source(&mut self, _source: &PbSource)

Load additional info from PbSource. Currently only used by CDC.

fn init_from_pb_cdc_table_desc(&mut self, _table_desc: &ExternalTableDesc)

Load additional info from ExternalTableDesc. Currently only used by CDC.

impl UnknownFields for AdbcSnowflakeProperties

fn unknown_fields(&self) -> HashMap<String, String>

Unrecognized fields in the WITH clause.

impl WithOptions for AdbcSnowflakeProperties