style(*): format code

Author: qevolg

taos-query/src/common/raw/mod.rs

@@ -11,33 +11,29 @@ use std::ptr::NonNull;
 use std::rc::Rc;
 
 use bytes::Bytes;
+pub use data::*;
+use derive_builder::Builder;
 use itertools::Itertools;
+use layout::Layout;
+pub use meta::*;
 use rayon::prelude::*;
+pub use rows::*;
 use serde::Deserialize;
 use taos_error::Error;
+pub use views::ColumnView;
+use views::*;
 
 use crate::common::{BorrowedValue, Field, Precision, Ty, Value};
 
 pub mod layout;
 pub mod meta;
-
-mod data;
-
-use layout::Layout;
-
 #[allow(clippy::missing_safety_doc)]
 #[allow(clippy::should_implement_trait)]
 pub mod views;
 
-pub use data::*;
-pub use meta::*;
-pub use views::ColumnView;
-use views::*;
-
+mod data;
 mod de;
 mod rows;
-use derive_builder::Builder;
-pub use rows::*;
 
 #[derive(Debug, Clone, Copy)]
 #[repr(C, packed(1))]
@@ -79,6 +75,7 @@ impl Header {
     fn nrows(&self) -> usize {
         self.nrows as _
     }
+
     fn ncols(&self) -> usize {
         self.ncols as _
     }

taos-ws-sys/src/ws/mod.rs

@@ -152,7 +152,6 @@ impl<T> Drop for WsMaybeError<T> {
     fn drop(&mut self) {
         if !self.data.is_null() {
             tracing::trace!("dropping obj {}", self.type_id);
-            // let _ = unsafe { self.data.read() };
             let _ = unsafe { Box::from_raw(self.data) };
         }
     }
@@ -348,6 +347,7 @@ impl WS_FIELD_V2 {
     pub fn name(&self) -> &CStr {
         unsafe { CStr::from_ptr(self.name.as_ptr() as _) }
     }
+
     pub fn r#type(&self) -> Ty {
         self.r#type.into()
     }
@@ -386,6 +386,7 @@ impl WS_FIELD {
     pub fn name(&self) -> &CStr {
         unsafe { CStr::from_ptr(self.name.as_ptr() as _) }
     }
+
     pub fn r#type(&self) -> Ty {
         self.r#type.into()
     }
@@ -569,13 +570,15 @@ impl WsResultSetTrait for WsResultSet {
             WsResultSet::Schemaless(rs) => rs.tmq_get_topic_name(),
         }
     }
+
     fn tmq_get_db_name(&self) -> *const c_char {
         match self {
             WsResultSet::Sql(rs) => rs.tmq_get_db_name(),
             WsResultSet::Tmq(rs) => rs.tmq_get_db_name(),
             WsResultSet::Schemaless(rs) => rs.tmq_get_db_name(),
         }
     }
+
     fn tmq_get_table_name(&self) -> *const c_char {
         match self {
             WsResultSet::Sql(rs) => rs.tmq_get_table_name(),
@@ -599,6 +602,7 @@ impl WsResultSetTrait for WsResultSet {
             WsResultSet::Schemaless(rs) => rs.tmq_get_vgroup_offset(),
         }
     }
+
     fn tmq_get_vgroup_id(&self) -> i32 {
         match self {
             WsResultSet::Sql(rs) => rs.tmq_get_vgroup_id(),
@@ -646,6 +650,7 @@ impl WsResultSetTrait for WsResultSet {
             WsResultSet::Schemaless(rs) => rs.get_fields(),
         }
     }
+
     fn get_fields_v2(&mut self) -> *const WS_FIELD_V2 {
         match self {
             WsResultSet::Sql(rs) => rs.get_fields_v2(),
@@ -989,9 +994,9 @@ unsafe fn query_with_sql(
 ) -> WsResult<WsResultSet> {
     let client = (taos as *mut Taos)
         .as_mut()
-        .ok_or(WsError::new(Code::INVALID_PARA, "client pointer it null"))?;
+        .ok_or(WsError::new(Code::INVALID_PARA, "client pointer is null"))?;
 
-    let sql = CStr::from_ptr(sql as _).to_str()?;
+    let sql = CStr::from_ptr(sql).to_str()?;
     let rs = client.query_with_req_id(sql, req_id)?;
     Ok(WsResultSet::Sql(WsSqlResultSet::new(rs)))
 }
@@ -1141,7 +1146,7 @@ pub unsafe extern "C" fn ws_select_db(taos: *mut WS_TAOS, db: *const c_char) ->
         }
     };
 
-    let db = CStr::from_ptr(db as _).to_str();
+    let db = CStr::from_ptr(db).to_str();
     let db = match db {
         Ok(t) => t,
         Err(_) => {