Struct taos::Taos

pub struct Taos(/* private fields */);

Implementations

impl Taos

pub fn is_native(&self) -> bool

The connection uses native protocol.

pub fn is_ws(&self) -> bool

The connection uses websocket protocol.

Trait Implementations

impl AsyncBindable<Taos> for Stmt

fn init<'life0, 'async_trait>( taos: &'life0 Taos ) -> Pin<Box<dyn Future<Output = RawResult<Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn init_with_req_id<'life0, 'async_trait>( taos: &'life0 Taos, req_id: u64 ) -> Pin<Box<dyn Future<Output = RawResult<Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn prepare<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str ) -> Pin<Box<dyn Future<Output = RawResult<&mut Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn set_tbname<'life0, 'life1, 'async_trait>( &'life0 mut self, name: &'life1 str ) -> Pin<Box<dyn Future<Output = RawResult<&mut Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn set_tags<'life0, 'life1, 'async_trait>( &'life0 mut self, tags: &'life1 [Value] ) -> Pin<Box<dyn Future<Output = RawResult<&mut Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn bind<'life0, 'life1, 'async_trait>( &'life0 mut self, params: &'life1 [ColumnView] ) -> Pin<Box<dyn Future<Output = RawResult<&mut Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn add_batch<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = RawResult<&mut Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn execute<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = RawResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn affected_rows<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn set_tbname_tags<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, name: &'life1 str, tags: &'life2 [Value] ) -> Pin<Box<dyn Future<Output = Result<&'life0 mut Self, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: Send + 'async_trait,

fn result_set<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<<Q as AsyncQueryable>::AsyncResultSet, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

impl AsyncQueryable for Taos

type AsyncResultSet = ResultSet

fn query<'life0, 'async_trait, T>( &'life0 self, sql: T ) -> Pin<Box<dyn Future<Output = RawResult<Self::AsyncResultSet>> + Send + 'async_trait>>

where T: 'async_trait + AsRef<str> + Send + Sync, Self: 'async_trait, 'life0: 'async_trait,

fn query_with_req_id<'life0, 'async_trait, T>( &'life0 self, sql: T, req_id: u64 ) -> Pin<Box<dyn Future<Output = RawResult<Self::AsyncResultSet>> + Send + 'async_trait>>

where T: 'async_trait + AsRef<str> + Send + Sync, Self: 'async_trait, 'life0: 'async_trait,

fn write_raw_meta<'life0, 'life1, 'async_trait>( &'life0 self, meta: &'life1 RawMeta ) -> Pin<Box<dyn Future<Output = RawResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn write_raw_block<'life0, 'life1, 'async_trait>( &'life0 self, block: &'life1 RawBlock ) -> Pin<Box<dyn Future<Output = RawResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn write_raw_block_with_req_id<'life0, 'life1, 'async_trait>( &'life0 self, block: &'life1 RawBlock, req_id: u64 ) -> Pin<Box<dyn Future<Output = RawResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn put<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 SmlData ) -> Pin<Box<dyn Future<Output = RawResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn exec<'life0, 'async_trait, T>( &'life0 self, sql: T ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: 'async_trait + AsRef<str> + Send + Sync, Self: 'async_trait,

fn exec_with_req_id<'life0, 'async_trait, T>( &'life0 self, sql: T, req_id: u64 ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: 'async_trait + AsRef<str> + Send + Sync, Self: 'async_trait,

fn exec_many<'life0, 'async_trait, T, I>( &'life0 self, input: I ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: AsRef<str> + Send + Sync + 'async_trait, <I as IntoIterator>::IntoIter: Send, I: IntoIterator<Item = T> + Send + 'async_trait, Self: 'async_trait,

fn query_one<'life0, 'async_trait, T, O>( &'life0 self, sql: T ) -> Pin<Box<dyn Future<Output = Result<Option<O>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: 'async_trait + AsRef<str> + Send + Sync, O: 'async_trait + DeserializeOwned + Send, Self: 'async_trait,

To conveniently get first row of the result, useful for queries like

fn server_version<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Cow<'life0, str>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Short for SELECT server_version() as String.

fn create_database<'life0, 'async_trait, N>( &'life0 self, name: N ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, N: 'async_trait + AsRef<str> + Send, Self: 'async_trait,

Short for CREATE DATABASE IF NOT EXISTS {name}.

fn use_database<'life0, 'async_trait, N>( &'life0 self, name: N ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, N: 'async_trait + AsRef<str> + Send, Self: 'async_trait,

Short for USE {name}.

fn create_topic<'life0, 'async_trait, N, S>( &'life0 self, name: N, sql: S ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, N: 'async_trait + AsRef<str> + Send + Sync, S: 'async_trait + AsRef<str> + Send, Self: 'async_trait,

Short for CREATE TOPIC IF NOT EXISTS {name} AS {sql}.

fn create_topic_as_database<'life0, 'async_trait>( &'life0 self, name: impl AsRef<str> + Send + Sync + 'async_trait, db: impl Display + Send + 'async_trait ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Short for CREATE TOPIC IF NOT EXISTS {name} WITH META AS DATABASE {db}.

fn databases<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Vec<ShowDatabase>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Short for SHOW DATABASES.

fn topics<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Vec<Topic>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Topics information by SELECT * FROM information_schema.ins_topics sql.

fn describe<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<Describe, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Get table meta information.

fn database_exists<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Check if database exists

fn exec_sync<T>(&self, sql: T) -> Result<usize, Error>

where T: AsRef<str> + Send + Sync,

Sync version of exec.

fn query_sync<T>(&self, sql: T) -> Result<Self::AsyncResultSet, Error>

where T: AsRef<str> + Send + Sync,

Sync version of query.

impl Bindable<Taos> for Stmt

fn init(taos: &Taos) -> RawResult<Self>

fn init_with_req_id(taos: &Taos, req_id: u64) -> RawResult<Self>

fn prepare<S: AsRef<str>>(&mut self, sql: S) -> RawResult<&mut Self>

fn set_tbname<S: AsRef<str>>(&mut self, name: S) -> RawResult<&mut Self>

fn set_tags(&mut self, tags: &[Value]) -> RawResult<&mut Self>

fn bind(&mut self, params: &[ColumnView]) -> RawResult<&mut Self>

fn add_batch(&mut self) -> RawResult<&mut Self>

fn execute(&mut self) -> RawResult<usize>

fn affected_rows(&self) -> usize

fn set_tbname_tags<S>( &mut self, name: S, tags: &[Value] ) -> Result<&mut Self, Error>

where S: AsRef<str>,

fn result_set(&mut self) -> Result<<Q as Queryable>::ResultSet, Error>

impl Debug for Taos

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

Formats the value using the given formatter.

impl Queryable for Taos

type ResultSet = ResultSet

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

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

fn write_raw_meta(&self, meta: &RawMeta) -> RawResult<()>

fn write_raw_block(&self, block: &RawBlock) -> RawResult<()>

fn write_raw_block_with_req_id( &self, block: &RawBlock, req_id: u64 ) -> RawResult<()>

fn put(&self, data: &SmlData) -> RawResult<()>

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

where T: AsRef<str>,

fn exec_many<T, I>(&self, input: I) -> Result<usize, Error>

where T: AsRef<str>, I: IntoIterator<Item = T>,

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

where T: AsRef<str>, O: DeserializeOwned,

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

Short for SELECT server_version() as String.

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

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

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

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

Topics information by SELECT * FROM information_schema.ins_topics sql.

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

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

Check if database exists