use crate::{
metadata::tables::{
localvariable::LocalVariableRaw,
types::{RowWritable, TableInfoRef},
},
utils::{write_le_at, write_le_at_dyn},
Result,
};
impl RowWritable for LocalVariableRaw {
fn row_write(
&self,
data: &mut [u8],
offset: &mut usize,
_rid: u32,
sizes: &TableInfoRef,
) -> Result<()> {
write_le_at::<u16>(data, offset, self.attributes)?;
write_le_at::<u16>(data, offset, self.index)?;
write_le_at_dyn(data, offset, self.name, sizes.is_large_str())?;
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_heap() {
let original_row = LocalVariableRaw {
rid: 1,
token: Token::new(0x3300_0001),
offset: 0,
attributes: 0x1234,
index: 0x5678,
name: 42,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalVariableRaw 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 =
LocalVariableRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(original_row.attributes, deserialized_row.attributes);
assert_eq!(original_row.index, deserialized_row.index);
assert_eq!(original_row.name, deserialized_row.name);
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_heap() {
let original_row = LocalVariableRaw {
rid: 2,
token: Token::new(0x3300_0002),
offset: 0,
attributes: 0x9ABC,
index: 0xDEF0,
name: 0x1BEEF,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], true, false, false));
let row_size = <LocalVariableRaw 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 =
LocalVariableRaw::row_read(&buffer, &mut read_offset, 2, &table_info)
.expect("Deserialization should succeed");
assert_eq!(original_row.attributes, deserialized_row.attributes);
assert_eq!(original_row.index, deserialized_row.index);
assert_eq!(original_row.name, deserialized_row.name);
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_heap() {
let local_variable = LocalVariableRaw {
rid: 1,
token: Token::new(0x3300_0001),
offset: 0,
attributes: 0x1234,
index: 0x5678,
name: 0x9ABC,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalVariableRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_variable
.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 small heap");
assert_eq!(buffer[0], 0x34);
assert_eq!(buffer[1], 0x12);
assert_eq!(buffer[2], 0x78);
assert_eq!(buffer[3], 0x56);
assert_eq!(buffer[4], 0xBC);
assert_eq!(buffer[5], 0x9A);
}
#[test]
fn test_known_binary_format_large_heap() {
let local_variable = LocalVariableRaw {
rid: 1,
token: Token::new(0x3300_0001),
offset: 0,
attributes: 0x1234,
index: 0x5678,
name: 0x9ABCDEF0,
};
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], true, false, false));
let row_size = <LocalVariableRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_variable
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
assert_eq!(row_size, 8, "Row size should be 8 bytes for large heap");
assert_eq!(buffer[0], 0x34);
assert_eq!(buffer[1], 0x12);
assert_eq!(buffer[2], 0x78);
assert_eq!(buffer[3], 0x56);
assert_eq!(buffer[4], 0xF0);
assert_eq!(buffer[5], 0xDE);
assert_eq!(buffer[6], 0xBC);
assert_eq!(buffer[7], 0x9A);
}
#[test]
fn test_anonymous_variable() {
let local_variable = LocalVariableRaw {
rid: 1,
token: Token::new(0x3300_0001),
offset: 0,
attributes: 0x0001, index: 0, name: 0, };
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalVariableRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_variable
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
let mut read_offset = 0;
let deserialized_row =
LocalVariableRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(deserialized_row.attributes, 0x0001);
assert_eq!(deserialized_row.index, 0);
assert_eq!(deserialized_row.name, 0);
}
#[test]
fn test_various_attributes_and_indices() {
let test_cases = vec![
(0x0000, 0), (0x0001, 1), (0xFFFF, 65535), ];
for (attributes, index) in test_cases {
let local_variable = LocalVariableRaw {
rid: 1,
token: Token::new(0x3300_0001),
offset: 0,
attributes,
index,
name: 100, };
let table_info = std::sync::Arc::new(TableInfo::new_test(&[], false, false, false));
let row_size = <LocalVariableRaw as TableRow>::row_size(&table_info) as usize;
let mut buffer = vec![0u8; row_size];
let mut offset = 0;
local_variable
.row_write(&mut buffer, &mut offset, 1, &table_info)
.expect("Serialization should succeed");
let mut read_offset = 0;
let deserialized_row =
LocalVariableRaw::row_read(&buffer, &mut read_offset, 1, &table_info)
.expect("Deserialization should succeed");
assert_eq!(deserialized_row.attributes, attributes);
assert_eq!(deserialized_row.index, index);
assert_eq!(deserialized_row.name, 100);
}
}
}