cdrs 2.3.3

Cassandra DB driver written in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

#[cfg(feature = "e2e-tests")]
#[macro_use]
extern crate cdrs;

mod common;

#[cfg(feature = "e2e-tests")]
use common::*;

#[cfg(feature = "e2e-tests")]
use cdrs::query::QueryExecutor;
#[cfg(feature = "e2e-tests")]
use cdrs::types::{AsRust, ByName, IntoRustByName};

#[cfg(feature = "e2e-tests")]
use std::str::FromStr;

#[test]
#[cfg(feature = "e2e-tests")]
fn query_values_in() {
  let cql = "CREATE TABLE IF NOT EXISTS cdrs_test.test_query_values_in \
             (id text PRIMARY KEY)";
  let session = setup(cql).expect("setup");

  session.query(cql).expect("create table error");

  let query_insert = "INSERT INTO cdrs_test.test_query_values_in \
                      (id) VALUES (?)";

  let items = vec!["1".to_string(), "2".to_string(), "3".to_string()];

  for item in items {
    let values = query_values!(item);
    session
      .query_with_values(query_insert, values)
      .expect("insert item error");
  }

  let cql = "SELECT * FROM cdrs_test.test_query_values_in WHERE id IN ?";
  let criteria = vec!["1".to_string(), "3".to_string()];

  let rows = session
    .query_with_values(cql, query_values!(criteria.clone()))
    .expect("select values query error")
    .get_body()
    .expect("get body error")
    .into_rows()
    .expect("converting into rows error");

  assert_eq!(rows.len(), criteria.len());

  let found_all_matching_criteria = criteria.iter().all(|criteria_item: &String| {
    rows.iter().any(|row| {
      let id: String = row.get_r_by_name("id").expect("id");

      criteria_item.clone() == id
    })
  });

  assert!(
    found_all_matching_criteria,
    "should find at least one element for each criteria"
  );
}