From 2d19e5dac4ac7a9b0e6d16a6fbb0603f59e915f7 Mon Sep 17 00:00:00 2001 From: Kould <2435992353@qq.com> Date: Sat, 7 Oct 2023 15:40:50 +0800 Subject: [PATCH] style: code fmt --- src/execution/executor/dml/copy_from_file.rs | 6 +----- src/execution/executor/dml/update.rs | 2 +- src/execution/executor/dql/join/hash_join.rs | 6 +----- 3 files changed, 3 insertions(+), 11 deletions(-) diff --git a/src/execution/executor/dml/copy_from_file.rs b/src/execution/executor/dml/copy_from_file.rs index a85c401b..fa8ea2fc 100644 --- a/src/execution/executor/dml/copy_from_file.rs +++ b/src/execution/executor/dml/copy_from_file.rs @@ -194,11 +194,7 @@ mod tests { .await; let storage = db.storage; let transaction = RefCell::new(storage.transaction().await?); - let actual = executor - .execute(&transaction) - .next() - .await - .unwrap()?; + let actual = executor.execute(&transaction).next().await.unwrap()?; let tuple_builder = TupleBuilder::new_result(); let expected = tuple_builder diff --git a/src/execution/executor/dml/update.rs b/src/execution/executor/dml/update.rs index 6dd1055a..ee48a87a 100644 --- a/src/execution/executor/dml/update.rs +++ b/src/execution/executor/dml/update.rs @@ -39,7 +39,7 @@ impl Executor for Update { impl Update { #[try_stream(boxed, ok = Tuple, error = ExecutorError)] - pub async fn _execute(self, transaction: &mut T, ) { + pub async fn _execute(self, transaction: &mut T) { let Update { table_name, input, diff --git a/src/execution/executor/dql/join/hash_join.rs b/src/execution/executor/dql/join/hash_join.rs index 1fdc75bb..c99fee67 100644 --- a/src/execution/executor/dql/join/hash_join.rs +++ b/src/execution/executor/dql/join/hash_join.rs @@ -369,11 +369,7 @@ mod test { columns: t2_columns, }); - ( - on_keys, - values_t1.execute(&_t), - values_t2.execute(&_t), - ) + (on_keys, values_t1.execute(&_t), values_t2.execute(&_t)) } #[tokio::test]