chore: uncheck for decode tuple primary key when query

Author: KKould

src/execution/ddl/mod.rs

@@ -124,9 +124,7 @@ where
         if batch_len == 0 {
             break;
         }
-        last_pk = batch
-            .get(batch_len - 1)
-            .and_then(|tuple| tuple.pk.clone());
+        last_pk = batch.get(batch_len - 1).and_then(|tuple| tuple.pk.clone());
 
         for tuple in batch.iter().take(batch_len) {
             visit(tuple)?;
@@ -174,9 +172,7 @@ where
         if batch_len == 0 {
             break;
         }
-        last_pk = batch
-            .get(batch_len - 1)
-            .and_then(|tuple| tuple.pk.clone());
+        last_pk = batch.get(batch_len - 1).and_then(|tuple| tuple.pk.clone());
 
         for tuple in batch.iter_mut().take(batch_len) {
             rewrite(tuple)?;

src/execution/mod.rs

@@ -261,12 +261,8 @@ impl<'a, T: Transaction + 'a> ExecArena<'a, T> {
             ExecNode::DropColumn(mut exec) => {
                 (exec.next_tuple(self, id), ExecNode::DropColumn(exec))
             }
-            ExecNode::DropIndex(mut exec) => {
-                (exec.next_tuple(self, id), ExecNode::DropIndex(exec))
-            }
-            ExecNode::DropTable(mut exec) => {
-                (exec.next_tuple(self, id), ExecNode::DropTable(exec))
-            }
+            ExecNode::DropIndex(mut exec) => (exec.next_tuple(self, id), ExecNode::DropIndex(exec)),
+            ExecNode::DropTable(mut exec) => (exec.next_tuple(self, id), ExecNode::DropTable(exec)),
             ExecNode::DropView(mut exec) => (exec.next_tuple(self, id), ExecNode::DropView(exec)),
             ExecNode::Dummy(mut exec) => (exec.next_tuple(self, id), ExecNode::Dummy(exec)),
             ExecNode::Except(mut exec) => (exec.next_tuple(self, id), ExecNode::Except(exec)),
@@ -293,12 +289,8 @@ impl<'a, T: Transaction + 'a> ExecArena<'a, T> {
             ExecNode::ShowTables(mut exec) => {
                 (exec.next_tuple(self, id), ExecNode::ShowTables(exec))
             }
-            ExecNode::ShowViews(mut exec) => {
-                (exec.next_tuple(self, id), ExecNode::ShowViews(exec))
-            }
-            ExecNode::SimpleAgg(mut exec) => {
-                (exec.next_tuple(self, id), ExecNode::SimpleAgg(exec))
-            }
+            ExecNode::ShowViews(mut exec) => (exec.next_tuple(self, id), ExecNode::ShowViews(exec)),
+            ExecNode::SimpleAgg(mut exec) => (exec.next_tuple(self, id), ExecNode::SimpleAgg(exec)),
             ExecNode::Sort(mut exec) => (exec.next_tuple(self), ExecNode::Sort(exec)),
             ExecNode::StreamDistinct(mut exec) => {
                 (exec.next_tuple(self, id), ExecNode::StreamDistinct(exec))

src/python.rs

@@ -208,8 +208,7 @@ impl PythonDatabase {
 
     pub fn execute(&self, sql: &str) -> PyResult<()> {
         let mut iter = self.inner.run(sql).map_err(to_py_err)?;
-        while iter.next_tuple().map_err(to_py_err)?.is_some() {
-        }
+        while iter.next_tuple().map_err(to_py_err)?.is_some() {}
         iter.done().map_err(to_py_err)?;
 
         Ok(())

src/storage/mod.rs

@@ -1423,11 +1423,15 @@ impl<T: Transaction> IndexImpl<T> for PrimaryKeyIndexImpl {
         _: bool,
         out: &mut Bytes,
     ) -> Result<(), DatabaseError> {
-        unsafe { &*params.table_codec() }.with_tuple_key_unchecked(params.table_name, value, |key| {
-            out.clear();
-            out.extend_from_slice(key);
-            Ok(())
-        })
+        unsafe { &*params.table_codec() }.with_tuple_key_unchecked(
+            params.table_name,
+            value,
+            |key| {
+                out.clear();
+                out.extend_from_slice(key);
+                Ok(())
+            },
+        )
     }
 }
 

src/wasm.rs

@@ -86,8 +86,7 @@ impl WasmDatabase {
 
     pub fn execute(&self, sql: &str) -> Result<(), JsValue> {
         let mut iter = self.inner.run(sql).map_err(to_js_err)?;
-        while iter.next_borrowed_tuple().map_err(to_js_err)?.is_some() {
-        }
+        while iter.next_borrowed_tuple().map_err(to_js_err)?.is_some() {}
         Ok(())
     }
 }