reifydb_codec/encoded/
i8.rs1use std::ptr;
5
6use reifydb_value::{reifydb_assertions, value::value_type::ValueType};
7
8use crate::encoded::{row::EncodedRow, shape::RowShape};
9
10impl RowShape {
11 pub fn set_i8(&self, row: &mut EncodedRow, index: usize, value: impl Into<i8>) {
12 let field = &self.fields()[index];
13 reifydb_assertions! {
14 assert!(
15 row.len() >= self.total_static_size(),
16 "row/shape size mismatch: row.len()={} < total_static_size()={}",
17 row.len(),
18 self.total_static_size()
19 );
20 assert_eq!(*field.constraint.get_type().inner_type(), ValueType::Int1);
21 }
22 row.set_valid(index, true);
23 unsafe {
24 ptr::write_unaligned(
25 row.make_mut().as_mut_ptr().add(field.offset as usize) as *mut i8,
26 value.into(),
27 )
28 }
29 }
30
31 pub fn get_i8(&self, row: &EncodedRow, index: usize) -> i8 {
32 let field = &self.fields()[index];
33 reifydb_assertions! {
34 assert!(
35 row.len() >= self.total_static_size(),
36 "row/shape size mismatch: row.len()={} < total_static_size()={}",
37 row.len(),
38 self.total_static_size()
39 );
40 assert_eq!(*field.constraint.get_type().inner_type(), ValueType::Int1);
41 }
42 unsafe { (row.as_ptr().add(field.offset as usize) as *const i8).read_unaligned() }
43 }
44
45 pub fn try_get_i8(&self, row: &EncodedRow, index: usize) -> Option<i8> {
46 if row.is_defined(index) && self.fields()[index].constraint.get_type() == ValueType::Int1 {
47 Some(self.get_i8(row, index))
48 } else {
49 None
50 }
51 }
52}
53
54#[cfg(test)]
55pub mod tests {
56 use reifydb_value::value::value_type::ValueType;
57
58 use crate::encoded::shape::RowShape;
59
60 #[test]
61 fn test_set_get_i8() {
62 let shape = RowShape::testing(&[ValueType::Int1]);
63 let mut row = shape.allocate();
64 shape.set_i8(&mut row, 0, 42i8);
65 assert_eq!(shape.get_i8(&row, 0), 42i8);
66 }
67
68 #[test]
69 fn test_try_get_i8() {
70 let shape = RowShape::testing(&[ValueType::Int1]);
71 let mut row = shape.allocate();
72
73 assert_eq!(shape.try_get_i8(&row, 0), None);
74
75 shape.set_i8(&mut row, 0, 42i8);
76 assert_eq!(shape.try_get_i8(&row, 0), Some(42i8));
77 }
78
79 #[test]
80 fn test_extremes() {
81 let shape = RowShape::testing(&[ValueType::Int1]);
82 let mut row = shape.allocate();
83
84 shape.set_i8(&mut row, 0, i8::MAX);
85 assert_eq!(shape.get_i8(&row, 0), i8::MAX);
86
87 let mut row2 = shape.allocate();
88 shape.set_i8(&mut row2, 0, i8::MIN);
89 assert_eq!(shape.get_i8(&row2, 0), i8::MIN);
90
91 let mut row3 = shape.allocate();
92 shape.set_i8(&mut row3, 0, 0i8);
93 assert_eq!(shape.get_i8(&row3, 0), 0i8);
94 }
95
96 #[test]
97 fn test_negative_positive() {
98 let shape = RowShape::testing(&[ValueType::Int1, ValueType::Int1]);
99 let mut row = shape.allocate();
100
101 shape.set_i8(&mut row, 0, -100i8);
102 shape.set_i8(&mut row, 1, 100i8);
103
104 assert_eq!(shape.get_i8(&row, 0), -100i8);
105 assert_eq!(shape.get_i8(&row, 1), 100i8);
106 }
107
108 #[test]
109 fn test_mixed_with_other_types() {
110 let shape = RowShape::testing(&[ValueType::Int1, ValueType::Boolean, ValueType::Int1]);
111 let mut row = shape.allocate();
112
113 shape.set_i8(&mut row, 0, -50i8);
114 shape.set_bool(&mut row, 1, true);
115 shape.set_i8(&mut row, 2, 75i8);
116
117 assert_eq!(shape.get_i8(&row, 0), -50i8);
118 assert_eq!(shape.get_bool(&row, 1), true);
119 assert_eq!(shape.get_i8(&row, 2), 75i8);
120 }
121
122 #[test]
123 fn test_undefined_handling() {
124 let shape = RowShape::testing(&[ValueType::Int1, ValueType::Int1]);
125 let mut row = shape.allocate();
126
127 shape.set_i8(&mut row, 0, 42);
128
129 assert_eq!(shape.try_get_i8(&row, 0), Some(42));
130 assert_eq!(shape.try_get_i8(&row, 1), None);
131
132 shape.set_none(&mut row, 0);
133 assert_eq!(shape.try_get_i8(&row, 0), None);
134 }
135
136 #[test]
137 fn test_try_get_i8_wrong_type() {
138 let shape = RowShape::testing(&[ValueType::Boolean]);
139 let mut row = shape.allocate();
140
141 shape.set_bool(&mut row, 0, true);
142
143 assert_eq!(shape.try_get_i8(&row, 0), None);
144 }
145}