fmt

Author: hantmac

driver/src/rest_api.rs

@@ -234,16 +234,16 @@ impl<'o> RestAPIConnection {
             ("record_delimiter", "\n"),
             ("skip_header", "0"),
         ]
-            .into_iter()
-            .collect()
+        .into_iter()
+        .collect()
     }
 
     fn default_copy_options() -> BTreeMap<&'o str, &'o str> {
         vec![("purge", "true")].into_iter().collect()
     }
 }
 
-type PageFut = Pin<Box<dyn Future<Output=Result<QueryResponse>> + Send>>;
+type PageFut = Pin<Box<dyn Future<Output = Result<QueryResponse>> + Send>>;
 
 pub struct RestAPIRows {
     client: APIClient,

driver/tests/driver/transaction.rs

@@ -16,19 +16,20 @@ use databend_driver::Client;
 
 use crate::common::DEFAULT_DSN;
 
-
 #[tokio::test]
 async fn test_commit() {
     let dsn = option_env!("TEST_DATABEND_DSN").unwrap_or(DEFAULT_DSN);
     let client = Client::new(dsn.to_string());
     let conn = client.get_conn().await.unwrap();
 
-    conn.exec("CREATE OR REPLACE TABLE t(c int);").await.unwrap();
+    conn.exec("CREATE OR REPLACE TABLE t(c int);")
+        .await
+        .unwrap();
     conn.begin().await.unwrap();
     conn.exec("INSERT INTO t VALUES(1);").await.unwrap();
     let row = conn.query_row("SELECT * FROM t").await.unwrap();
     let row = row.unwrap();
-    let (val, ): (i32, ) = row.try_into().unwrap();
+    let (val,): (i32,) = row.try_into().unwrap();
     assert_eq!(val, 1);
     conn.commit().await.unwrap();
 }
@@ -39,17 +40,18 @@ async fn test_rollback() {
     let client = Client::new(dsn.to_string());
     let conn = client.get_conn().await.unwrap();
 
-    conn.exec("CREATE OR REPLACE TABLE t(c int);").await.unwrap();
+    conn.exec("CREATE OR REPLACE TABLE t(c int);")
+        .await
+        .unwrap();
     conn.begin().await.unwrap();
     conn.exec("INSERT INTO t VALUES(1);").await.unwrap();
     let row = conn.query_row("SELECT * FROM t").await.unwrap();
     let row = row.unwrap();
-    let (val, ): (i32, ) = row.try_into().unwrap();
+    let (val,): (i32,) = row.try_into().unwrap();
     assert_eq!(val, 1);
     conn.rollback().await.unwrap();
     let row = conn.query_row("SELECT * FROM t").await.unwrap();
     let row = row.unwrap();
-    let (val, ): (Option<i32>, ) = row.try_into().unwrap();
+    let (val,): (Option<i32>,) = row.try_into().unwrap();
     assert_eq!(val, None)
 }
-