#mooncql

#能力

• v5 外层帧与消息 envelope 分层；CRC24 帧头校验、带 Cassandra 固定前缀的 CRC32 载荷校验。
• 普通帧、LZ4 压缩帧、协商压缩后的原始载荷、大消息分片重组、单帧多消息与 TCP 拆包。
• OPTIONS／STARTUP 握手、无认证及 PasswordAuthenticator；在 READY／AUTHENTICATE 后切换帧格式。
• 参数化 QUERY、命名绑定、PREPARE／EXECUTE，以及 logged／unlogged／counter BATCH。
• 按请求指定 keyspace、32 位查询标志、now_in_seconds、一致性级别、串行一致性和默认时间戳。
• 每连接最多缓存 64 条预处理语句，缓存区分 keyspace；传递结果元数据 ID，并处理元数据变化通知。
• stream id 多路复用、有界在途请求、写入串行化及作用域内的连接生命周期。
• 普通查询和预处理查询的惰性分页；空页仍按 paging state 继续，绑定值与命名列表保持快照。
• 中文文本、blob、布尔、整数、浮点、UUID、timeuuid、inet、日期、时间与 duration。
• bigint／timestamp 使用 Int64；decimal 与 varint 保留精确的有符号字节表示。
• list／set／map、tuple、UDT，预处理绑定校验与嵌套上限。
• 服务端结构化错误，包括读写失败原因映射和 CAS 争用信息；保留 warnings、tracing id、custom payload。

#快速运行

docker compose up -d --wait
moon run cmd/main

$env:CQL_PORT = '9042'
$env:CQL_COMPRESSION = 'lz4'
moon run cmd/main

#库用法

async fn main {
  @client.with_connection(
    config=@client.Config::new(compression=true),
    connection => {
      let statement = connection.prepare(
        "SELECT id, message FROM events WHERE device=?",
        keyspace="app",
      )
      let pages = statement.pages(
        [Integer(42)],
        options=@protocol.QueryOptions::new(page_size=100, skip_metadata=true),
      )
      while pages.next() is Some(page) {
        for i = 0; i < page.rows.length(); i = i + 1 {
          // 按应用需要匹配 Text、Null 等值类型。
          ignore(page.get(i, "message"))
        }
      }
    },
  )
}

#失败语义与边界

#验证

moon check --target native --deny-warn
moon test --target native --deny-warn
moon info
moon fmt --check

moon run cmd/integration
python -m pip install -r scripts/requirements-reference.txt
python scripts/interop.py

#参考与许可

• Apache CQL binary protocol v5
• Apache Cassandra framing
• LZ4 block format
• MoonBit async