Skip to content

Commit 81f29a8

Browse files
Move test_prepared_config to query.rs
1 parent d6b9e09 commit 81f29a8

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
@@ -7,6 +7,21 @@ use scylla::{
77
use std::collections::HashSet;
88
use std::sync::{Arc, Mutex};
99

10+
#[tokio::test]
11+
async fn test_prepared_config() {
12+
setup_tracing();
13+
let session = create_new_session_builder().build().await.unwrap();
14+
15+
let mut query = Query::new("SELECT * FROM system_schema.tables");
16+
query.set_is_idempotent(true);
17+
query.set_page_size(42);
18+
19+
let prepared_statement = session.prepare(query).await.unwrap();
20+
21+
assert!(prepared_statement.get_is_idempotent());
22+
assert_eq!(prepared_statement.get_page_size(), 42);
23+
}
24+
1025
#[tokio::test]
1126
async fn test_timestamp() {
1227
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)