use reifydb_type::value::constraint::{Constraint, TypeConstraint};
use crate::{
encoded::shape::{RowShape, RowShapeField},
interface::catalog::column::Column,
};
impl From<&Vec<Column>> for RowShape {
fn from(value: &Vec<Column>) -> Self {
RowShape::from(value.as_slice())
}
}
impl From<&[Column]> for RowShape {
fn from(value: &[Column]) -> Self {
let fields = value
.iter()
.map(|col| {
let constraint = match col.constraint.constraint() {
Some(Constraint::Dictionary(dict_id, id_type)) => {
TypeConstraint::dictionary(*dict_id, id_type.clone())
}
_ => col.constraint.clone(),
};
RowShapeField::new(col.name.clone(), constraint)
})
.collect();
RowShape::new(fields)
}
}
#[cfg(test)]
mod tests {
mod from_shape {
}
mod from_column {
use reifydb_type::value::{constraint::TypeConstraint, r#type::Type};
use crate::{
encoded::shape::{RowShape, RowShapeField},
interface::catalog::{
column::{Column, ColumnIndex},
id::ColumnId,
},
};
fn make_column(id: u64, name: &str, ty: Type, index: u8) -> Column {
Column {
id: ColumnId(id),
name: name.to_string(),
constraint: TypeConstraint::unconstrained(ty),
properties: vec![],
index: ColumnIndex(index),
auto_increment: false,
dictionary_id: None,
}
}
#[test]
fn test_from_column_single_field() {
let columns = vec![make_column(1, "id", Type::Int8, 0)];
let shape = RowShape::from(columns.as_slice());
assert_eq!(shape.fields().len(), 1);
assert_eq!(shape.fields()[0].name, "id");
assert_eq!(shape.fields()[0].constraint.get_type(), Type::Int8);
}
#[test]
fn test_from_column_multiple_fields() {
let columns = vec![
make_column(1, "a", Type::Int1, 0),
make_column(2, "b", Type::Int2, 1),
make_column(3, "c", Type::Int4, 2),
];
let shape = RowShape::from(columns.as_slice());
assert_eq!(shape.fields().len(), 3);
assert_eq!(shape.fields()[0].name, "a");
assert_eq!(shape.fields()[0].constraint.get_type(), Type::Int1);
assert_eq!(shape.fields()[1].name, "b");
assert_eq!(shape.fields()[1].constraint.get_type(), Type::Int2);
assert_eq!(shape.fields()[2].name, "c");
assert_eq!(shape.fields()[2].constraint.get_type(), Type::Int4);
}
#[test]
fn test_from_column_preserves_field_order() {
let columns = vec![
make_column(1, "first", Type::Utf8, 0),
make_column(2, "second", Type::Int4, 1),
make_column(3, "third", Type::Boolean, 2),
];
let shape = RowShape::from(columns.as_slice());
assert_eq!(shape.fields()[0].name, "first");
assert_eq!(shape.fields()[0].constraint.get_type(), Type::Utf8);
assert_eq!(shape.fields()[1].name, "second");
assert_eq!(shape.fields()[1].constraint.get_type(), Type::Int4);
assert_eq!(shape.fields()[2].name, "third");
assert_eq!(shape.fields()[2].constraint.get_type(), Type::Boolean);
}
#[test]
fn test_from_column_equivalence_with_direct_construction() {
let columns = vec![
make_column(1, "f0", Type::Uint1, 0),
make_column(2, "f1", Type::Uint2, 1),
make_column(3, "f2", Type::Uint4, 2),
make_column(4, "f3", Type::Uint8, 3),
make_column(5, "f4", Type::Uint16, 4),
];
let shape_from_columns = RowShape::from(columns.as_slice());
let shape_direct = RowShape::new(vec![
RowShapeField::unconstrained("f0", Type::Uint1),
RowShapeField::unconstrained("f1", Type::Uint2),
RowShapeField::unconstrained("f2", Type::Uint4),
RowShapeField::unconstrained("f3", Type::Uint8),
RowShapeField::unconstrained("f4", Type::Uint16),
]);
assert_eq!(shape_from_columns.fields().len(), shape_direct.fields().len());
assert_eq!(shape_from_columns.fingerprint(), shape_direct.fingerprint());
for (i, (from_columns, direct)) in
shape_from_columns.fields().iter().zip(shape_direct.fields().iter()).enumerate()
{
assert_eq!(from_columns.name, direct.name, "name mismatch at field {}", i);
assert_eq!(
from_columns.constraint, direct.constraint,
"constraint mismatch at field {}",
i
);
assert_eq!(from_columns.offset, direct.offset, "offset mismatch at field {}", i);
assert_eq!(from_columns.size, direct.size, "size mismatch at field {}", i);
assert_eq!(from_columns.align, direct.align, "align mismatch at field {}", i);
}
}
#[test]
fn test_from_column_empty() {
let columns: Vec<Column> = vec![];
let shape = RowShape::from(columns.as_slice());
assert_eq!(shape.fields().len(), 0);
}
#[test]
fn test_from_column_nine_fields() {
let columns = vec![
make_column(1, "f0", Type::Boolean, 0),
make_column(2, "f1", Type::Int1, 1),
make_column(3, "f2", Type::Int2, 2),
make_column(4, "f3", Type::Int4, 3),
make_column(5, "f4", Type::Int8, 4),
make_column(6, "f5", Type::Uint1, 5),
make_column(7, "f6", Type::Uint2, 6),
make_column(8, "f7", Type::Uint4, 7),
make_column(9, "f8", Type::Uint8, 8),
];
let shape = RowShape::from(columns.as_slice());
assert_eq!(shape.fields().len(), 9);
for (i, field) in shape.fields().iter().enumerate() {
assert_eq!(field.name, format!("f{}", i));
}
}
}
}