use crate::{
metadata::tables::{
localconstant::LocalConstantRaw,
types::{RowWritable, TableInfoRef},
},
utils::write_le_at_dyn,
Result,
};
impl RowWritable for LocalConstantRaw {
fn row_write(
&self,
data: &mut [u8],
offset: &mut usize,
_rid: u32,
sizes: &TableInfoRef,
) -> Result<()> {
write_le_at_dyn(data, offset, self.name, sizes.is_large_str())?;
write_le_at_dyn(data, offset, self.signature, sizes.is_large_blob())?;
Ok(())
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::{
metadata::tables::types::{RowReadable, TableInfo, TableRow},
metadata::token::Token,
};
#[test]
fn test_round_trip_serialization_small_heaps() {
let original_row = LocalConstantRaw {
rid: 1,
token: Token::new(0x3400_0001),
offset: 0,
name: 42,
signature: 123,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
original_row
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
let mut read_offset = 0;
let deserialized_row =
LocalConstantRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(original_row.name, deserialized_row.name);
assert_eq!(original_row.signature, deserialized_row.signature);
assert_eq!(offset, row_size, "Offset should match expected row size");
assert_eq!(
read_offset, row_size,
"Read offset should match expected row size"
);
}
#[test]
fn test_round_trip_serialization_large_heaps() {
let original_row = LocalConstantRaw {
rid: 2,
token: Token::new(0x3400_0002),
offset: 0,
name: 0x1BEEF,
signature: 0x2CA, };
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], true, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
original_row
.row_write(&mut buffer, &mut offset, 2, &table_info)
.expect("Serialization should succeed");
let mut read_offset = 0;
let deserialized_row =
LocalConstantRaw::row_read(&buffer, &mut read_offset, 2, &table_info)
.expect("Deserialization should succeed");
assert_eq!(original_row.name, deserialized_row.name);
assert_eq!(original_row.signature, deserialized_row.signature);
assert_eq!(offset, row_size, "Offset should match expected row size");
assert_eq!(
read_offset, row_size,
"Read offset should match expected row size"
);
}
#[test]
fn test_known_binary_format_small_heaps() {
let local_constant = LocalConstantRaw {
rid: 1,
token: Token::new(0x3400_0001),
offset: 0,
name: 0x1234,
signature: 0x5678,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_constant
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
assert_eq!(row_size, 4, "Row size should be 4 bytes for small heaps");
assert_eq!(buffer[0], 0x34);
assert_eq!(buffer[1], 0x12);
assert_eq!(buffer[2], 0x78);
assert_eq!(buffer[3], 0x56);
}
#[test]
fn test_known_binary_format_large_heaps() {
let local_constant = LocalConstantRaw {
rid: 1,
token: Token::new(0x3400_0001),
offset: 0,
name: 0x12345678,
signature: 0x9ABC, };
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], true, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_constant
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
assert_eq!(
row_size, 6,
"Row size should be 6 bytes for large string, small blob"
);
assert_eq!(buffer[0], 0x78);
assert_eq!(buffer[1], 0x56);
assert_eq!(buffer[2], 0x34);
assert_eq!(buffer[3], 0x12);
assert_eq!(buffer[4], 0xBC);
assert_eq!(buffer[5], 0x9A);
}
#[test]
fn test_anonymous_constant() {
let local_constant = LocalConstantRaw {
rid: 1,
token: Token::new(0x3400_0001),
offset: 0,
name: 0, signature: 100,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_constant
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
let mut read_offset = 0;
let deserialized_row =
LocalConstantRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(deserialized_row.name, 0);
assert_eq!(deserialized_row.signature, 100);
}
#[test]
fn test_mixed_heap_sizes() {
let local_constant = LocalConstantRaw {
rid: 1,
token: Token::new(0x3400_0001),
offset: 0,
name: 0x12345678, signature: 0x1234, };
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], true, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_constant
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
assert_eq!(
row_size, 6,
"Row size should be 6 bytes for mixed heap sizes"
);
let mut read_offset = 0;
let deserialized_row =
LocalConstantRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(deserialized_row.name, 0x12345678);
assert_eq!(deserialized_row.signature, 0x1234);
}
#[test]
fn test_edge_case_values() {
let test_cases = vec![
(0, 0), (1, 1), (0xFFFF, 0xFFFF), ];
for (name, signature) in test_cases {
let local_constant = LocalConstantRaw {
rid: 1,
token: Token::new(0x3400_0001),
offset: 0,
name,
signature,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalConstantRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_constant
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
let mut read_offset = 0;
let deserialized_row =
LocalConstantRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(deserialized_row.name, name);
assert_eq!(deserialized_row.signature, signature);
}
}
}