Skip to content

Commit 99ff6a2

Browse files
Move test_prepared_config to query.rs
1 parent 4da5785 commit 99ff6a2

File tree

2 files changed

+15
-15
lines changed

2 files changed

+15
-15
lines changed

scylla/tests/integration/query.rs

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,21 @@ use std::collections::HashSet;
1111
use std::sync::{Arc, Mutex};
1212
use uuid::Uuid;
1313

14+
#[tokio::test]
15+
async fn test_prepared_config() {
16+
setup_tracing();
17+
let session = create_new_session_builder().build().await.unwrap();
18+
19+
let mut query = Query::new("SELECT * FROM system_schema.tables");
20+
query.set_is_idempotent(true);
21+
query.set_page_size(42);
22+
23+
let prepared_statement = session.prepare(query).await.unwrap();
24+
25+
assert!(prepared_statement.get_is_idempotent());
26+
assert_eq!(prepared_statement.get_page_size(), 42);
27+
}
28+
1429
#[tokio::test]
1530
async fn test_timestamp() {
1631
setup_tracing();

scylla/tests/integration/session.rs

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1013,21 +1013,6 @@ async fn test_request_timeout() {
10131013
}
10141014
}
10151015

1016-
#[tokio::test]
1017-
async fn test_prepared_config() {
1018-
setup_tracing();
1019-
let session = create_new_session_builder().build().await.unwrap();
1020-
1021-
let mut query = Query::new("SELECT * FROM system_schema.tables");
1022-
query.set_is_idempotent(true);
1023-
query.set_page_size(42);
1024-
1025-
let prepared_statement = session.prepare(query).await.unwrap();
1026-
1027-
assert!(prepared_statement.get_is_idempotent());
1028-
assert_eq!(prepared_statement.get_page_size(), 42);
1029-
}
1030-
10311016
fn udt_type_a_def(ks: &str) -> Arc<UserDefinedType<'_>> {
10321017
Arc::new(UserDefinedType {
10331018
name: "type_a".into(),

0 commit comments

Comments
 (0)