Trait taos_query::prelude::sync::Queryable
source · 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§
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>
sourcefn server_version(&self) -> Result<Cow<'_, str>, Self::Error>
fn server_version(&self) -> Result<Cow<'_, str>, Self::Error>
Short for SELECT server_version() as String.
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>
sourcefn topics(&self) -> Result<Vec<Topic>, Self::Error>
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.