prepared it: teardown keyspaces

Author: Lorak-mmk

scylla/tests/integration/statements/prepared.rs

@@ -187,6 +187,8 @@ async fn test_prepared_statement() {
             (17, 16, "I'm prepared!!!", 7, None)
         );
     }
+
+    session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
 }
 
 /// Tests that PreparedStatement inherits the StatementConfig from Statement
@@ -230,7 +232,7 @@ async fn test_prepared_partitioner() {
     }
 
     session.ddl(create_ks).await.unwrap();
-    session.use_keyspace(ks, false).await.unwrap();
+    session.use_keyspace(&ks, false).await.unwrap();
 
     session
         .ddl("CREATE TABLE IF NOT EXISTS t1 (a int primary key)")
@@ -267,6 +269,8 @@ async fn test_prepared_partitioner() {
         prepared_statement_for_cdc_log.get_partitioner_name(),
         &PartitionerName::CDC
     );
+
+    session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
 }
 
 #[tokio::test]
@@ -425,6 +429,8 @@ async fn test_token_calculation() {
         )
         .await;
     }
+
+    session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
 }
 
 #[tokio::test]
@@ -477,6 +483,8 @@ async fn test_prepared_statement_col_specs() {
         spec("c", ColumnType::Native(NativeType::SmallInt)),
     ];
     assert_eq!(result_set_col_specs, expected_result_set_col_specs);
+
+    session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
 }
 
 #[tokio::test]
@@ -501,7 +509,7 @@ async fn test_skip_result_metadata() {
 
         let ks = unique_keyspace_name();
         session.ddl(format!("CREATE KEYSPACE IF NOT EXISTS {ks} WITH REPLICATION = {{'class' : 'NetworkTopologyStrategy', 'replication_factor' : 3}}")).await.unwrap();
-        session.use_keyspace(ks, false).await.unwrap();
+        session.use_keyspace(&ks, false).await.unwrap();
         session
             .ddl("CREATE TABLE t (a int primary key, b int, c text)")
             .await
@@ -556,7 +564,7 @@ async fn test_skip_result_metadata() {
             let ks = unique_keyspace_name();
 
             session.ddl(format!("CREATE KEYSPACE IF NOT EXISTS {ks} WITH REPLICATION = {{'class' : 'NetworkTopologyStrategy', 'replication_factor' : 1}}")).await.unwrap();
-            session.use_keyspace(ks, true).await.unwrap();
+            session.use_keyspace(&ks, true).await.unwrap();
 
             type RowT = (i32, i32, String);
             session
@@ -622,8 +630,12 @@ async fn test_skip_result_metadata() {
                 }
                 assert_eq!(results_from_manual_paging, rs);
             }
+
+            session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
         }
 
+        session.ddl(format!("DROP KEYSPACE {ks}")).await.unwrap();
+
         running_proxy
     }).await;