Struct SnowflakeSession 

pub struct SnowflakeSession { /* private fields */ }

A live, authenticated Snowflake session.

Holds the session and master tokens behind a mutex so a query (reading the session token) and a heartbeat/renew can interleave. query runs SQL; renew swaps in a fresh session token via the master token; heartbeat keeps the master token alive so renewal can continue indefinitely.

Implementations

impl SnowflakeSession

pub fn abort_handle(&self) -> AbortHandle

A cloneable AbortHandle for this session’s in-flight statement.

The returned handle shares the session’s in-flight slot, so it can cancel whatever statement is running even after the session is checked out of a pool (moved out of the pool’s slot).

pub fn session_expiring_within(&self, within: TimeDelta) -> bool

Whether the session token expires within within from now.

pub fn master_expires_at(&self) -> DateTime<Utc>

When the master token currently expires (renewal must happen before this, kept alive by heartbeat).

pub async fn query(&self, sql: &str) -> Result<Vec<Row>>

Runs SQL and returns the result rows.

Errors

Error::SessionExpired when the session token is no longer valid (renew or re-authenticate), or a transport/server/protocol error.

pub async fn query_multi(&self, sql: &str) -> Result<Vec<Vec<Row>>>

Runs SQL that may contain multiple ;-separated statements, returning one row set per statement (in submission order).

A single-statement submission takes the same path as query and yields a one-element vector. When the SQL parses to more than one statement it is submitted with MULTI_STATEMENT_COUNT = 0 (“any count”): the server then returns a comma-separated list of child resultIds in place of inline rows, and each child result is fetched from the /queries/{id}/result endpoint.

Errors

As query.

pub async fn renew(&self) -> Result<()>

Renews the session token using the master token, extending the session.

Errors

Error::SessionExpired when the master token has itself expired (a full re-authentication is then required), or a transport/server error.

pub async fn heartbeat(&self) -> Result<()>

Sends a keep-alive heartbeat, extending the master token server-side.

Errors

A transport/server error, or Error::SessionExpired if the session token used to authorize the heartbeat has already lapsed.

pub async fn close(&self) -> Result<()>

Logs the session out (best-effort).

Errors

A transport/server error.