Struct Database

pub struct Database {
    catalog: String,
    schema: String,
    dbname: String,
    timezone: String,
    client: Client,
    ctx: FlightContext,
}

Fields

catalog: String

schema: String

dbname: String

timezone: String

client: Client

ctx: FlightContext

Implementations

impl Database

pub fn new( catalog: impl Into<String>, schema: impl Into<String>, client: Client, ) -> Self

Create database service client using catalog and schema

pub fn new_with_dbname(dbname: impl Into<String>, client: Client) -> Self

Create database service client using dbname.

This API is designed for external usage. dbname is:

• the name of database when using GreptimeDB standalone or cluster
• the name provided by GreptimeCloud or other multi-tenant GreptimeDB environment

pub fn set_catalog(&mut self, catalog: impl Into<String>)

pub fn catalog(&self) -> &String

pub fn set_schema(&mut self, schema: impl Into<String>)

pub fn schema(&self) -> &String

pub fn set_timezone(&mut self, timezone: impl Into<String>)

pub fn set_auth(&mut self, auth: AuthScheme)

pub async fn insert(&self, requests: InsertRequests) -> Result<u32>

pub async fn insert_with_hints( &self, requests: InsertRequests, hints: &[(&str, &str)], ) -> Result<u32>

async fn handle(&self, request: Request) -> Result<u32>

fn to_rpc_request(&self, request: Request) -> GreptimeRequest

pub async fn sql<S>(&self, sql: S) -> Result<Output>

where S: AsRef<str>,

pub async fn logical_plan(&self, logical_plan: Vec<u8>) -> Result<Output>

pub async fn create(&self, expr: CreateTableExpr) -> Result<Output>

pub async fn alter(&self, expr: AlterTableExpr) -> Result<Output>

async fn do_get(&self, request: Request) -> Result<Output>

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Database

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Database

fn default() -> Database

Returns the “default value” for a type.