Struct google_cloud_bigquery::client::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub async fn new(config: ClientConfig) -> Result<Self, Error>

New client

pub fn dataset(&self) -> &BigqueryDatasetClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets BigqueryDatasetClient

pub fn table(&self) -> &BigqueryTableClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/tables BigqueryTableClient

pub fn tabledata(&self) -> &BigqueryTabledataClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/tabledata BigqueryTabledataClient

pub fn job(&self) -> &BigqueryJobClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs BigqueryJobClient

pub fn routine(&self) -> &BigqueryRoutineClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/routines BigqueryRoutineClient

pub fn row_access_policy(&self) -> &BigqueryRowAccessPolicyClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/rowAccessPolicy BigqueryRowAccessPolicyClient

pub fn model(&self) -> &BigqueryModelClient

https://cloud.google.com/bigquery/docs/reference/rest/v2/models BigqueryModelClient

pub async fn query( &self, project_id: &str, request: QueryRequest ) -> Result<Iterator, Error>

Run query job and get result.

use google_cloud_bigquery::http::job::query::QueryRequest;
use google_cloud_bigquery::query::row::Row;
use google_cloud_bigquery::client::Client;

async fn run(client: &Client, project_id: &str) {
    let request = QueryRequest {
        query: "SELECT * FROM dataset.table".to_string(),
        ..Default::default()
    };
    let mut iter = client.query(project_id, request).await.unwrap();
    while let Some(row) = iter.next::<Row>().await.unwrap() {
        let col1 = row.column::<String>(0);
        let col2 = row.column::<Option<String>>(1);
    }
}

pub async fn query_with_option( &self, project_id: &str, request: QueryRequest, option: QueryOption ) -> Result<Iterator, Error>

Run query job and get result.

use google_cloud_bigquery::http::job::query::QueryRequest;
use google_cloud_bigquery::query::row::Row;
use google_cloud_bigquery::client::Client;
use google_cloud_bigquery::query::QueryOption;
use google_cloud_bigquery::query::ExponentialBuilder;

async fn run(client: &Client, project_id: &str) {
    let request = QueryRequest {
        query: "SELECT * FROM dataset.table".to_string(),
        ..Default::default()
    };
    let retry = ExponentialBuilder::default().with_max_times(10);
    let option = QueryOption::default().with_retry(retry);
    let mut iter = client.query_with_option(project_id, request, option).await.unwrap();
    while let Some(row) = iter.next::<Row>().await.unwrap() {
        let col1 = row.column::<String>(0);
        let col2 = row.column::<Option<String>>(1);
    }
}

pub async fn read_table<T>( &self, table: &TableReference, option: Option<ReadTableOption> ) -> Result<Iterator<T>, Error>where T: StructDecodable,

Read table data by BigQuery Storage Read API.

use google_cloud_bigquery::storage::row::Row;
use google_cloud_bigquery::client::Client;
use google_cloud_bigquery::http::table::TableReference;

async fn run(client: &Client, project_id: &str) {
    let table = TableReference {
        project_id: project_id.to_string(),
        dataset_id: "dataset".to_string(),
        table_id: "table".to_string(),
    };
    let mut iter = client.read_table::<Row>(&table, None).await.unwrap();
    while let Some(row) = iter.next().await.unwrap() {
        let col1 = row.column::<String>(0);
        let col2 = row.column::<Option<String>>(1);
    }
}

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.