diff --git a/src/datatypes/src/value.rs b/src/datatypes/src/value.rs index bd5c47b64b..4868eb4cd4 100644 --- a/src/datatypes/src/value.rs +++ b/src/datatypes/src/value.rs @@ -340,7 +340,7 @@ impl GeometryValue { GeometryValueRef::Ref { val: self } } - pub fn from_str(s: &str) -> Result { + pub fn from_wkb(s: &str) -> Result { let wktls: Wkt = Wkt::from_str(s).unwrap(); match wktls.item { Geometry::Point(_) => { diff --git a/src/sql/src/statements.rs b/src/sql/src/statements.rs index 1fd530cc23..1266e86fb5 100644 --- a/src/sql/src/statements.rs +++ b/src/sql/src/statements.rs @@ -8,7 +8,6 @@ pub mod statement; use std::str::FromStr; use common_time::Timestamp; -use datatypes::data_type::DataType; use datatypes::prelude::ConcreteDataType; use datatypes::schema::{ColumnDefaultConstraint, ColumnSchema}; use datatypes::types::{DateTimeType, GeometryType}; @@ -94,8 +93,8 @@ fn parse_string_to_value( .fail() } } - ConcreteDataType::Geometry(t) => { - if let Ok(geo_value) = GeometryValue::from_str(&s) { + ConcreteDataType::Geometry(_) => { + if let Ok(geo_value) = GeometryValue::from_wkb(&s) { Ok(Value::Geometry(geo_value)) } else { ParseSqlValueSnafu {