use new query engine to delete all records from table (#473)

data/catalog/src/in_memory.rs

@@ -512,6 +512,11 @@ impl SqlTable for InMemoryTable {
                 .collect(),
         ))
     }
+
+    fn delete_all(&self) -> usize {
+        let keys = self.data_table.select().map(|(key, _value)| key).collect();
+        self.data_table.delete(keys)
+    }
 }
 
 #[cfg(test)]

data/catalog/src/lib.rs

@@ -98,6 +98,8 @@ pub trait SqlTable {
 
     fn select(&self) -> (Vec<ColumnDef>, Vec<Vec<Datum>>);
     fn select_with_columns(&self, column_names: Vec<String>) -> Result<(Vec<ColumnDef>, Vec<Vec<Datum>>), String>;
+
+    fn delete_all(&self) -> usize;
 }
 
 pub trait Database {

data_manipulation/query_result/src/lib.rs

@@ -18,6 +18,7 @@ use repr::Datum;
 #[derive(Debug, PartialEq)]
 pub enum QueryExecution {
     Inserted(usize),
+    Deleted(usize),
     Selected((Vec<ColumnDef>, Vec<Vec<Datum>>)),
 }
 

data_manipulation/typed_queries/src/lib.rs

@@ -22,9 +22,15 @@ pub struct InsertQuery {
     pub values: Vec<Vec<StaticTypedTree>>,
 }
 
+#[derive(Debug, PartialEq)]
+pub struct DeleteQuery {
+    pub full_table_name: FullTableName,
+}
+
 #[derive(Debug, PartialEq)]
 pub enum TypedWrite {
     Insert(InsertQuery),
+    Delete(DeleteQuery),
 }
 
 #[derive(Debug, PartialEq)]

server/node/src/query_engine/tests/mod.rs

@@ -26,8 +26,8 @@ use std::{
 };
 
 // TODO: new engine does not handle deletes
-// #[cfg(test)]
-// mod delete;
+#[cfg(test)]
+mod delete;
 // TODO: new engine does not handle extended query flow
 // #[cfg(test)]
 // mod extended_query_flow;

write_query/executor/src/lib.rs

@@ -14,7 +14,7 @@
 
 use catalog::{Database, SqlTable};
 use data_manipulation_query_result::{QueryExecution, QueryExecutionError};
-use data_manipulation_typed_queries::{InsertQuery, TypedWrite};
+use data_manipulation_typed_queries::{DeleteQuery, InsertQuery, TypedWrite};
 use data_manipulation_typed_tree::StaticTypedTree;
 use std::sync::Arc;
 
@@ -49,6 +49,9 @@ impl<D: Database> WriteQueryExecutor<D> {
                 };
                 Ok(QueryExecution::Inserted(inserted))
             }
+            TypedWrite::Delete(DeleteQuery { full_table_name }) => Ok(QueryExecution::Deleted(
+                self.database.work_with(&full_table_name, |table| table.delete_all()),
+            )),
         }
     }
 }