Method upsert_kg_edge

atomic-core/src/pristine/txn/write/triples.rs:228–247

(&mut self, edge: &KgEdge)

    }

    fn upsert_kg_edge(&mut self, edge: &KgEdge) -> PristineResult<()> {
        let edge_key = encode_edge_key(&edge.from_id, &edge.to_id, &edge.kind);

        let mut edges_table = self.txn.open_table(KG_EDGES)?;
        let bytes = serde_json::to_vec(edge).map_err(|e| PristineError::Serialization {
            message: e.to_string(),
        })?;
        edges_table.insert(edge_key.as_str(), bytes.as_slice())?;
        drop(edges_table);

        // Update indexes
        let mut from_table = self.txn.open_multimap_table(KG_EDGES_FROM)?;
        from_table.insert(edge.from_id.as_str(), edge_key.as_str())?;
        drop(from_table);

        let mut to_table = self.txn.open_multimap_table(KG_EDGES_TO)?;
        to_table.insert(edge.to_id.as_str(), edge_key.as_str())?;

        Ok(())
    }

    fn del_kg_node(&mut self, id: &str) -> PristineResult<bool> {
        // First delete all edges for this node