@@ -200,7 +200,7 @@ impl DataValue {
200200 LogicalType :: Float => DataValue :: Float32 ( None ) ,
201201 LogicalType :: Double => DataValue :: Float64 ( None ) ,
202202 LogicalType :: Varchar => DataValue :: Utf8 ( None ) ,
203- LogicalType :: Date => DataValue :: Date64 ( None )
203+ LogicalType :: DateTime => DataValue :: Date64 ( None )
204204 }
205205 }
206206
@@ -220,7 +220,7 @@ impl DataValue {
220220 LogicalType :: Float => DataValue :: Float32 ( Some ( 0.0 ) ) ,
221221 LogicalType :: Double => DataValue :: Float64 ( Some ( 0.0 ) ) ,
222222 LogicalType :: Varchar => DataValue :: Utf8 ( Some ( "" . to_string ( ) ) ) ,
223- LogicalType :: Date => DataValue :: Date64 ( Some ( UNIX_DATETIME . timestamp ( ) ) )
223+ LogicalType :: DateTime => DataValue :: Date64 ( Some ( UNIX_DATETIME . timestamp ( ) ) )
224224 }
225225 }
226226
@@ -267,7 +267,7 @@ impl DataValue {
267267 f64:: from_ne_bytes ( buf)
268268 } ) ) ,
269269 LogicalType :: Varchar => DataValue :: Utf8 ( ( !bytes. is_empty ( ) ) . then ( || String :: from_utf8 ( bytes. to_owned ( ) ) . unwrap ( ) ) ) ,
270- LogicalType :: Date => DataValue :: Date64 ( ( !bytes. is_empty ( ) ) . then ( || i64:: decode_fixed ( bytes) ) ) ,
270+ LogicalType :: DateTime => DataValue :: Date64 ( ( !bytes. is_empty ( ) ) . then ( || i64:: decode_fixed ( bytes) ) ) ,
271271 }
272272 }
273273
@@ -286,7 +286,7 @@ impl DataValue {
286286 DataValue :: UInt32 ( _) => LogicalType :: UInteger ,
287287 DataValue :: UInt64 ( _) => LogicalType :: UBigint ,
288288 DataValue :: Utf8 ( _) => LogicalType :: Varchar ,
289- DataValue :: Date64 ( _) => LogicalType :: Date ,
289+ DataValue :: Date64 ( _) => LogicalType :: DateTime ,
290290 }
291291 }
292292
@@ -308,7 +308,7 @@ impl DataValue {
308308 LogicalType :: Float => DataValue :: Float32 ( None ) ,
309309 LogicalType :: Double => DataValue :: Float64 ( None ) ,
310310 LogicalType :: Varchar => DataValue :: Utf8 ( None ) ,
311- LogicalType :: Date => DataValue :: Date64 ( None ) ,
311+ LogicalType :: DateTime => DataValue :: Date64 ( None ) ,
312312 }
313313 }
314314 DataValue :: Boolean ( value) => {
@@ -327,7 +327,7 @@ impl DataValue {
327327 LogicalType :: Float => DataValue :: Float32 ( value. map ( |v| v. into ( ) ) ) ,
328328 LogicalType :: Double => DataValue :: Float64 ( value. map ( |v| v. into ( ) ) ) ,
329329 LogicalType :: Varchar => DataValue :: Utf8 ( value. map ( |v| format ! ( "{}" , v) ) ) ,
330- LogicalType :: Date => panic ! ( "not support" ) ,
330+ LogicalType :: DateTime => panic ! ( "not support" ) ,
331331 }
332332 }
333333 DataValue :: Float32 ( value) => {
@@ -481,7 +481,7 @@ impl DataValue {
481481 LogicalType :: Float => DataValue :: Float32 ( value. map ( |v| f32:: from_str ( & v) . unwrap ( ) ) ) ,
482482 LogicalType :: Double => DataValue :: Float64 ( value. map ( |v| f64:: from_str ( & v) . unwrap ( ) ) ) ,
483483 LogicalType :: Varchar => DataValue :: Utf8 ( value) ,
484- LogicalType :: Date => {
484+ LogicalType :: DateTime => {
485485 let option = value. map ( |v| {
486486 NaiveDateTime :: parse_from_str ( & v, "%Y-%m-%d %H:%M:%S" )
487487 . unwrap ( )
@@ -497,7 +497,7 @@ impl DataValue {
497497 LogicalType :: Invalid => panic ! ( "invalid logical type" ) ,
498498 LogicalType :: SqlNull => DataValue :: Null ,
499499 LogicalType :: Varchar => DataValue :: Utf8 ( value. map ( |v| format ! ( "{}" , v) ) ) ,
500- LogicalType :: Date => DataValue :: Date64 ( value) ,
500+ LogicalType :: DateTime => DataValue :: Date64 ( value) ,
501501 _ => panic ! ( "not support" ) ,
502502 }
503503 }
0 commit comments