#[macro_use] extern crate maplit; use cdrs_tokio::authenticators::StaticPasswordAuthenticatorProvider; use cdrs_tokio::cluster::session::{Session, SessionBuilder, TcpSessionBuilder}; use cdrs_tokio::cluster::{NodeTcpConfigBuilder, TcpConnectionManager}; use cdrs_tokio::frame::TryFromRow; use cdrs_tokio::load_balancing::RoundRobinLoadBalancingStrategy; use cdrs_tokio::query::*; use cdrs_tokio::query_values; use cdrs_tokio::transport::TransportTcp; use cdrs_tokio::{IntoCdrsValue, TryFromRow, TryFromUdt}; use std::collections::HashMap; use std::sync::Arc; type CurrentSession = Session< TransportTcp, TcpConnectionManager, RoundRobinLoadBalancingStrategy, >; #[tokio::main] async fn main() { let user = "user"; let password = "password"; let auth = StaticPasswordAuthenticatorProvider::new(&user, &password); let cluster_config = NodeTcpConfigBuilder::new() .with_contact_point("127.0.0.1:9042".into()) .with_authenticator_provider(Arc::new(auth)) .build() .await .unwrap(); let mut session: CurrentSession = TcpSessionBuilder::new(RoundRobinLoadBalancingStrategy::new(), cluster_config) .build() .await .unwrap(); create_keyspace(&mut session).await; create_udt(&mut session).await; create_table(&mut session).await; insert_struct(&mut session).await; append_list(&mut session).await; prepend_list(&mut session).await; append_set(&mut session).await; append_map(&mut session).await; select_struct(&mut session).await; delete_struct(&mut session).await; } #[derive(Clone, Debug, IntoCdrsValue, TryFromRow, PartialEq)] struct RowStruct { key: i32, map: HashMap, list: Vec, cset: Vec, } impl RowStruct { fn into_query_values(self) -> QueryValues { query_values!("key" => self.key, "map" => self.map, "list" => self.list, "cset" => self.cset) } } #[derive(Debug, Clone, PartialEq, IntoCdrsValue, TryFromUdt)] struct User { username: String, } async fn create_keyspace(session: &mut CurrentSession) { let create_ks: &'static str = "CREATE KEYSPACE IF NOT EXISTS test_ks WITH REPLICATION = { \ 'class' : 'SimpleStrategy', 'replication_factor' : 1 };"; session .query(create_ks) .await .expect("Keyspace creation error"); } async fn create_udt(session: &mut CurrentSession) { let create_type_cql = "CREATE TYPE IF NOT EXISTS test_ks.user (username text)"; session .query(create_type_cql) .await .expect("Keyspace creation error"); } async fn create_table(session: &mut CurrentSession) { let create_table_cql = "CREATE TABLE IF NOT EXISTS test_ks.collection_table (key int PRIMARY KEY, \ user frozen, map map>, \ list list>, cset set>);"; session .query(create_table_cql) .await .expect("Table creation error"); } async fn append_list(session: &mut CurrentSession) { let key = 3i32; let extra_values = vec![ User { username: "William".to_string(), }, User { username: "Averel".to_string(), }, ]; let append_list_cql = "UPDATE test_ks.collection_table SET list = list + ? \ WHERE key = ?"; session .query_with_values(append_list_cql, query_values!(extra_values, key)) .await .expect("append list"); } async fn prepend_list(session: &mut CurrentSession) { let key = 3i32; let extra_values = vec![ User { username: "Joe".to_string(), }, User { username: "Jack".to_string(), }, ]; let prepend_list_cql = "UPDATE test_ks.collection_table SET list = ? + list \ WHERE key = ?"; session .query_with_values(prepend_list_cql, query_values!(extra_values, key)) .await .expect("prepend list"); } async fn append_set(session: &mut CurrentSession) { let key = 3i32; let extra_values = vec![ User { username: "William".to_string(), }, User { username: "Averel".to_string(), }, ]; let append_set_cql = "UPDATE test_ks.collection_table SET cset = cset + ? \ WHERE key = ?"; session .query_with_values(append_set_cql, query_values!(extra_values, key)) .await .expect("append set"); } async fn append_map(session: &mut CurrentSession) { let key = 3i32; let extra_values = hashmap![ "Joe".to_string() => User { username: "Joe".to_string() }, "Jack".to_string() => User { username: "Jack".to_string() }, ]; let append_map_cql = "UPDATE test_ks.collection_table SET map = map + ? \ WHERE key = ?"; session .query_with_values(append_map_cql, query_values!(extra_values, key)) .await .expect("append map"); } async fn insert_struct(session: &mut CurrentSession) { let row = RowStruct { key: 3i32, map: hashmap! { "John".to_string() => User { username: "John".to_string() } }, list: vec![User { username: "John".to_string(), }], cset: vec![User { username: "John".to_string(), }], }; let insert_struct_cql = "INSERT INTO test_ks.collection_table \ (key, map, list, cset) VALUES (?, ?, ?, ?)"; session .query_with_values(insert_struct_cql, row.into_query_values()) .await .expect("insert"); } async fn select_struct(session: &mut CurrentSession) { let select_struct_cql = "SELECT * FROM test_ks.collection_table"; let rows = session .query(select_struct_cql) .await .expect("query") .response_body() .expect("get body") .into_rows() .expect("into rows"); for row in rows { let my_row: RowStruct = RowStruct::try_from_row(row).expect("into RowStruct"); println!("struct got: {my_row:#?}"); } } async fn delete_struct(session: &mut CurrentSession) { let delete_struct_cql = "DELETE FROM test_ks.collection_table WHERE key = ?"; let user_key = 3i32; session .query_with_values(delete_struct_cql, query_values!(user_key)) .await .expect("delete"); }