gcp_bigquery_client::dataset

Struct DatasetApi

Source
pub struct DatasetApi { /* private fields */ }
Expand description

A dataset API handler.

Implementations§

Source§

impl DatasetApi

Source

pub async fn create(&self, dataset: Dataset) -> Result<Dataset, BQError>

Creates a new empty dataset.

§Argument
  • dataset - The dataset to create
§Example

let (ref project_id, ref dataset_id, ref _table_id, ref sa_key) = env_vars();
let dataset_id = &format!("{}_dataset", dataset_id);

let client = Client::from_service_account_key_file(sa_key).await?;

client.dataset().create(Dataset::new(project_id, dataset_id)).await?;
Source

pub async fn list( &self, project_id: &str, options: ListOptions, ) -> Result<Datasets, BQError>

Lists all datasets in the specified project to which the user has been granted the READER dataset role.

§Arguments
  • project_id - Project ID of the datasets to be listed
  • options - Options
§Example

let (ref project_id, ref dataset_id, ref _table_id, ref sa_key) = env_vars();
let dataset_id = &format!("{}_dataset", dataset_id);

let client = Client::from_service_account_key_file(sa_key).await?;

let datasets = client.dataset().list(project_id, ListOptions::default().all(true)).await?;
for dataset in datasets.datasets.iter() {
    // Do some stuff
}
Source

pub async fn delete( &self, project_id: &str, dataset_id: &str, delete_contents: bool, ) -> Result<(), BQError>

Deletes the dataset specified by the datasetId value. Before you can delete a dataset, you must delete all its tables, either manually or by specifying deleteContents. Immediately after deletion, you can create another dataset with the same name.

§Arguments
  • project_id - Project ID of the dataset being deleted
  • dataset_id - Dataset ID of dataset being deleted
  • delete_contents - If True, delete all the tables in the dataset. If False and the dataset contains tables, the request will fail. Default is False
§Example

let (ref project_id, ref dataset_id, ref _table_id, ref sa_key) = env_vars();
let dataset_id = &format!("{}_dataset", dataset_id);

let client = Client::from_service_account_key_file(sa_key).await?;

client.dataset().create(Dataset::new(project_id, dataset_id)).await?;
client.dataset().delete(project_id, dataset_id, true).await?;
Source

pub async fn delete_if_exists( &self, project_id: &str, dataset_id: &str, delete_contents: bool, ) -> bool

Deletes the dataset specified by the datasetId value and returns true or returs false when the dataset doesn’t exist. Before you can delete a dataset, you must delete all its tables, either manually or by specifying deleteContents. Immediately after deletion, you can create another dataset with the same name.

§Arguments
  • project_id - Project ID of the dataset being deleted
  • dataset_id - Dataset ID of dataset being deleted
  • delete_contents - If True, delete all the tables in the dataset. If False and the dataset contains tables, the request will fail. Default is False
§Example

let (ref project_id, ref dataset_id, ref _table_id, ref sa_key) = env_vars();
let dataset_id = &format!("{}_dataset", dataset_id);

let client = Client::from_service_account_key_file(sa_key).await?;

client.dataset().delete_if_exists(project_id, dataset_id, true);
Source

pub async fn get( &self, project_id: &str, dataset_id: &str, ) -> Result<Dataset, BQError>

Returns the dataset specified by datasetID.

§Arguments
  • project_id - Project ID of the requested dataset
  • dataset_id - Dataset ID of the requested dataset
§Example

let (ref project_id, ref dataset_id, ref _table_id, ref sa_key) = env_vars();
let dataset_id = &format!("{}_dataset", dataset_id);

let client = Client::from_service_account_key_file(sa_key).await?;

client.dataset().create(Dataset::new(project_id, dataset_id)).await?;
let dataset = client.dataset().get(project_id, dataset_id).await?;
Source

pub async fn patch( &self, project_id: &str, dataset_id: &str, dataset: Dataset, ) -> Result<Dataset, BQError>

Updates information in an existing dataset. The update method replaces the entire dataset resource, whereas the patch method only replaces fields that are provided in the submitted dataset resource. This method supports patch semantics.

§Arguments
  • dataset - The request body contains an instance of Dataset.
Source

pub async fn update( &self, project_id: &str, dataset_id: &str, dataset: Dataset, ) -> Result<Dataset, BQError>

Updates information in an existing dataset. The update method replaces the entire dataset resource, whereas the patch method only replaces fields that are provided in the submitted dataset resource.

§Arguments
  • dataset - The request body contains an instance of Dataset.
Source

pub async fn information_schema_schemata( &self, project_id: &str, region: &str, ) -> Result<Vec<Schemata>, BQError>

Trait Implementations§

Source§

impl Clone for DatasetApi

Source§

fn clone(&self) -> DatasetApi

Returns a copy of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T