client.query("DROP TABLE IF EXISTS some").execute().await?;

let mut cursor = client
    .watch("SELECT max(no), argMax(name, no) FROM some")
    .fetch::<Row<'_>>()?;

let (version, row) = cursor.next().await?.unwrap();
println!("live view updated: version={}, row={:?}", version, row);

// Use `only_events()` to iterate over versions only.
let mut cursor = client.watch("some_live_view").limit(20).only_events().fetch()?;
println!("live view updated: version={:?}", cursor.next().await?);

请参阅 示例。

功能标志

• lz4（默认启用）— 启用 Compression::Lz4 和 Compression::Lz4Hc(_) 变体。如果启用，默认情况下使用 Compression::Lz4 对所有查询进行处理，除了 WATCH。
• tls（默认启用）— 支持以 HTTPS 为主干的 URL。
• inserter— 启用 client.inserter()。
• test-util— 添加模拟。见 示例。仅在使用 dev-dependencies 时使用。
• watch— 启用 client.watch 功能。详见相应部分。
• uuid— 为与 uuid 包协同工作，添加 serde::uuid。
• time— 为与 time 包协同工作，添加 serde::time。

数据类型

• (U)Int(8|16|32|64|128) 映射到/从对应的 (u|i)(8|16|32|64|128) 类型或其周围的新类型。

• (U)Int256 不直接支持，但有 一个解决方案。

• Float(32|64) 映射到/从对应的 f(32|64) 或其周围的新类型。

• Decimal(32|64|128) 映射到/从对应的 i(32|64|128) 或其周围的新类型。使用 fixnum 或其他有符号定点数的实现会更方便。

• Boolean 映射到/从 bool 或其周围的新类型。

• String 可以映射到任何字符串或字节类型，例如 &str，&[u8]，String，Vec<u8> 或 SmartString。也支持新类型。为了存储字节，可以考虑使用 serde_bytes，因为它更高效。

  示例

  #[derive(Row, Debug, Serialize, Deserialize)]
  struct MyRow<'a> {
      str: &'a str,
      string: String,
      #[serde(with = "serde_bytes")]
      bytes: Vec<u8>,
      #[serde(with = "serde_bytes")]
      byte_slice: &'a [u8],
  }
  

• FixedString(_) 目前还不支持。

• Enum(8|16) 通过使用 serde_repr 支持。

  示例

  use serde_repr::{Deserialize_repr, Serialize_repr};
  
  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      level: Level,
  }
  
  #[derive(Debug, Serialize_repr, Deserialize_repr)]
  #[repr(u8)]
  enum Level {
      Debug = 1,
      Info = 2,
      Warn = 3,
      Error = 4,
  }
  

• UUID 通过使用 serde::uuid 映射到/从 uuid::Uuid。需要 uuid 功能。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      #[serde(with = "clickhouse::serde::uuid")]
      uuid: uuid::Uuid,
  }
  

• IPv6 映射到/从 std::net::Ipv6Addr。

• IPv4 通过使用 serde::ipv4 映射到/从 std::net::Ipv4Addr。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      #[serde(with = "clickhouse::serde::ipv4")]
      ipv4: std::net::Ipv4Addr,
  }
  

• Date 映射到/从 u16 或围绕它的新类型，并代表自 1970-01-01 以来经过的天数。另外，通过使用 serde::time::date 支持 time::Date，该功能需要 time 功能。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      days: u16,
      #[serde(with = "clickhouse::serde::time::date")]
      date: Date,
  }
  

• Date32 映射到/从 i32 或围绕它的新类型，并代表自 1970-01-01 以来经过的天数。另外，通过使用 serde::time::date32 支持 time::Date，该功能需要 time 功能。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      days: i32,
      #[serde(with = "clickhouse::serde::time::date32")]
      date: Date,
  }
  

• DateTime 映射到/从 u32 或围绕它的新类型，并代表自 UNIX 纪元以来经过的秒数。另外，通过使用 serde::time::datetime 支持 time::OffsetDateTime，该功能需要 time 功能。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      ts: u32,
      #[serde(with = "clickhouse::serde::time::datetime")]
      dt: OffsetDateTime,
  }
  

• DateTime64(_) 映射到/从 i32 或其新类型，并代表自 UNIX 纪元以来的时间流逝。此外，通过使用 serde::time::datetime64::* 支持 time::OffsetDateTime，这需要 time 功能。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      ts: i64, // elapsed s/us/ms/ns depending on `DateTime64(X)`
      #[serde(with = "clickhouse::serde::time::datetime64::secs")]
      dt64s: OffsetDateTime,  // `DateTime64(0)`
      #[serde(with = "clickhouse::serde::time::datetime64::millis")]
      dt64ms: OffsetDateTime, // `DateTime64(3)`
      #[serde(with = "clickhouse::serde::time::datetime64::micros")]
      dt64us: OffsetDateTime, // `DateTime64(6)`
      #[serde(with = "clickhouse::serde::time::datetime64::nanos")]
      dt64ns: OffsetDateTime, // `DateTime64(9)`
  }
  

• Typle(A, B, ...) 映射到/从 (A, B, ...) 或其新类型。

• Array(_) 映射到/从任何切片，例如 Vec<_>，&[_]。也支持新类型。

• Map(K, V) 的行为类似于 Array((K, V))。

• LowCardinality(_) 支持无缝。

• Nullable(_) 映射到/从 Option<_>。对于 clickhouse::serde::* 辅助程序添加 ::option。

  示例

  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      #[serde(with = "clickhouse::serde::ipv4::option")]
      ipv4_opt: Option<Ipv4Addr>,
  }
  

• Nested 通过提供多个带重命名的数组来支持。

  示例

  // CREATE TABLE test(items Nested(name String, count UInt32))
  #[derive(Row, Serialize, Deserialize)]
  struct MyRow {
      #[serde(rename = "items.name")]
      items_name: Vec<String>,
      #[serde(rename = "items.count")]
      items_count: Vec<u32>,
  }
  

• JSON 和 Geo 目前不支持。