| 419 | } |
| 420 | |
| 421 | fn del_kg_edge(&mut self, from_id: &str, to_id: &str, kind: &str) -> PristineResult<bool> { |
| 422 | let edge_key = encode_edge_key(from_id, to_id, kind); |
| 423 | |
| 424 | let mut edges_table = match self.txn.open_table(KG_EDGES) { |
| 425 | Ok(t) => t, |
| 426 | Err(redb::TableError::TableDoesNotExist(_)) => return Ok(false), |
| 427 | Err(e) => return Err(PristineError::from(e)), |
| 428 | }; |
| 429 | |
| 430 | let existed = edges_table.remove(edge_key.as_str())?.is_some(); |
| 431 | drop(edges_table); |
| 432 | |
| 433 | if existed { |
| 434 | // Clean up indexes |
| 435 | let mut from_table = self.txn.open_multimap_table(KG_EDGES_FROM)?; |
| 436 | from_table.remove(from_id, edge_key.as_str())?; |
| 437 | drop(from_table); |
| 438 | |
| 439 | let mut to_table = self.txn.open_multimap_table(KG_EDGES_TO)?; |
| 440 | to_table.remove(to_id, edge_key.as_str())?; |
| 441 | } |
| 442 | |
| 443 | Ok(existed) |
| 444 | } |
| 445 | |
| 446 | fn del_kg_edges_for_node(&mut self, node_id: &str) -> PristineResult<usize> { |
| 447 | // Collect all edge keys for this node (both directions) |