docs: add decimal in rust examples

Author: RaphDal

questdb-rs/examples/basic.rs

@@ -8,15 +8,15 @@ use questdb::{
 fn main() -> Result<()> {
     let host: String = std::env::args().nth(1).unwrap_or("localhost".to_string());
     let port: &str = &std::env::args().nth(2).unwrap_or("9009".to_string());
-    let mut sender = Sender::from_conf(format!("tcp::addr={host}:{port};"))?;
+    let mut sender = Sender::from_conf(format!("tcp::addr={host}:{port};protocol_version=2;"))?;
     let mut buffer = sender.new_buffer();
     let designated_timestamp =
         TimestampNanos::from_datetime(Utc.with_ymd_and_hms(1997, 7, 4, 4, 56, 55).unwrap())?;
     buffer
         .table("trades")?
         .symbol("symbol", "ETH-USD")?
         .symbol("side", "sell")?
-        .column_f64("price", 2615.54)?
+        .column_decimal("price", "2615.54")?
         .column_f64("amount", 0.00044)?
         // QuestDB server version 9.0.0 or later is required for array support.
         .column_arr("location", &arr1(&[100.0, 100.1, 100.2]).view())?

questdb-rs/examples/http.rs

@@ -1,17 +1,23 @@
+use std::str::FromStr;
+
 use ndarray::arr1;
 use questdb::{
     ingress::{Sender, TimestampNanos},
     Result,
 };
+use rust_decimal::Decimal;
 
 fn main() -> Result<()> {
-    let mut sender = Sender::from_conf("https::addr=localhost:9000;username=foo;password=bar;")?;
+    let mut sender = Sender::from_conf(
+        "https::addr=localhost:9000;username=foo;password=bar;protocol_version=2;",
+    )?;
     let mut buffer = sender.new_buffer();
+    let price = Decimal::from_str("2615.54").unwrap();
     buffer
         .table("trades")?
         .symbol("symbol", "ETH-USD")?
         .symbol("side", "sell")?
-        .column_f64("price", 2615.54)?
+        .column_decimal("price", &price)?
         .column_f64("amount", 0.00044)?
         // QuestDB server version 9.0.0 or later is required for array support.
         .column_arr("location", &arr1(&[100.0, 100.1, 100.2]).view())?

questdb-rs/examples/protocol_version.rs

@@ -1,33 +1,38 @@
+use std::str::FromStr;
+
+use bigdecimal::BigDecimal;
 use ndarray::arr1;
 use questdb::{
     ingress::{Sender, TimestampNanos},
     Result,
 };
 
 fn main() -> Result<()> {
+    let price = BigDecimal::from_str("2615.54").unwrap();
+
     let mut sender = Sender::from_conf(
-        "https::addr=localhost:9000;username=foo;password=bar;protocol_version=1;",
+        "http::addr=localhost:9000;username=foo;password=bar;protocol_version=1;",
     )?;
     let mut buffer = sender.new_buffer();
     buffer
         .table("trades_ilp_v1")?
         .symbol("symbol", "ETH-USD")?
         .symbol("side", "sell")?
-        .column_f64("price", 2615.54)?
+        .column_decimal("price", &price)?
         .column_f64("amount", 0.00044)?
         .at(TimestampNanos::now())?;
     sender.flush(&mut buffer)?;
 
     // QuestDB server version 9.0.0 or later is required for `protocol_version=2` support.
     let mut sender2 = Sender::from_conf(
-        "https::addr=localhost:9000;username=foo;password=bar;protocol_version=2;",
+        "http::addr=localhost:9000;username=foo;password=bar;protocol_version=2;",
     )?;
-    let mut buffer2 = sender.new_buffer();
+    let mut buffer2 = sender2.new_buffer();
     buffer2
         .table("trades_ilp_v2")?
         .symbol("symbol", "ETH-USD")?
         .symbol("side", "sell")?
-        .column_f64("price", 2615.54)?
+        .column_decimal("price", &price)?
         .column_f64("amount", 0.00044)?
         .column_arr("location", &arr1(&[100.0, 100.1, 100.2]).view())?
         .at(TimestampNanos::now())?;