From 38c5176b04fbfd9faeae0f57f17ce65e703e806f Mon Sep 17 00:00:00 2001
From: Otavio Santana <otaviopolianasantana@gmail.com>
Date: Wed, 29 Nov 2023 14:51:45 +0000
Subject: [PATCH] feat: create delete implementation

Signed-off-by: Otavio Santana <otaviopolianasantana@gmail.com>
---
 .../java/expert/os/harperdb/Template.java     | 32 +++++++++++++++++++
 1 file changed, 32 insertions(+)

diff --git a/core/src/main/java/expert/os/harperdb/Template.java b/core/src/main/java/expert/os/harperdb/Template.java
index 4fc7e1f..21e0d69 100644
--- a/core/src/main/java/expert/os/harperdb/Template.java
+++ b/core/src/main/java/expert/os/harperdb/Template.java
@@ -72,6 +72,38 @@ public <T> boolean upsert(Iterable<T> entities) {
         return server.execute(insert);
     }
 
+    public <K> boolean delete(String table, K id) {
+        Objects.requireNonNull(table, "table is required");
+        Objects.requireNonNull(id, "id is required");
+        var delete = new Delete<>(database, table, Collections.singleton(id), ALL_ATTRIBUTES);
+        return server.execute(delete);
+    }
+
+    public <K, T> boolean delete(Class<T> type, K id) {
+        Objects.requireNonNull(type, "type is required");
+        Objects.requireNonNull(id, "id is required");
+        var delete = new Delete<>(database, table(type), Collections.singleton(id), ALL_ATTRIBUTES);
+        return server.execute(delete);
+    }
+
+    public <K, T> boolean deleteAllById(Class<T> type, Iterable<K> ids) {
+        Objects.requireNonNull(type, "type is required");
+        Objects.requireNonNull(ids, "ids is required");
+        var keys = StreamSupport.stream(ids.spliterator(), false)
+                .collect(Collectors.toSet());
+        var delete = new Delete<>(database, table(type), Collections.singleton(keys), ALL_ATTRIBUTES);
+        return server.execute(delete);
+    }
+
+    public <K> boolean deleteAllById(String table, Iterable<K> ids) {
+        Objects.requireNonNull(table, "table is required");
+        Objects.requireNonNull(ids, "ids is required");
+        var keys = StreamSupport.stream(ids.spliterator(), false)
+                .collect(Collectors.toSet());
+        var delete = new Delete<>(database, table, keys, ALL_ATTRIBUTES);
+        return server.execute(delete);
+    }
+
     public <K, T> Optional<T> findById(K id, Class<T> type) {
         Objects.requireNonNull(id, "id is required");
         Objects.requireNonNull(type, "type is required");