Skip to content

Commit 943251b

Browse files
committed
statement: rename Query -> Statement
1 parent 5d80c93 commit 943251b

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+191
-186
lines changed

docs/source/execution-profiles/create-and-use.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ To create an `ExecutionProfile` and attach it to a `Query`:
3333
# extern crate scylla;
3434
# use std::error::Error;
3535
# async fn check_only_compiles() -> Result<(), Box<dyn Error>> {
36-
use scylla::statement::query::Query;
36+
use scylla::statement::query::Statement;
3737
use scylla::statement::Consistency;
3838
use scylla::client::execution_profile::ExecutionProfile;
3939
use std::time::Duration;
@@ -45,10 +45,10 @@ let profile = ExecutionProfile::builder()
4545

4646
let handle = profile.into_handle();
4747

48-
let mut query1 = Query::from("SELECT * FROM ks.table");
48+
let mut query1 = Statement::from("SELECT * FROM ks.table");
4949
query1.set_execution_profile_handle(Some(handle.clone()));
5050

51-
let mut query2 = Query::from("SELECT pk FROM ks.table WHERE pk = ?");
51+
let mut query2 = Statement::from("SELECT pk FROM ks.table WHERE pk = ?");
5252
query2.set_execution_profile_handle(Some(handle));
5353
# Ok(())
5454
# }

docs/source/execution-profiles/maximal-example.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
# extern crate scylla;
77
# use std::error::Error;
88
# async fn check_only_compiles() -> Result<(), Box<dyn Error>> {
9-
use scylla::statement::query::Query;
9+
use scylla::statement::query::Statement;
1010
use scylla::policies::speculative_execution::SimpleSpeculativeExecutionPolicy;
1111
use scylla::statement::{Consistency, SerialConsistency};
1212
use scylla::client::execution_profile::ExecutionProfile;
@@ -32,7 +32,7 @@ let profile = ExecutionProfile::builder()
3232
)
3333
.build();
3434

35-
let mut query = Query::from("SELECT * FROM ks.table");
35+
let mut query = Statement::from("SELECT * FROM ks.table");
3636
query.set_execution_profile_handle(Some(profile.into_handle()));
3737

3838
# Ok(())

docs/source/execution-profiles/priority.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ Priorities of execution profiles and directly set options:
1515
# async fn check_only_compiles() -> Result<(), Box<dyn Error>> {
1616
use scylla::client::session::Session;
1717
use scylla::client::session_builder::SessionBuilder;
18-
use scylla::statement::query::Query;
18+
use scylla::statement::query::Statement;
1919
use scylla::statement::Consistency;
2020
use scylla::client::execution_profile::ExecutionProfile;
2121

@@ -33,7 +33,7 @@ let session: Session = SessionBuilder::new()
3333
.build()
3434
.await?;
3535

36-
let mut query = Query::from("SELECT * FROM ks.table");
36+
let mut query = Statement::from("SELECT * FROM ks.table");
3737

3838
// Query is not assigned any specific profile, so session's profile is applied.
3939
// Therefore, the query will be executed with Consistency::One.

docs/source/execution-profiles/remap.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ Below, the remaps described above are followed in code.
2525
# async fn check_only_compiles() -> Result<(), Box<dyn Error>> {
2626
use scylla::client::session::Session;
2727
use scylla::client::session_builder::SessionBuilder;
28-
use scylla::statement::query::Query;
28+
use scylla::statement::query::Statement;
2929
use scylla::statement::Consistency;
3030
use scylla::client::execution_profile::ExecutionProfile;
3131

@@ -46,8 +46,8 @@ let session: Session = SessionBuilder::new()
4646
.build()
4747
.await?;
4848

49-
let mut query1 = Query::from("SELECT * FROM ks.table");
50-
let mut query2 = Query::from("SELECT pk FROM ks.table WHERE pk = ?");
49+
let mut query1 = Statement::from("SELECT * FROM ks.table");
50+
let mut query2 = Statement::from("SELECT pk FROM ks.table WHERE pk = ?");
5151

5252
query1.set_execution_profile_handle(Some(handle1.clone()));
5353
query2.set_execution_profile_handle(Some(handle2.clone()));

docs/source/queries/batch.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ Only `INSERT`, `UPDATE` and `DELETE` statements are allowed.
1010
# use std::error::Error;
1111
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
1212
use scylla::statement::batch::Batch;
13-
use scylla::statement::query::Query;
13+
use scylla::statement::query::Statement;
1414
use scylla::statement::prepared::PreparedStatement;
1515

1616
// Create a batch statement
@@ -20,7 +20,7 @@ let mut batch: Batch = Default::default();
2020
batch.append_statement("INSERT INTO ks.tab(a, b) VALUES(1, 2)");
2121

2222
// Add a simple statement created manually to the batch
23-
let simple: Query = Query::new("INSERT INTO ks.tab (a, b) VALUES(3, 4)");
23+
let simple: Statement = Statement::new("INSERT INTO ks.tab (a, b) VALUES(3, 4)");
2424
batch.append_statement(simple);
2525

2626
// Add a prepared statement to the batch

