Struct SpannerConnection 

pub struct SpannerConnection { /* private fields */ }

An ADBC connection to a Spanner database.

Trait Implementations

impl Connection for SpannerConnection

fn get_table_types(&self) -> Result<Box<dyn RecordBatchReader + Send + 'static>>

Return the table types supported by Spanner as a single-column (table_type: utf8) batch, per the ADBC specification.

type StatementType = SpannerStatement

fn new_statement(&mut self) -> Result<Self::StatementType>

Allocate and initialize a new statement.

fn cancel(&mut self) -> Result<()>

Cancel the in-progress operation on a connection.

fn get_info( &self, _codes: Option<HashSet<InfoCode>>, ) -> Result<Box<dyn RecordBatchReader + Send + 'static>>

Get metadata about the database/driver.

fn get_objects( &self, _depth: ObjectDepth, _catalog: Option<&str>, _db_schema: Option<&str>, _table_name: Option<&str>, _table_type: Option<Vec<&str>>, _column_name: Option<&str>, ) -> Result<Box<dyn RecordBatchReader + Send + 'static>>

Get a hierarchical view of all catalogs, database schemas, tables, and columns.

fn get_table_schema( &self, _catalog: Option<&str>, _db_schema: Option<&str>, _table_name: &str, ) -> Result<Schema>

Get the Arrow schema of a table.

fn get_statistic_names( &self, ) -> Result<Box<dyn RecordBatchReader + Send + 'static>>

Get the names of statistics specific to this driver.

fn get_statistics( &self, _catalog: Option<&str>, _db_schema: Option<&str>, _table_name: Option<&str>, _approximate: bool, ) -> Result<Box<dyn RecordBatchReader + Send + 'static>>

Get statistics about the data distribution of table(s).

fn commit(&mut self) -> Result<()>

Commit any pending transactions. Only used if autocommit is disabled.

fn rollback(&mut self) -> Result<()>

Roll back any pending transactions. Only used if autocommit is disabled.

fn read_partition( &self, _partition: impl AsRef<[u8]>, ) -> Result<Box<dyn RecordBatchReader + Send + 'static>>

Retrieve a given partition of data.

impl Optionable for SpannerConnection

type Option = OptionConnection

fn set_option(&mut self, key: Self::Option, value: OptionValue) -> Result<()>

Set a post-init option.

fn get_option_string(&self, key: Self::Option) -> Result<String>

Get a string option value by key.

fn get_option_bytes(&self, key: Self::Option) -> Result<Vec<u8>>

Get a bytes option value by key.

fn get_option_int(&self, key: Self::Option) -> Result<i64>

Get an integer option value by key.

fn get_option_double(&self, key: Self::Option) -> Result<f64>

Get a float option value by key.