pub trait Queryable {
    type Error: From<<Self::ResultSet as Fetchable>::Error>;
    type ResultSet: Fetchable;

Show 15 methods // Required methods fn query<T: AsRef<str>>( &self, sql: T ) -> Result<Self::ResultSet, Self::Error>; fn query_with_req_id<T: AsRef<str>>( &self, sql: T, req_id: u64 ) -> Result<Self::ResultSet, Self::Error>; fn write_raw_meta(&self, _: &RawMeta) -> Result<(), Self::Error>; fn write_raw_block(&self, _: &RawBlock) -> Result<(), Self::Error>; fn put(&self, data: &SmlData) -> Result<(), Self::Error>; // Provided methods fn exec<T: AsRef<str>>(&self, sql: T) -> Result<usize, Self::Error> { ... } fn exec_many<T: AsRef<str>, I: IntoIterator<Item = T>>( &self, input: I ) -> Result<usize, Self::Error> { ... } fn query_one<T: AsRef<str>, O: DeserializeOwned>( &self, sql: T ) -> Result<Option<O>, Self::Error> { ... } fn server_version(&self) -> Result<Cow<'_, str>, Self::Error> { ... } fn create_topic( &self, name: impl AsRef<str>, sql: impl AsRef<str> ) -> Result<(), Self::Error> { ... } fn create_topic_as_database( &self, name: impl AsRef<str>, db: impl Display ) -> Result<(), Self::Error> { ... } fn databases(&self) -> Result<Vec<ShowDatabase>, Self::Error> { ... } fn topics(&self) -> Result<Vec<Topic>, Self::Error> { ... } fn describe(&self, table: &str) -> Result<Describe, Self::Error> { ... } fn database_exists(&self, name: &str) -> Result<bool, Self::Error> { ... }
}
Expand description

The synchronous query trait for TDengine connection.

Required Associated Types§

Required Methods§

source

fn query<T: AsRef<str>>(&self, sql: T) -> Result<Self::ResultSet, Self::Error>

source

fn query_with_req_id<T: AsRef<str>>( &self, sql: T, req_id: u64 ) -> Result<Self::ResultSet, Self::Error>

source

fn write_raw_meta(&self, _: &RawMeta) -> Result<(), Self::Error>

source

fn write_raw_block(&self, _: &RawBlock) -> Result<(), Self::Error>

source

fn put(&self, data: &SmlData) -> Result<(), Self::Error>

Provided Methods§

source

fn exec<T: AsRef<str>>(&self, sql: T) -> Result<usize, Self::Error>

source

fn exec_many<T: AsRef<str>, I: IntoIterator<Item = T>>( &self, input: I ) -> Result<usize, Self::Error>

source

fn query_one<T: AsRef<str>, O: DeserializeOwned>( &self, sql: T ) -> Result<Option<O>, Self::Error>

source

fn server_version(&self) -> Result<Cow<'_, str>, Self::Error>

Short for SELECT server_version() as String.

source

fn create_topic( &self, name: impl AsRef<str>, sql: impl AsRef<str> ) -> Result<(), Self::Error>

source

fn create_topic_as_database( &self, name: impl AsRef<str>, db: impl Display ) -> Result<(), Self::Error>

source

fn databases(&self) -> Result<Vec<ShowDatabase>, Self::Error>

source

fn topics(&self) -> Result<Vec<Topic>, Self::Error>

Topics information by SELECT * FROM information_schema.ins_topics sql.

Compatibility

This is a 3.x-only API.

source

fn describe(&self, table: &str) -> Result<Describe, Self::Error>

source

fn database_exists(&self, name: &str) -> Result<bool, Self::Error>

Check if database exists

Implementors§