datatypes/vectors/
date.rs

1// Copyright 2023 Greptime Team
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use crate::types::DateType;
16use crate::vectors::{PrimitiveVector, PrimitiveVectorBuilder};
17
18// Vector for [`Date`](common_time::Date).
19pub type DateVector = PrimitiveVector<DateType>;
20// Builder to build DateVector.
21pub 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!(builder
76            .extend_slice_of(&crate::vectors::Int32Vector::from_slice([13]), 0, 1)
77            .is_err());
78        let vector = builder.to_vector();
79
80        let expect: VectorRef = Arc::new(DateVector::from_slice([5, 2, 3]));
81        assert_eq!(expect, vector);
82    }
83
84    #[test]
85    fn test_date_from_arrow() {
86        let vector = DateVector::from_slice([1, 2]);
87        let arrow: ArrayRef = Arc::new(vector.as_arrow().slice(0, vector.len()));
88        let vector2 = DateVector::try_from_arrow_array(&arrow).unwrap();
89        assert_eq!(vector, vector2);
90    }
91
92    #[test]
93    fn test_serialize_date_vector() {
94        let vector = DateVector::from_slice([-1, 0, 1]);
95        let serialized_json = serde_json::to_string(&vector.serialize_to_json().unwrap()).unwrap();
96        assert_eq!(
97            r#"["1969-12-31","1970-01-01","1970-01-02"]"#,
98            serialized_json
99        );
100    }
101}
datatypes/vectors/date.rs

datatypes/vectors/
date.rs
