diff --git a/influxdb/src/query/line_proto_term.rs b/influxdb/src/query/line_proto_term.rs index 0b82a8b..3d1845a 100644 --- a/influxdb/src/query/line_proto_term.rs +++ b/influxdb/src/query/line_proto_term.rs @@ -43,7 +43,7 @@ impl LineProtoTerm<'_> { .to_string(), Float(v) => v.to_string(), SignedInteger(v) => format!("{}i", v), - UnsignedInteger(v) => format!("{}i", v), + UnsignedInteger(v) => format!("{}u", v), Text(v) => format!(r#""{}""#, Self::escape_any(v, &*QUOTES_SLASHES)), } } diff --git a/influxdb/src/query/write_query.rs b/influxdb/src/query/write_query.rs index e882e5d..d9e8b08 100644 --- a/influxdb/src/query/write_query.rs +++ b/influxdb/src/query/write_query.rs @@ -264,12 +264,13 @@ mod tests { .into_query("weather".to_string()) .add_field("temperature", 82) .add_field("wind_strength", 3.7) + .add_field("temperature_unsigned", 82u64) .build(); assert!(query.is_ok(), "Query was empty"); assert_eq!( query.unwrap(), - "weather temperature=82i,wind_strength=3.7 11" + "weather temperature=82i,wind_strength=3.7,temperature_unsigned=82u 11" ); } @@ -282,7 +283,7 @@ mod tests { .build(); assert!(query.is_ok(), "Query was empty"); - assert_eq!(query.unwrap(), "weather temperature=82i 11"); + assert_eq!(query.unwrap(), "weather temperature=82u 11"); } #[test]