reifydb-catalog 0.4.13

Database catalog and metadata management 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

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

use reifydb_core::{
	encoded::shape::RowShape,
	key::shape::{RowShapeFieldKey, RowShapeKey},
};
use reifydb_transaction::transaction::Transaction;
use tracing::instrument;

use super::shape::{shape_field, shape_header};
use crate::Result;

#[instrument(
	name = "shape_store::create",
	level = "debug",
	skip(txn, shape),
	fields(fingerprint = ?shape.fingerprint(), field_count = shape.field_count())
)]
pub(crate) fn create_row_shape(txn: &mut Transaction<'_>, shape: &RowShape) -> Result<()> {
	let fingerprint = shape.fingerprint();

	let mut header_row = shape_header::SHAPE.allocate();
	shape_header::SHAPE.set_u16(&mut header_row, shape_header::FIELD_COUNT, shape.field_count() as u16);
	txn.set(&RowShapeKey::encoded(fingerprint), header_row)?;

	for (idx, field) in shape.fields().iter().enumerate() {
		let ffi = field.constraint.to_ffi();

		let mut field_row = shape_field::SHAPE.allocate();
		shape_field::SHAPE.set_utf8(&mut field_row, shape_field::NAME, &field.name);
		shape_field::SHAPE.set_u8(&mut field_row, shape_field::TYPE, ffi.base_type);
		shape_field::SHAPE.set_u8(&mut field_row, shape_field::CONSTRAINT_TYPE, ffi.constraint_type);
		shape_field::SHAPE.set_u32(&mut field_row, shape_field::CONSTRAINT_P1, ffi.constraint_param1);
		shape_field::SHAPE.set_u32(&mut field_row, shape_field::CONSTRAINT_P2, ffi.constraint_param2);
		shape_field::SHAPE.set_u32(&mut field_row, shape_field::OFFSET, field.offset);
		shape_field::SHAPE.set_u32(&mut field_row, shape_field::SIZE, field.size);
		shape_field::SHAPE.set_u8(&mut field_row, shape_field::ALIGN, field.align);

		txn.set(&RowShapeFieldKey::encoded(fingerprint, idx as u16), field_row)?;
	}

	Ok(())
}