From b1b1ab3951bcca87de9af09ea291421dba43ace6 Mon Sep 17 00:00:00 2001 From: Nick Sippl-Swezey Date: Tue, 17 Oct 2023 11:27:46 -0700 Subject: [PATCH] change ks to example_ks and change table names to example file name where appropriate --- examples/allocations.rs | 8 ++++---- examples/auth.rs | 4 ++-- examples/basic.rs | 16 ++++++++-------- examples/cloud.rs | 4 ++-- examples/compare-tokens.rs | 10 +++++----- examples/cql-time-types.rs | 24 ++++++++++++------------ examples/custom_deserialization.rs | 10 +++++----- examples/execution_profile.rs | 12 ++++++------ examples/get_by_name.rs | 10 +++++----- examples/logging.rs | 4 ++-- examples/parallel-prepared.rs | 6 +++--- examples/parallel.rs | 6 +++--- examples/query_history.rs | 8 ++++---- examples/schema_agreement.rs | 12 ++++++------ examples/select-paging.rs | 12 ++++++------ examples/speculative-execution.rs | 6 +++--- examples/tls.rs | 12 ++++++------ examples/tracing.rs | 8 ++++---- examples/user-defined-type.rs | 10 +++++----- examples/value_list.rs | 10 +++++----- 20 files changed, 96 insertions(+), 96 deletions(-) diff --git a/examples/allocations.rs b/examples/allocations.rs index deac274a31..3148bb51c2 100644 --- a/examples/allocations.rs +++ b/examples/allocations.rs @@ -131,12 +131,12 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(args.node).build().await?; let session = Arc::new(session); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session.await_schema_agreement().await.unwrap(); session .query( - "CREATE TABLE IF NOT EXISTS ks.alloc_test (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.allocations (a int, b int, c text, primary key (a, b))", &[], ) .await?; @@ -145,13 +145,13 @@ async fn main() -> Result<()> { let prepared_inserts = Arc::new( session - .prepare("INSERT INTO ks.alloc_test (a, b, c) VALUES (?, ?, 'abc')") + .prepare("INSERT INTO examples_ks.allocations (a, b, c) VALUES (?, ?, 'abc')") .await?, ); let prepared_selects = Arc::new( session - .prepare("SELECT * FROM ks.alloc_test WHERE a = ? and b = ?") + .prepare("SELECT * FROM examples_ks.allocations WHERE a = ? and b = ?") .await?, ); diff --git a/examples/auth.rs b/examples/auth.rs index 9b5953b9c0..982ccf5d3a 100644 --- a/examples/auth.rs +++ b/examples/auth.rs @@ -14,9 +14,9 @@ async fn main() -> Result<()> { .await .unwrap(); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await.unwrap(); + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await.unwrap(); session - .query("DROP TABLE IF EXISTS ks.t;", &[]) + .query("DROP TABLE IF EXISTS examples_ks.auth;", &[]) .await .unwrap(); diff --git a/examples/basic.rs b/examples/basic.rs index 01fb4848b0..8e49a16aa7 100644 --- a/examples/basic.rs +++ b/examples/basic.rs @@ -12,25 +12,25 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.basic (a int, b int, c text, primary key (a, b))", &[], ) .await?; session - .query("INSERT INTO ks.t (a, b, c) VALUES (?, ?, ?)", (3, 4, "def")) + .query("INSERT INTO examples_ks.basic (a, b, c) VALUES (?, ?, ?)", (3, 4, "def")) .await?; session - .query("INSERT INTO ks.t (a, b, c) VALUES (1, 2, 'abc')", &[]) + .query("INSERT INTO examples_ks.basic (a, b, c) VALUES (1, 2, 'abc')", &[]) .await?; let prepared = session - .prepare("INSERT INTO ks.t (a, b, c) VALUES (?, 7, ?)") + .prepare("INSERT INTO examples_ks.basic (a, b, c) VALUES (?, 7, ?)") .await?; session .execute(&prepared, (42_i32, "I'm prepared!")) @@ -43,7 +43,7 @@ async fn main() -> Result<()> { .await?; // Rows can be parsed as tuples - if let Some(rows) = session.query("SELECT a, b, c FROM ks.t", &[]).await?.rows { + if let Some(rows) = session.query("SELECT a, b, c FROM examples_ks.basic", &[]).await?.rows { for row in rows.into_typed::<(i32, i32, String)>() { let (a, b, c) = row?; println!("a, b, c: {}, {}, {}", a, b, c); @@ -58,7 +58,7 @@ async fn main() -> Result<()> { _c: String, } - if let Some(rows) = session.query("SELECT a, b, c FROM ks.t", &[]).await?.rows { + if let Some(rows) = session.query("SELECT a, b, c FROM examples_ks.basic", &[]).await?.rows { for row_data in rows.into_typed::() { let row_data = row_data?; println!("row_data: {:?}", row_data); @@ -66,7 +66,7 @@ async fn main() -> Result<()> { } // Or simply as untyped rows - if let Some(rows) = session.query("SELECT a, b, c FROM ks.t", &[]).await?.rows { + if let Some(rows) = session.query("SELECT a, b, c FROM examples_ks.basic", &[]).await?.rows { for row in rows { let a = row.columns[0].as_ref().unwrap().as_int().unwrap(); let b = row.columns[1].as_ref().unwrap().as_int().unwrap(); diff --git a/examples/cloud.rs b/examples/cloud.rs index 99bb85314d..e469ae3241 100644 --- a/examples/cloud.rs +++ b/examples/cloud.rs @@ -16,10 +16,10 @@ async fn main() -> Result<()> { .await .unwrap(); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await.unwrap(); session - .query("DROP TABLE IF EXISTS ks.t;", &[]) + .query("DROP TABLE IF EXISTS examples_ks.cloud;", &[]) .await .unwrap(); diff --git a/examples/compare-tokens.rs b/examples/compare-tokens.rs index 9b2c18b7d7..8dbd491f37 100644 --- a/examples/compare-tokens.rs +++ b/examples/compare-tokens.rs @@ -13,20 +13,20 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.compare_tokens_example (pk bigint primary key)", + "CREATE TABLE IF NOT EXISTS examples_ks.compare_tokens (pk bigint primary key)", &[], ) .await?; - let prepared = session.prepare("INSERT INTO ks.compare_tokens_example (pk) VALUES (?)").await?; + let prepared = session.prepare("INSERT INTO examples_ks.compare_tokens (pk) VALUES (?)").await?; for pk in (0..100_i64).chain(99840..99936_i64) { session - .query("INSERT INTO ks.compare_tokens_example (pk) VALUES (?)", (pk,)) + .query("INSERT INTO ks.compare_tokens (pk) VALUES (?)", (pk,)) .await?; let serialized_pk = (pk,).serialized()?.into_owned(); @@ -43,7 +43,7 @@ async fn main() -> Result<()> { ); let qt = session - .query(format!("SELECT token(pk) FROM ks.compare_tokens_example where pk = {}", pk), &[]) + .query(format!("SELECT token(pk) FROM ks.compare_tokens where pk = {}", pk), &[]) .await? .rows .unwrap() diff --git a/examples/cql-time-types.rs b/examples/cql-time-types.rs index ac4da4831e..b6ebdeef15 100644 --- a/examples/cql-time-types.rs +++ b/examples/cql-time-types.rs @@ -17,14 +17,14 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; // Date // Date is a year, month and day in the range -5877641-06-23 to -5877641-06-23 session .query( - "CREATE TABLE IF NOT EXISTS ks.dates (d date primary key)", + "CREATE TABLE IF NOT EXISTS examples_ks.dates (d date primary key)", &[], ) .await?; @@ -33,10 +33,10 @@ async fn main() -> Result<()> { let example_date: NaiveDate = NaiveDate::from_ymd_opt(2020, 2, 20).unwrap(); session - .query("INSERT INTO ks.dates (d) VALUES (?)", (example_date,)) + .query("INSERT INTO examples_ks.dates (d) VALUES (?)", (example_date,)) .await?; - if let Some(rows) = session.query("SELECT d from ks.dates", &[]).await?.rows { + if let Some(rows) = session.query("SELECT d from examples_ks.dates", &[]).await?.rows { for row in rows.into_typed::<(NaiveDate,)>() { let (read_date,): (NaiveDate,) = match row { Ok(read_date) => read_date, @@ -50,10 +50,10 @@ async fn main() -> Result<()> { // Dates outside this range must be represented in the raw form - an u32 describing days since -5877641-06-23 let example_big_date: Date = Date(u32::MAX); session - .query("INSERT INTO ks.dates (d) VALUES (?)", (example_big_date,)) + .query("INSERT INTO examples_ks.dates (d) VALUES (?)", (example_big_date,)) .await?; - if let Some(rows) = session.query("SELECT d from ks.dates", &[]).await?.rows { + if let Some(rows) = session.query("SELECT d from examples_ks.dates", &[]).await?.rows { for row in rows { let read_days: u32 = match row.columns[0] { Some(CqlValue::Date(days)) => days, @@ -69,17 +69,17 @@ async fn main() -> Result<()> { session .query( - "CREATE TABLE IF NOT EXISTS ks.times (t time primary key)", + "CREATE TABLE IF NOT EXISTS examples_ks.times (t time primary key)", &[], ) .await?; // Time as bound value must be wrapped in value::Time to differentiate from Timestamp session - .query("INSERT INTO ks.times (t) VALUES (?)", (Time(example_time),)) + .query("INSERT INTO examples_ks.times (t) VALUES (?)", (Time(example_time),)) .await?; - if let Some(rows) = session.query("SELECT t from ks.times", &[]).await?.rows { + if let Some(rows) = session.query("SELECT t from examples_ks.times", &[]).await?.rows { for row in rows.into_typed::<(Duration,)>() { let (read_time,): (Duration,) = row?; @@ -92,7 +92,7 @@ async fn main() -> Result<()> { session .query( - "CREATE TABLE IF NOT EXISTS ks.timestamps (t timestamp primary key)", + "CREATE TABLE IF NOT EXISTS examples_ks.timestamps (t timestamp primary key)", &[], ) .await?; @@ -100,13 +100,13 @@ async fn main() -> Result<()> { // Timestamp as bound value must be wrapped in value::Timestamp to differentiate from Time session .query( - "INSERT INTO ks.timestamps (t) VALUES (?)", + "INSERT INTO examples_ks.timestamps (t) VALUES (?)", (Timestamp(example_timestamp),), ) .await?; if let Some(rows) = session - .query("SELECT t from ks.timestamps", &[]) + .query("SELECT t from examples_ks.timestamps", &[]) .await? .rows { diff --git a/examples/custom_deserialization.rs b/examples/custom_deserialization.rs index 3eb40ee7f1..f18b89db6f 100644 --- a/examples/custom_deserialization.rs +++ b/examples/custom_deserialization.rs @@ -13,16 +13,16 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.custom_deserialization (pk int primary key, v text)", + "CREATE TABLE IF NOT EXISTS examples_ks.custom_deserialization (pk int primary key, v text)", &[], ) .await?; session - .query("INSERT INTO ks.custom_deserialization (pk, v) VALUES (1, 'asdf')", ()) + .query("INSERT INTO examples_ks.custom_deserialization (pk, v) VALUES (1, 'asdf')", ()) .await?; // You can implement FromCqlVal for your own types @@ -38,7 +38,7 @@ async fn main() -> Result<()> { } let (v,) = session - .query("SELECT v FROM ks.custom_deserialization WHERE pk = 1", ()) + .query("SELECT v FROM examples_ks.custom_deserialization WHERE pk = 1", ()) .await? .single_row_typed::<(MyType,)>()?; assert_eq!(v, MyType("asdf".to_owned())); @@ -62,7 +62,7 @@ async fn main() -> Result<()> { impl_from_cql_value_from_method!(MyOtherType, into_my_other_type); let (v,) = session - .query("SELECT v FROM ks.custom_deserialization WHERE pk = 1", ()) + .query("SELECT v FROM examples_ks.custom_deserialization WHERE pk = 1", ()) .await? .single_row_typed::<(MyOtherType,)>()?; assert_eq!(v, MyOtherType("asdf".to_owned())); diff --git a/examples/execution_profile.rs b/examples/execution_profile.rs index d8d1b1eed9..b03969acf1 100644 --- a/examples/execution_profile.rs +++ b/examples/execution_profile.rs @@ -59,16 +59,16 @@ async fn main() -> Result<()> { session_3_config.add_known_node(uri); let session3: Session = Session::connect(session_3_config).await?; - session1.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session1.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session2 .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.execution_profile (a int, b int, c text, primary key (a, b))", &[], ) .await?; - let mut query_insert: Query = "INSERT INTO ks.t (a, b, c) VALUES (?, ?, ?)".into(); + let mut query_insert: Query = "INSERT INTO examples_ks.execution_profile (a, b, c) VALUES (?, ?, ?)".into(); // As `query_insert` is set another handle than session1, the execution profile pointed by query's handle // will be preferred, so the query below will be executed with `profile2`, even though `session1` is set `profile1`. @@ -79,12 +79,12 @@ async fn main() -> Result<()> { handle2.map_to_another_profile(profile1); // And now the following queries are executed with profile1: session1.query(query_insert.clone(), (3, 4, "def")).await?; - session2.query("SELECT * FROM ks.t", ()).await?; + session2.query("SELECT * FROM examples_ks.execution_profile", ()).await?; // One can unset a profile handle from a statement and, since then, execute it with session's default profile. query_insert.set_execution_profile_handle(None); - session3.query("SELECT * FROM ks.t", ()).await?; // This executes with default session profile. - session2.query("SELECT * FROM ks.t", ()).await?; // This executes with profile1. + session3.query("SELECT * FROM examples_ks.execution_profile", ()).await?; // This executes with default session profile. + session2.query("SELECT * FROM examples_ks.execution_profile", ()).await?; // This executes with profile1. Ok(()) } diff --git a/examples/get_by_name.rs b/examples/get_by_name.rs index 0b94b1e898..03c14b8721 100644 --- a/examples/get_by_name.rs +++ b/examples/get_by_name.rs @@ -12,31 +12,31 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.hello (pk int, ck int, value text, primary key (pk, ck))", + "CREATE TABLE IF NOT EXISTS examples_ks.get_by_name (pk int, ck int, value text, primary key (pk, ck))", &[], ) .await?; session .query( - "INSERT INTO ks.hello (pk, ck, value) VALUES (?, ?, ?)", + "INSERT INTO examples_ks.get_by_name (pk, ck, value) VALUES (?, ?, ?)", (3, 4, "def"), ) .await?; session .query( - "INSERT INTO ks.hello (pk, ck, value) VALUES (1, 2, 'abc')", + "INSERT INTO examples_ks.get_by_name (pk, ck, value) VALUES (1, 2, 'abc')", &[], ) .await?; let query_result = session - .query("SELECT pk, ck, value FROM ks.hello", &[]) + .query("SELECT pk, ck, value FROM examples_ks.get_by_name", &[]) .await?; let (ck_idx, _) = query_result .get_column_spec("ck") diff --git a/examples/logging.rs b/examples/logging.rs index 0ee57340c7..19b22d73cb 100644 --- a/examples/logging.rs +++ b/examples/logging.rs @@ -17,9 +17,9 @@ async fn main() -> Result<()> { info!("Connecting to {}", uri); let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; - session.query("USE ks", &[]).await?; + session.query("USE examples_ks", &[]).await?; Ok(()) } diff --git a/examples/parallel-prepared.rs b/examples/parallel-prepared.rs index abab78af64..ae2a11e3f0 100644 --- a/examples/parallel-prepared.rs +++ b/examples/parallel-prepared.rs @@ -14,18 +14,18 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; let session = Arc::new(session); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t2 (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.parallel_prepared (a int, b int, c text, primary key (a, b))", &[], ) .await?; let prepared = Arc::new( session - .prepare("INSERT INTO ks.t2 (a, b, c) VALUES (?, ?, 'abc')") + .prepare("INSERT INTO examples_ks.parallel_prepared (a, b, c) VALUES (?, ?, 'abc')") .await?, ); println!("Prepared statement: {:#?}", prepared); diff --git a/examples/parallel.rs b/examples/parallel.rs index e23c560f41..63b22225c9 100644 --- a/examples/parallel.rs +++ b/examples/parallel.rs @@ -14,11 +14,11 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; let session = Arc::new(session); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t2 (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.parallel (a int, b int, c text, primary key (a, b))", &[], ) .await?; @@ -36,7 +36,7 @@ async fn main() -> Result<()> { session .query( format!( - "INSERT INTO ks.t2 (a, b, c) VALUES ({}, {}, 'abc')", + "INSERT INTO examples_ks.parallel (a, b, c) VALUES ({}, {}, 'abc')", i, 2 * i ), diff --git a/examples/query_history.rs b/examples/query_history.rs index f95001c2e3..2e943e5a6d 100644 --- a/examples/query_history.rs +++ b/examples/query_history.rs @@ -17,11 +17,11 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.query_history (a int, b int, c text, primary key (a, b))", &[], ) .await?; @@ -47,11 +47,11 @@ async fn main() -> Result<()> { // The same works for other types of queries, e.g iterators for i in 0..32 { session - .query("INSERT INTO ks.t (a, b, c) VALUES (?, ?, 't')", (i, i)) + .query("INSERT INTO examples_ks.query_history (a, b, c) VALUES (?, ?, 't')", (i, i)) .await?; } - let mut iter_query: Query = Query::new("SELECT * FROM ks.t"); + let mut iter_query: Query = Query::new("SELECT * FROM examples_ks.query_history"); iter_query.set_page_size(8); let iter_history_listener = Arc::new(HistoryCollector::new()); iter_query.set_history_listener(iter_history_listener.clone()); diff --git a/examples/schema_agreement.rs b/examples/schema_agreement.rs index 08e5a59384..6f2a769057 100644 --- a/examples/schema_agreement.rs +++ b/examples/schema_agreement.rs @@ -22,7 +22,7 @@ async fn main() -> Result<()> { println!("Schema version: {}", schema_version); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; match session.await_schema_agreement().await { Ok(_schema_version) => println!("Schema is in agreement in time"), @@ -31,23 +31,23 @@ async fn main() -> Result<()> { }; session .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.schema_agreement (a int, b int, c text, primary key (a, b))", &[], ) .await?; session.await_schema_agreement().await?; session - .query("INSERT INTO ks.t (a, b, c) VALUES (?, ?, ?)", (3, 4, "def")) + .query("INSERT INTO examples_ks.schema_agreement (a, b, c) VALUES (?, ?, ?)", (3, 4, "def")) .await?; session.await_schema_agreement().await?; session - .query("INSERT INTO ks.t (a, b, c) VALUES (1, 2, 'abc')", &[]) + .query("INSERT INTO examples_ks.schema_agreement (a, b, c) VALUES (1, 2, 'abc')", &[]) .await?; let prepared = session - .prepare("INSERT INTO ks.t (a, b, c) VALUES (?, 7, ?)") + .prepare("INSERT INTO examples_ks.schema_agreement (a, b, c) VALUES (?, 7, ?)") .await?; session .execute(&prepared, (42_i32, "I'm prepared!")) @@ -60,7 +60,7 @@ async fn main() -> Result<()> { .await?; // Rows can be parsed as tuples - if let Some(rows) = session.query("SELECT a, b, c FROM ks.t", &[]).await?.rows { + if let Some(rows) = session.query("SELECT a, b, c FROM examples_ks.schema_agreement", &[]).await?.rows { for row in rows.into_typed::<(i32, i32, String)>() { let (a, b, c) = row?; println!("a, b, c: {}, {}, {}", a, b, c); diff --git a/examples/select-paging.rs b/examples/select-paging.rs index 5386dcf881..8cee4742cb 100644 --- a/examples/select-paging.rs +++ b/examples/select-paging.rs @@ -11,11 +11,11 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.select_paging (a int, b int, c text, primary key (a, b))", &[], ) .await?; @@ -23,7 +23,7 @@ async fn main() -> Result<()> { for i in 0..16_i32 { session .query( - "INSERT INTO ks.t (a, b, c) VALUES (?, ?, 'abc')", + "INSERT INTO examples_ks.select_paging (a, b, c) VALUES (?, ?, 'abc')", (i, 2 * i), ) .await?; @@ -31,7 +31,7 @@ async fn main() -> Result<()> { // Iterate through select result with paging let mut rows_stream = session - .query_iter("SELECT a, b, c FROM ks.t", &[]) + .query_iter("SELECT a, b, c FROM examples_ks.select_paging", &[]) .await? .into_typed::<(i32, i32, String)>(); @@ -40,7 +40,7 @@ async fn main() -> Result<()> { println!("a, b, c: {}, {}, {}", a, b, c); } - let paged_query = Query::new("SELECT a, b, c FROM ks.t").with_page_size(6); + let paged_query = Query::new("SELECT a, b, c FROM examples_ks.select_paging").with_page_size(6); let res1 = session.query(paged_query.clone(), &[]).await?; println!( "Paging state: {:#?} ({} rows)", @@ -65,7 +65,7 @@ async fn main() -> Result<()> { ); let paged_prepared = session - .prepare(Query::new("SELECT a, b, c FROM ks.t").with_page_size(7)) + .prepare(Query::new("SELECT a, b, c FROM examples_ks.select_paging").with_page_size(7)) .await?; let res4 = session.execute(&paged_prepared, &[]).await?; println!( diff --git a/examples/speculative-execution.rs b/examples/speculative-execution.rs index 4f0b3445f9..a0ea2a7dfc 100644 --- a/examples/speculative-execution.rs +++ b/examples/speculative-execution.rs @@ -26,16 +26,16 @@ async fn main() -> Result<()> { .build() .await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.speculative_execution (a int, b int, c text, primary key (a, b))", &[], ) .await?; - let mut select_stmt = session.prepare("SELECT a, b, c FROM ks.t").await?; + let mut select_stmt = session.prepare("SELECT a, b, c FROM examples_ks.speculative_execution").await?; // This will allow for speculative execution select_stmt.set_is_idempotent(true); diff --git a/examples/tls.rs b/examples/tls.rs index 49006c1602..8aa2fb04de 100644 --- a/examples/tls.rs +++ b/examples/tls.rs @@ -49,25 +49,25 @@ async fn main() -> Result<()> { .build() .await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.t (a int, b int, c text, primary key (a, b))", + "CREATE TABLE IF NOT EXISTS examples_ks.tls (a int, b int, c text, primary key (a, b))", &[], ) .await?; session - .query("INSERT INTO ks.t (a, b, c) VALUES (?, ?, ?)", (3, 4, "def")) + .query("INSERT INTO examples_ks.tls (a, b, c) VALUES (?, ?, ?)", (3, 4, "def")) .await?; session - .query("INSERT INTO ks.t (a, b, c) VALUES (1, 2, 'abc')", &[]) + .query("INSERT INTO examples_ks.tls (a, b, c) VALUES (1, 2, 'abc')", &[]) .await?; let prepared = session - .prepare("INSERT INTO ks.t (a, b, c) VALUES (?, 7, ?)") + .prepare("INSERT INTO examples_ks.tls (a, b, c) VALUES (?, 7, ?)") .await?; session .execute(&prepared, (42_i32, "I'm prepared!")) @@ -80,7 +80,7 @@ async fn main() -> Result<()> { .await?; // Rows can be parsed as tuples - if let Some(rows) = session.query("SELECT a, b, c FROM ks.t", &[]).await?.rows { + if let Some(rows) = session.query("SELECT a, b, c FROM examples_ks.tls", &[]).await?.rows { for row in rows.into_typed::<(i32, i32, String)>() { let (a, b, c) = row?; println!("a, b, c: {}, {}, {}", a, b, c); diff --git a/examples/tracing.rs b/examples/tracing.rs index bff0bca94a..e4c9eb8047 100644 --- a/examples/tracing.rs +++ b/examples/tracing.rs @@ -26,18 +26,18 @@ async fn main() -> Result<()> { .build() .await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.tracing_example (val text primary key)", + "CREATE TABLE IF NOT EXISTS examples_ks.tracing (val text primary key)", &[], ) .await?; // QUERY // Create a simple query and enable tracing for it - let mut query: Query = Query::new("SELECT val from ks.tracing_example"); + let mut query: Query = Query::new("SELECT val from examples_ks.tracing"); query.set_tracing(true); query.set_serial_consistency(Some(SerialConsistency::LocalSerial)); @@ -101,7 +101,7 @@ async fn main() -> Result<()> { // BATCH // Create a simple batch and enable tracing let mut batch: Batch = Batch::default(); - batch.append_statement("INSERT INTO ks.tracing_example (val) VALUES('val')"); + batch.append_statement("INSERT INTO examples_ks.tracing (val) VALUES('val')"); batch.set_tracing(true); // Run the batch and print its tracing_id diff --git a/examples/user-defined-type.rs b/examples/user-defined-type.rs index d42429c65e..a1ae9ec705 100644 --- a/examples/user-defined-type.rs +++ b/examples/user-defined-type.rs @@ -11,18 +11,18 @@ async fn main() -> Result<()> { let session: Session = SessionBuilder::new().known_node(uri).build().await?; - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await?; session .query( - "CREATE TYPE IF NOT EXISTS ks.my_type (int_val int, text_val text)", + "CREATE TYPE IF NOT EXISTS examples_ks.my_type (int_val int, text_val text)", &[], ) .await?; session .query( - "CREATE TABLE IF NOT EXISTS ks.udt_tab (k int, my my_type, primary key (k))", + "CREATE TABLE IF NOT EXISTS examples_ks.user_defined_type_table (k int, my my_type, primary key (k))", &[], ) .await?; @@ -42,11 +42,11 @@ async fn main() -> Result<()> { // It can be inserted like a normal value session - .query("INSERT INTO ks.udt_tab (k, my) VALUES (5, ?)", (to_insert,)) + .query("INSERT INTO examples_ks.user_defined_type_table (k, my) VALUES (5, ?)", (to_insert,)) .await?; // And read like any normal value - if let Some(rows) = session.query("SELECT my FROM ks.udt_tab", &[]).await?.rows { + if let Some(rows) = session.query("SELECT my FROM examples_ks.user_defined_type_table", &[]).await?.rows { for row in rows.into_typed::<(MyType,)>() { let (my_val,) = row?; println!("{:?}", my_val) diff --git a/examples/value_list.rs b/examples/value_list.rs index 44b388dcbc..c2ad88d66f 100644 --- a/examples/value_list.rs +++ b/examples/value_list.rs @@ -9,11 +9,11 @@ async fn main() { let session: Session = SessionBuilder::new().known_node(uri).build().await.unwrap(); - session.query("CREATE KEYSPACE IF NOT EXISTS ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await.unwrap(); + session.query("CREATE KEYSPACE IF NOT EXISTS examples_ks WITH REPLICATION = {'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}", &[]).await.unwrap(); session .query( - "CREATE TABLE IF NOT EXISTS ks.my_type (k int, my text, primary key (k))", + "CREATE TABLE IF NOT EXISTS examples_ks.my_type (k int, my text, primary key (k))", &[], ) .await @@ -31,7 +31,7 @@ async fn main() { }; session - .query("INSERT INTO ks.my_type (k, my) VALUES (?, ?)", to_insert) + .query("INSERT INTO examples_ks.my_type (k, my) VALUES (?, ?)", to_insert) .await .unwrap(); @@ -48,12 +48,12 @@ async fn main() { }; session - .query("INSERT INTO ks.my_type (k, my) VALUES (?, ?)", to_insert_2) + .query("INSERT INTO examples_ks.my_type (k, my) VALUES (?, ?)", to_insert_2) .await .unwrap(); let q = session - .query("SELECT * FROM ks.my_type", &[]) + .query("SELECT * FROM examples_ks.my_type", &[]) .await .unwrap();