reifydb-core 0.4.12

Core database interfaces and data structures for ReifyDB
Documentation
// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

use reifydb_type::{
	fragment::Fragment,
	util::cowvec::CowVec,
	value::{
		constraint::{bytes::MaxBytes, precision::Precision, scale::Scale},
		frame::{column::FrameColumn, data::FrameColumnData, frame::Frame},
	},
};

use crate::value::column::{Column, ColumnData, columns::Columns};

impl From<ColumnData> for FrameColumnData {
	fn from(value: ColumnData) -> Self {
		match value {
			ColumnData::Bool(container) => FrameColumnData::Bool(container),
			ColumnData::Float4(container) => FrameColumnData::Float4(container),
			ColumnData::Float8(container) => FrameColumnData::Float8(container),
			ColumnData::Int1(container) => FrameColumnData::Int1(container),
			ColumnData::Int2(container) => FrameColumnData::Int2(container),
			ColumnData::Int4(container) => FrameColumnData::Int4(container),
			ColumnData::Int8(container) => FrameColumnData::Int8(container),
			ColumnData::Int16(container) => FrameColumnData::Int16(container),
			ColumnData::Uint1(container) => FrameColumnData::Uint1(container),
			ColumnData::Uint2(container) => FrameColumnData::Uint2(container),
			ColumnData::Uint4(container) => FrameColumnData::Uint4(container),
			ColumnData::Uint8(container) => FrameColumnData::Uint8(container),
			ColumnData::Uint16(container) => FrameColumnData::Uint16(container),
			ColumnData::Utf8 {
				container,
				..
			} => FrameColumnData::Utf8(container),
			ColumnData::Date(container) => FrameColumnData::Date(container),
			ColumnData::DateTime(container) => FrameColumnData::DateTime(container),
			ColumnData::Time(container) => FrameColumnData::Time(container),
			ColumnData::Duration(container) => FrameColumnData::Duration(container),
			ColumnData::IdentityId(container) => FrameColumnData::IdentityId(container),
			ColumnData::Uuid4(container) => FrameColumnData::Uuid4(container),
			ColumnData::Uuid7(container) => FrameColumnData::Uuid7(container),
			ColumnData::Blob {
				container,
				..
			} => FrameColumnData::Blob(container),
			ColumnData::Int {
				container,
				..
			} => FrameColumnData::Int(container),
			ColumnData::Uint {
				container,
				..
			} => FrameColumnData::Uint(container),
			ColumnData::Decimal {
				container,
				..
			} => FrameColumnData::Decimal(container),
			ColumnData::Any(container) => FrameColumnData::Any(container),
			ColumnData::DictionaryId(container) => FrameColumnData::DictionaryId(container),
			ColumnData::Option {
				inner,
				bitvec,
			} => FrameColumnData::Option {
				inner: Box::new(FrameColumnData::from(*inner)),
				bitvec,
			},
		}
	}
}

impl From<Column> for FrameColumn {
	fn from(value: Column) -> Self {
		FrameColumn {
			name: value.name.to_string(),
			data: value.data.into(),
		}
	}
}

impl From<Columns> for Frame {
	fn from(columns: Columns) -> Self {
		let frame_columns: Vec<FrameColumn> = columns.columns.into_iter().map(|col| col.into()).collect();
		Frame {
			row_numbers: columns.row_numbers.to_vec(),
			created_at: columns.created_at.to_vec(),
			updated_at: columns.updated_at.to_vec(),
			columns: frame_columns,
		}
	}
}

impl From<FrameColumnData> for ColumnData {
	fn from(value: FrameColumnData) -> Self {
		match value {
			FrameColumnData::Bool(container) => ColumnData::Bool(container),
			FrameColumnData::Float4(container) => ColumnData::Float4(container),
			FrameColumnData::Float8(container) => ColumnData::Float8(container),
			FrameColumnData::Int1(container) => ColumnData::Int1(container),
			FrameColumnData::Int2(container) => ColumnData::Int2(container),
			FrameColumnData::Int4(container) => ColumnData::Int4(container),
			FrameColumnData::Int8(container) => ColumnData::Int8(container),
			FrameColumnData::Int16(container) => ColumnData::Int16(container),
			FrameColumnData::Uint1(container) => ColumnData::Uint1(container),
			FrameColumnData::Uint2(container) => ColumnData::Uint2(container),
			FrameColumnData::Uint4(container) => ColumnData::Uint4(container),
			FrameColumnData::Uint8(container) => ColumnData::Uint8(container),
			FrameColumnData::Uint16(container) => ColumnData::Uint16(container),
			FrameColumnData::Utf8(container) => ColumnData::Utf8 {
				container,
				max_bytes: MaxBytes::MAX,
			},
			FrameColumnData::Date(container) => ColumnData::Date(container),
			FrameColumnData::DateTime(container) => ColumnData::DateTime(container),
			FrameColumnData::Time(container) => ColumnData::Time(container),
			FrameColumnData::Duration(container) => ColumnData::Duration(container),
			FrameColumnData::IdentityId(container) => ColumnData::IdentityId(container),
			FrameColumnData::Uuid4(container) => ColumnData::Uuid4(container),
			FrameColumnData::Uuid7(container) => ColumnData::Uuid7(container),
			FrameColumnData::Blob(container) => ColumnData::Blob {
				container,
				max_bytes: MaxBytes::MAX,
			},
			FrameColumnData::Int(container) => ColumnData::Int {
				container,
				max_bytes: MaxBytes::MAX,
			},
			FrameColumnData::Uint(container) => ColumnData::Uint {
				container,
				max_bytes: MaxBytes::MAX,
			},
			FrameColumnData::Decimal(container) => ColumnData::Decimal {
				container,
				precision: Precision::MAX,
				scale: Scale::new(0),
			},
			FrameColumnData::Any(container) => ColumnData::Any(container),
			FrameColumnData::DictionaryId(container) => ColumnData::DictionaryId(container),
			FrameColumnData::Option {
				inner,
				bitvec,
			} => ColumnData::Option {
				inner: Box::new(ColumnData::from(*inner)),
				bitvec,
			},
		}
	}
}

impl From<FrameColumn> for Column {
	fn from(value: FrameColumn) -> Self {
		Column {
			name: Fragment::internal(value.name),
			data: value.data.into(),
		}
	}
}

impl From<Frame> for Columns {
	fn from(frame: Frame) -> Self {
		let columns: Vec<Column> = frame.columns.into_iter().map(|col| col.into()).collect();
		Columns {
			row_numbers: CowVec::new(frame.row_numbers),
			created_at: CowVec::new(frame.created_at),
			updated_at: CowVec::new(frame.updated_at),
			columns: CowVec::new(columns),
		}
	}
}