Struct google_cloud_bigquery::client::Client

source ·

pub struct Client { /* private fields */ }

Implementations§

source §

impl Client

source

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

New client

source

pub fn dataset(&self) -> &BigqueryDatasetClient

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

source

pub fn table(&self) -> &BigqueryTableClient

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

source

pub fn tabledata(&self) -> &BigqueryTabledataClient

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

source

pub fn job(&self) -> &BigqueryJobClient

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

source

pub fn routine(&self) -> &BigqueryRoutineClient

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

source

pub fn row_access_policy(&self) -> &BigqueryRowAccessPolicyClient

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

source

pub fn model(&self) -> &BigqueryModelClient

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

source

pub async fn query<T>( &self, project_id: &str, request: QueryRequest ) -> Result<Iterator<T>, QueryError>
where T: StructDecodable + StructDecodable,

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::<Row>(project_id, request).await.unwrap();
    while let Some(row) = iter.next().await.unwrap() {
        let col1 = row.column::<String>(0);
        let col2 = row.column::<Option<String>>(1);
    }
}

source

pub async fn query_with_option<T>( &self, project_id: &str, request: QueryRequest, option: QueryOption ) -> Result<Iterator<T>, QueryError>
where T: StructDecodable + StructDecodable,

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).with_enable_storage_read(true);
    let mut iter = client.query_with_option::<Row>(project_id, request, option).await.unwrap();
    while let Some(row) = iter.next().await.unwrap() {
        let col1 = row.column::<String>(0);
        let col2 = row.column::<Option<String>>(1);
    }
}

source

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);
    }
}