#![allow(unused_imports)]
use super::builders::*;
use super::client::TableServiceClient;
use unitycatalog_common::models::tables::v1::*;
#[derive(Clone)]
pub struct TableClient {
pub(crate) catalog_name: String,
pub(crate) schema_name: String,
pub(crate) table_name: String,
pub(crate) client: TableServiceClient,
}
impl TableClient {
pub fn new(
catalog_name: impl Into<String>,
schema_name: impl Into<String>,
table_name: impl Into<String>,
client: TableServiceClient,
) -> Self {
Self {
catalog_name: catalog_name.into(),
schema_name: schema_name.into(),
table_name: table_name.into(),
client,
}
}
pub fn from_full_name(full_name: impl Into<String>, client: TableServiceClient) -> Self {
let full_name = full_name.into();
let mut parts = full_name.splitn(3usize, '.');
let catalog_name = parts.next().unwrap_or_default();
let schema_name = parts.next().unwrap_or_default();
let table_name = parts.next().unwrap_or_default();
Self::new(catalog_name, schema_name, table_name, client)
}
pub fn catalog_name(&self) -> &str {
&self.catalog_name
}
pub fn schema_name(&self) -> &str {
&self.schema_name
}
pub fn name(&self) -> &str {
&self.table_name
}
pub fn full_name(&self) -> String {
format!(
"{}.{}.{}",
self.catalog_name, self.schema_name, self.table_name
)
}
pub fn get(&self) -> GetTableBuilder {
GetTableBuilder::new(
self.client.clone(),
format!(
"{}.{}.{}",
self.catalog_name, self.schema_name, self.table_name
),
)
}
pub fn get_table_exists(&self) -> GetTableExistsBuilder {
GetTableExistsBuilder::new(
self.client.clone(),
format!(
"{}.{}.{}",
self.catalog_name, self.schema_name, self.table_name
),
)
}
pub fn delete(&self) -> DeleteTableBuilder {
DeleteTableBuilder::new(
self.client.clone(),
format!(
"{}.{}.{}",
self.catalog_name, self.schema_name, self.table_name
),
)
}
}