|
40 | 40 | import java.time.Duration;
|
41 | 41 | import java.util.Iterator;
|
42 | 42 | import java.util.List;
|
| 43 | +import java.util.Objects; |
43 | 44 | import java.util.Optional;
|
44 | 45 | import java.util.function.Consumer;
|
45 | 46 | import java.util.function.Function;
|
@@ -148,6 +149,27 @@ public <T> Iterable<T> insert(Iterable<T> entities, Duration ttl) {
|
148 | 149 | .collect(Collectors.toList());
|
149 | 150 | }
|
150 | 151 |
|
| 152 | + @Override |
| 153 | + public <T> void delete(T entity) { |
| 154 | + Objects.requireNonNull(entity, "entity is required"); |
| 155 | + EntityMetadata metadata = entities().get(entity.getClass()); |
| 156 | + FieldMetadata idField = metadata.id() |
| 157 | + .orElseThrow(() -> IdNotFoundException.newInstance(metadata.type())); |
| 158 | + |
| 159 | + var idValue = idField.read(entity); |
| 160 | + LOGGER.fine("Deleting entity: " + entity.getClass() + " with id: " + idValue); |
| 161 | + DeleteQuery query = DeleteQuery.delete().from(metadata.name()) |
| 162 | + .where(idField.name()).eq(idValue).build(); |
| 163 | + manager().delete(query); |
| 164 | + } |
| 165 | + |
| 166 | + @Override |
| 167 | + public <T> void delete(Iterable<? extends T> iterable) { |
| 168 | + Objects.requireNonNull(iterable, "iterable is required"); |
| 169 | + StreamSupport.stream(iterable.spliterator(), false) |
| 170 | + .forEach(this::delete); |
| 171 | + } |
| 172 | + |
151 | 173 | @Override
|
152 | 174 | public void delete(DeleteQuery query) {
|
153 | 175 | requireNonNull(query, "query is required");
|
|
0 commit comments