docs/source/queries/lwt.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,11 @@ A lightweight transaction query is not a separate type - it can be expressed jus
1010
# use scylla::client::session::Session;
1111
# use std::error::Error;
1212
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
13-
use scylla::statement::query::Query;
13+
use scylla::statement::query::Statement;
1414
use scylla::statement::{Consistency, SerialConsistency};
1515

1616
// Create a Query manually to change the Consistency to ONE
17-
let mut my_query: Query = Query::new("INSERT INTO ks.tab (a) VALUES(?) IF NOT EXISTS".to_string());
17+
let mut my_query: Statement = Statement::new("INSERT INTO ks.tab (a) VALUES(?) IF NOT EXISTS".to_string());
1818
my_query.set_consistency(Consistency::One);
1919
// Use cross-datacenter serial consistency
2020
my_query.set_serial_consistency(Some(SerialConsistency::Serial));

docs/source/queries/paged.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -105,9 +105,9 @@ On a `Query`:
105105
# use scylla::client::session::Session;
106106
# use std::error::Error;
107107
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
108-
use scylla::statement::query::Query;
108+
use scylla::statement::query::Statement;
109109

110-
let mut query: Query = Query::new("SELECT a, b FROM ks.t");
110+
let mut query: Statement = Statement::new("SELECT a, b FROM ks.t");
111111
query.set_page_size(16);
112112

113113
let _ = session.query_iter(query, &[]).await?; // ...
@@ -145,11 +145,11 @@ On a `Query`:
145145
# use scylla::client::session::Session;
146146
# use std::error::Error;
147147
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
148-
use scylla::statement::query::Query;
148+
use scylla::statement::query::Statement;
149149
use scylla::response::{PagingState, PagingStateResponse};
150150
use std::ops::ControlFlow;
151151

152-
let paged_query = Query::new("SELECT a, b, c FROM ks.t").with_page_size(6);
152+
let paged_query = Statement::new("SELECT a, b, c FROM ks.t").with_page_size(6);
153153

154154
let mut paging_state = PagingState::start();
155155
loop {
@@ -188,12 +188,12 @@ On a `PreparedStatement`:
188188
# use scylla::client::session::Session;
189189
# use std::error::Error;
190190
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
191-
use scylla::statement::query::Query;
191+
use scylla::statement::query::Statement;
192192
use scylla::response::{PagingState, PagingStateResponse};
193193
use std::ops::ControlFlow;
194194

195195
let paged_prepared = session
196-
.prepare(Query::new("SELECT a, b, c FROM ks.t").with_page_size(7))
196+
.prepare(Statement::new("SELECT a, b, c FROM ks.t").with_page_size(7))
197197
.await?;
198198

199199
let mut paging_state = PagingState::start();

docs/source/queries/simple.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,11 +36,11 @@ You can create a query manually to set custom options. For example to change que
3636
# use scylla::client::session::Session;
3737
# use std::error::Error;
3838
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
39-
use scylla::statement::query::Query;
39+
use scylla::statement::query::Statement;
4040
use scylla::statement::Consistency;
4141

4242
// Create a Query manually to change the Consistency to ONE
43-
let mut my_query: Query = Query::new("INSERT INTO ks.tab (a) VALUES(?)");
43+
let mut my_query: Statement = Statement::new("INSERT INTO ks.tab (a) VALUES(?)");
4444
my_query.set_consistency(Consistency::One);
4545

4646
// Insert a value into the table

docs/source/queries/timeouts.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ However, setting per-statement timeout to `None` results in falling back to per-
2020
use scylla::client::execution_profile::ExecutionProfile;
2121
use scylla::client::session::Session;
2222
use scylla::client::session_builder::SessionBuilder;
23-
use scylla::statement::query::Query;
23+
use scylla::statement::query::Statement;
2424
use std::time::Duration;
2525

2626
let uri = std::env::var("SCYLLA_URI")
@@ -49,7 +49,7 @@ let three_sec_timeout_profile_handle = ExecutionProfile::builder()
4949

5050
// The below query will last for no more than 3 seconds, yielding a RequestTimeout error
5151
// if no response arrives until then.
52-
let mut query: Query = "TRUNCATE keyspace.table".into();
52+
let mut query: Statement = "TRUNCATE keyspace.table".into();
5353
query.set_execution_profile_handle(Some(three_sec_timeout_profile_handle));
5454
session
5555
.query_unpaged(query, ())

docs/source/queries/timestamp-generators.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ be warned about the clock skew, the warnings can be turned off with `without_war
3333
use scylla::client::session::Session;
3434
use scylla::client::session_builder::SessionBuilder;
3535
use scylla::policies::timestamp_generator::MonotonicTimestampGenerator;
36-
use scylla::statement::query::Query;
36+
use scylla::statement::query::Statement;
3737
use std::sync::Arc;
3838

3939
let session: Session = SessionBuilder::new()
@@ -44,7 +44,7 @@ let session: Session = SessionBuilder::new()
4444

4545
// This query will have a timestamp generated
4646
// by the monotonic timestamp generator
47-
let my_query: Query = Query::new("INSERT INTO ks.tab (a) VALUES(?)");
47+
let my_query: Statement = Statement::new("INSERT INTO ks.tab (a) VALUES(?)");
4848
let to_insert: i32 = 12345;
4949
session.query_unpaged(my_query, (to_insert,)).await?;
5050
# Ok(())

0 commit comments

Comments
 (0)