reifydb-engine 0.9.0

Query execution and processing engine for ReifyDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2026 ReifyDB

use reifydb_catalog::catalog::relationship::RelationshipToCreate;
use reifydb_core::{
	interface::catalog::relationship::RelationshipJunction as CoreRelationshipJunction,
	value::column::columns::Columns,
};
use reifydb_rql::nodes::CreateRelationshipNode;
use reifydb_transaction::transaction::admin::AdminTransaction;
use reifydb_value::value::Value;

use crate::{Result, vm::services::Services};

pub(crate) fn create_relationship(
	services: &Services,
	txn: &mut AdminTransaction,
	plan: CreateRelationshipNode,
) -> Result<Columns> {
	let rel = services.catalog.create_relationship(
		txn,
		RelationshipToCreate {
			name: plan.name.clone(),
			namespace: plan.namespace,
			source_table: plan.source_table,
			source_column: plan.source_column,
			target_table: plan.target_table,
			target_column: plan.target_column,
			junction: plan.junction.map(|j| CoreRelationshipJunction {
				table: j.table,
				source_column: j.source_column,
				target_column: j.target_column,
			}),
			cardinality: plan.cardinality,
		},
	)?;

	Ok(Columns::single_row([
		("id", Value::Uint8(rel.id.0)),
		("namespace_id", Value::Uint8(rel.namespace.0)),
		("name", Value::Utf8(rel.name)),
		("cardinality", Value::Utf8(rel.cardinality.as_str().to_string())),
		("created", Value::Boolean(true)),
	]))
}