diff --git a/tests/it/insert.rs b/tests/it/insert.rs
index d32d489..09b0ea8 100644
--- a/tests/it/insert.rs
+++ b/tests/it/insert.rs
@@ -1,6 +1,25 @@
-use crate::{
-    create_rename_table, create_simple_table, fetch_rows, flush_query_log, RenameRow, SimpleRow,
-};
+use crate::{create_simple_table, fetch_rows, flush_query_log, SimpleRow};
+use clickhouse::{sql::Identifier, Client, Row};
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Row, Serialize, Deserialize, PartialEq)]
+#[serde(rename_all = "camelCase")]
+struct RenameRow {
+    #[serde(rename = "fix_id")]
+    pub fix_id: i64,
+    #[serde(rename = "extComplexId")]
+    pub complex_id: String,
+    pub ext_float: f64,
+}
+
+async fn create_rename_table(client: &Client, table_name: &str) {
+    client
+        .query("CREATE TABLE ?(fixId UInt64, extComplexId String, extFloat Float64) ENGINE = MergeTree ORDER BY fixId")
+        .bind(Identifier(table_name))
+        .execute()
+        .await
+        .unwrap();
+}
 
 #[tokio::test]
 async fn keeps_client_options() {
diff --git a/tests/it/main.rs b/tests/it/main.rs
index a03d6da..001cbd6 100644
--- a/tests/it/main.rs
+++ b/tests/it/main.rs
@@ -30,16 +30,6 @@ impl SimpleRow {
     }
 }
 
-#[derive(Debug, Row, Serialize, Deserialize, PartialEq)]
-#[serde(rename_all = "camelCase")]
-pub struct RenameRow {
-    #[serde(rename = "fix_id")]
-    pub fix_id: i64,
-    #[serde(rename = "extComplexId")]
-    pub complex_id: String,
-    pub ext_float: f64,
-}
-
 async fn create_simple_table(client: &Client, table_name: &str) {
     client
         .query("CREATE TABLE ?(id UInt64, data String) ENGINE = MergeTree ORDER BY id")
@@ -49,15 +39,6 @@ async fn create_simple_table(client: &Client, table_name: &str) {
         .unwrap();
 }
 
-async fn create_rename_table(client: &Client, table_name: &str) {
-    client
-        .query("CREATE TABLE ?(fixId UInt64, extComplexId String, extFloat Float64) ENGINE = MergeTree ORDER BY fixId")
-        .bind(Identifier(table_name))
-        .execute()
-        .await
-        .unwrap();
-}
-
 async fn fetch_rows<T>(client: &Client, table_name: &str) -> Vec<T>
 where
     T: Row + for<'b> Deserialize<'b>,