datatypes/vectors/
date.rs1use crate::types::DateType;
16use crate::vectors::{PrimitiveVector, PrimitiveVectorBuilder};
17
18pub type DateVector = PrimitiveVector<DateType>;
20pub type DateVectorBuilder = PrimitiveVectorBuilder<DateType>;
22
23#[cfg(test)]
24mod tests {
25 use std::sync::Arc;
26
27 use arrow_array::ArrayRef;
28 use common_time::date::Date;
29
30 use super::*;
31 use crate::data_type::DataType;
32 use crate::scalars::{ScalarVector, ScalarVectorBuilder};
33 use crate::serialize::Serializable;
34 use crate::types::DateType;
35 use crate::value::{Value, ValueRef};
36 use crate::vectors::{Vector, VectorRef};
37
38 #[test]
39 fn test_build_date_vector() {
40 let mut builder = DateVectorBuilder::with_capacity(4);
41 builder.push(Some(Date::new(1)));
42 builder.push(None);
43 builder.push(Some(Date::new(-1)));
44 let vector = builder.finish();
45 assert_eq!(3, vector.len());
46 assert_eq!(Value::Date(Date::new(1)), vector.get(0));
47 assert_eq!(ValueRef::Date(Date::new(1)), vector.get_ref(0));
48 assert_eq!(Some(Date::new(1)), vector.get_data(0));
49 assert_eq!(None, vector.get_data(1));
50 assert_eq!(Value::Null, vector.get(1));
51 assert_eq!(ValueRef::Null, vector.get_ref(1));
52 assert_eq!(Some(Date::new(-1)), vector.get_data(2));
53 let mut iter = vector.iter_data();
54 assert_eq!(Some(Date::new(1)), iter.next().unwrap());
55 assert_eq!(None, iter.next().unwrap());
56 assert_eq!(Some(Date::new(-1)), iter.next().unwrap());
57 }
58
59 #[test]
60 fn test_date_scalar() {
61 let vector = DateVector::from_slice([1, 2]);
62 assert_eq!(2, vector.len());
63 assert_eq!(Some(Date::new(1)), vector.get_data(0));
64 assert_eq!(Some(Date::new(2)), vector.get_data(1));
65 }
66
67 #[test]
68 fn test_date_vector_builder() {
69 let input = DateVector::from_slice([1, 2, 3]);
70
71 let mut builder = DateType.create_mutable_vector(3);
72 builder.push_value_ref(ValueRef::Date(Date::new(5)));
73 assert!(builder.try_push_value_ref(ValueRef::Int32(123)).is_err());
74 builder.extend_slice_of(&input, 1, 2).unwrap();
75 assert!(
76 builder
77 .extend_slice_of(&crate::vectors::Int32Vector::from_slice([13]), 0, 1)
78 .is_err()
79 );
80 let vector = builder.to_vector();
81
82 let expect: VectorRef = Arc::new(DateVector::from_slice([5, 2, 3]));
83 assert_eq!(expect, vector);
84 }
85
86 #[test]
87 fn test_date_from_arrow() {
88 let vector = DateVector::from_slice([1, 2]);
89 let arrow: ArrayRef = Arc::new(vector.as_arrow().slice(0, vector.len()));
90 let vector2 = DateVector::try_from_arrow_array(&arrow).unwrap();
91 assert_eq!(vector, vector2);
92 }
93
94 #[test]
95 fn test_serialize_date_vector() {
96 let vector = DateVector::from_slice([-1, 0, 1]);
97 let serialized_json = serde_json::to_string(&vector.serialize_to_json().unwrap()).unwrap();
98 assert_eq!(
99 r#"["1969-12-31","1970-01-01","1970-01-02"]"#,
100 serialized_json
101 );
102 }
103}