diff --git a/Cargo.lock b/Cargo.lock
index ee384d4..a5cc41d 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -86,7 +86,6 @@ name = "api-lib"
 version = "0.1.0"
 dependencies = [
  "application",
- "diesel",
  "infrastructure",
  "mysql",
  "r2d2",
@@ -100,10 +99,10 @@ dependencies = [
 name = "application"
 version = "0.1.0"
 dependencies = [
- "diesel",
+ "infrastructure",
  "mysql",
  "sea-query",
- "sea-query-diesel",
+ "serde",
  "shared",
 ]
 
@@ -194,17 +193,6 @@ version = "0.22.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9475866fec1451be56a3c2400fd081ff546538961565ccb5b7142cbd22bc7a51"
 
-[[package]]
-name = "bigdecimal"
-version = "0.3.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a6773ddc0eafc0e509fb60e48dff7f450f8e674a0686ae8605e8d9901bd5eefa"
-dependencies = [
- "num-bigint",
- "num-integer",
- "num-traits",
-]
-
 [[package]]
 name = "bigdecimal"
 version = "0.4.3"
@@ -636,47 +624,6 @@ dependencies = [
  "syn 2.0.48",
 ]
 
-[[package]]
-name = "diesel"
-version = "2.1.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "03fc05c17098f21b89bc7d98fe1dd3cce2c11c2ad8e145f2a44fe08ed28eb559"
-dependencies = [
- "bigdecimal 0.3.1",
- "bitflags 2.4.1",
- "byteorder",
- "chrono",
- "diesel_derives",
- "mysqlclient-sys",
- "num-bigint",
- "num-integer",
- "num-traits",
- "percent-encoding",
- "r2d2",
- "url",
-]
-
-[[package]]
-name = "diesel_derives"
-version = "2.1.3"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5d02eecb814ae714ffe61ddc2db2dd03e6c49a42e269b5001355500d431cce0c"
-dependencies = [
- "diesel_table_macro_syntax",
- "proc-macro2",
- "quote",
- "syn 2.0.48",
-]
-
-[[package]]
-name = "diesel_table_macro_syntax"
-version = "0.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "fc5557efc453706fed5e4fa85006fe9817c224c3f480a34c7e5959fd700921c5"
-dependencies = [
- "syn 2.0.48",
-]
-
 [[package]]
 name = "digest"
 version = "0.10.7"
@@ -1116,7 +1063,8 @@ dependencies = [
 name = "infrastructure"
 version = "0.1.0"
 dependencies = [
- "diesel",
+ "mysql",
+ "r2d2",
  "shared",
 ]
 
@@ -1399,7 +1347,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "0ccdc1fe2bb3ef97e07ba4397327ed45509a1e2e499e2f8265243879cbc7313c"
 dependencies = [
  "base64 0.21.7",
- "bigdecimal 0.4.3",
+ "bigdecimal",
  "bindgen",
  "bitflags 2.4.1",
  "bitvec",
@@ -1431,16 +1379,6 @@ dependencies = [
  "zstd",
 ]
 
-[[package]]
-name = "mysqlclient-sys"
-version = "0.2.5"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f61b381528ba293005c42a409dd73d034508e273bf90481f17ec2e964a6e969b"
-dependencies = [
- "pkg-config",
- "vcpkg",
-]
-
 [[package]]
 name = "named_pipe"
 version = "0.4.1"
@@ -2103,10 +2041,7 @@ version = "0.30.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "4166a1e072292d46dc91f31617c2a1cdaf55a8be4b5c9f4bf2ba248e3ac4999b"
 dependencies = [
- "bigdecimal 0.3.1",
- "chrono",
  "inherent",
- "rust_decimal",
  "sea-query-derive",
 ]
 
@@ -2123,19 +2058,6 @@ dependencies = [
  "thiserror",
 ]
 
-[[package]]
-name = "sea-query-diesel"
-version = "0.1.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a09ac7c3ff2bf910d468c9c8df7fe277322802d13e12d76dabb6a844914f04f6"
-dependencies = [
- "bigdecimal 0.3.1",
- "chrono",
- "diesel",
- "rust_decimal",
- "sea-query",
-]
-
 [[package]]
 name = "seahash"
 version = "4.1.0"
diff --git a/Cargo.toml b/Cargo.toml
index 79b0266..df1437d 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -20,12 +20,5 @@ proc-macro2 = "1.0.78"
 quote = "1.0.35"
 syn = { version = "2.0.48", features = ["parsing"] }
 sea-query = { version = "0.30.7", features = ["backend-mysql"] }
-sea-query-diesel = { version = "0.1.0", features = [
-    "mysql",
-    "with-chrono",
-    "with-rust_decimal",
-    "with-bigdecimal",
-] }
 r2d2 = "0.8.10"
-diesel = { version = "2.1.5", features = ["mysql", "chrono", "r2d2"] }
 mysql = { version = "25.0.0" }
diff --git a/bin/api/src/main.rs b/bin/api/src/main.rs
index e1f541d..0c61ebd 100644
--- a/bin/api/src/main.rs
+++ b/bin/api/src/main.rs
@@ -9,5 +9,5 @@ fn rocket() -> _ {
 
     rocket::build()
         .mount("/api", api_lib::handlers::handlers())
-        .manage(mysql::Pool::new("mysql://user:password@localhost:3306/f1db").unwrap())
+        .manage(infrastructure::ConnectionPool::try_new().unwrap())
 }
diff --git a/crates/api/Cargo.toml b/crates/api/Cargo.toml
index 7117263..b9589b1 100644
--- a/crates/api/Cargo.toml
+++ b/crates/api/Cargo.toml
@@ -7,7 +7,6 @@ edition = "2021"
 
 [dependencies]
 rocket.workspace = true
-diesel.workspace = true
 serde.workspace = true
 r2d2.workspace = true
 serde_json.workspace = true
diff --git a/crates/api/src/circuit.rs b/crates/api/src/circuit.rs
index fc2ca9c..b300128 100644
--- a/crates/api/src/circuit.rs
+++ b/crates/api/src/circuit.rs
@@ -1,28 +1,29 @@
-use diesel::{Connection, RunQueryDsl};
-use mysql::prelude::Queryable;
-use mysql::Pool;
 use rocket::serde::json::Json;
 use rocket::{get, routes, State};
 
-use application;
+use application::{self, models::Circuits};
 use infrastructure::ConnectionPool;
 use shared::prelude::*;
 
 #[get("/<series>/circuits?<param..>")]
 pub fn circuits(
-    db: &State<Pool>,
+    db: &State<ConnectionPool>,
     series: Series,
     param: shared::parameters::GetCircuitsParameter,
-) -> Result<()> {
-    let mut conn = db.get_conn().unwrap();
+) -> Result<Json<Response<Vec<Circuits>>>> {
+    let conn = &mut db.from_series(series).get().unwrap();
 
     let query = application::circuit::CircuitQueryBuilder::filter(param.into()).build();
 
-    let res: Vec<application::models::Circuits> = conn.query(query).unwrap();
+    let res = query.query_and_count::<Circuits>(conn);
 
-    println!("{:?}", res);
+    let response = Response {
+        data: res.0,
+        pagination: res.1,
+        series,
+    };
 
-    Ok(())
+    Ok(Json(response))
 }
 
 pub fn handlers() -> Vec<rocket::Route> {
diff --git a/crates/api/src/lib.rs b/crates/api/src/lib.rs
index a3f405b..9765612 100644
--- a/crates/api/src/lib.rs
+++ b/crates/api/src/lib.rs
@@ -2,8 +2,6 @@
 
 pub mod circuit;
 
-type Backend = diesel::mysql::Mysql;
-
 pub mod handlers {
     use crate::*;
     use rocket::Route;
diff --git a/crates/application/Cargo.toml b/crates/application/Cargo.toml
index 465e725..ef3f3fd 100644
--- a/crates/application/Cargo.toml
+++ b/crates/application/Cargo.toml
@@ -7,8 +7,8 @@ edition = "2021"
 
 [dependencies]
 sea-query.workspace = true
-sea-query-diesel.workspace = true
-diesel.workspace = true
 mysql.workspace = true
+serde.workspace = true
 
 shared.workspace = true
+infrastructure.workspace = true
diff --git a/crates/application/src/circuit.rs b/crates/application/src/circuit.rs
index 8482b3d..7336ff0 100644
--- a/crates/application/src/circuit.rs
+++ b/crates/application/src/circuit.rs
@@ -1,8 +1,9 @@
-use diesel::QueryResult;
 use sea_query::{Expr, Query, SelectStatement};
-use sea_query_diesel::{DieselBinder, SeaQuery};
 
-use crate::iden::*;
+use crate::{
+    iden::*,
+    pagination::{Paginate, Paginated},
+};
 use shared::filters::GetCircuitsFilter;
 
 pub struct CircuitQueryBuilder {
@@ -12,28 +13,40 @@ pub struct CircuitQueryBuilder {
 
 impl CircuitQueryBuilder {
     pub fn filter(filter: GetCircuitsFilter) -> Self {
-        let mut stmt = Query::select();
-        stmt.distinct().from(Circuits::Table).columns(
-            [
-                Circuits::CircuitId,
-                Circuits::CircuitRef,
-                Circuits::Name,
-                Circuits::Location,
-                Circuits::Country,
-                Circuits::Lat,
-                Circuits::Lng,
-                Circuits::Alt,
-                Circuits::Url,
-            ]
-            .into_iter()
-            .map(|c| (Circuits::Table, c)),
-        );
+        let stmt = Query::select()
+            .distinct()
+            .from(Circuits::Table)
+            .columns(
+                [
+                    Circuits::CircuitId,
+                    Circuits::CircuitRef,
+                    Circuits::Name,
+                    Circuits::Location,
+                    Circuits::Country,
+                    Circuits::Lat,
+                    Circuits::Lng,
+                    Circuits::Alt,
+                    Circuits::Url,
+                ]
+                .into_iter()
+                .map(|c| (Circuits::Table, c)),
+            )
+            .to_owned();
 
         Self { stmt, filter }
     }
 
-    pub fn build(self) -> String {
-        self.stmt.to_string(sea_query::MysqlQueryBuilder)
+    pub fn build(self) -> Paginated {
+        let page: u64 = self.filter.page.unwrap_or_default().0;
+        let limit: u64 = self.filter.limit.unwrap_or_default().0;
+
+        self.races_table()
+            .results_table()
+            .constructors_table()
+            .drivers_table()
+            .stmt
+            .paginate(page)
+            .per_page(limit)
     }
 
     fn one_of(&self) -> bool {
diff --git a/crates/application/src/entities/circuits.rs b/crates/application/src/entities/circuits.rs
deleted file mode 100644
index 7c43527..0000000
--- a/crates/application/src/entities/circuits.rs
+++ /dev/null
@@ -1,27 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
-#[sea_orm(table_name = "circuits")]
-pub struct Model {
-    #[sea_orm(column_name = "circuitId", primary_key)]
-    pub circuit_id: i32,
-    #[sea_orm(column_name = "circuitRef")]
-    pub circuit_ref: String,
-    pub name: String,
-    pub location: Option<String>,
-    pub country: Option<String>,
-    #[sea_orm(column_type = "Float", nullable)]
-    pub lat: Option<f32>,
-    #[sea_orm(column_type = "Float", nullable)]
-    pub lng: Option<f32>,
-    pub alt: Option<i32>,
-    #[sea_orm(unique)]
-    pub url: String,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/constructor_results.rs b/crates/application/src/entities/constructor_results.rs
deleted file mode 100644
index d9c1110..0000000
--- a/crates/application/src/entities/constructor_results.rs
+++ /dev/null
@@ -1,22 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
-#[sea_orm(table_name = "constructorResults")]
-pub struct Model {
-    #[sea_orm(column_name = "constructorResultsId", primary_key)]
-    pub constructor_results_id: i32,
-    #[sea_orm(column_name = "raceId")]
-    pub race_id: i32,
-    #[sea_orm(column_name = "constructorId")]
-    pub constructor_id: i32,
-    #[sea_orm(column_type = "Float", nullable)]
-    pub points: Option<f32>,
-    pub status: Option<String>,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/constructor_standings.rs b/crates/application/src/entities/constructor_standings.rs
deleted file mode 100644
index 06a73bf..0000000
--- a/crates/application/src/entities/constructor_standings.rs
+++ /dev/null
@@ -1,25 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
-#[sea_orm(table_name = "constructorStandings")]
-pub struct Model {
-    #[sea_orm(column_name = "constructorStandingsId", primary_key)]
-    pub constructor_standings_id: i32,
-    #[sea_orm(column_name = "raceId")]
-    pub race_id: i32,
-    #[sea_orm(column_name = "constructorId")]
-    pub constructor_id: i32,
-    #[sea_orm(column_type = "Float")]
-    pub points: f32,
-    pub position: Option<i32>,
-    #[sea_orm(column_name = "positionText")]
-    pub position_text: Option<String>,
-    pub wins: i32,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/constructors.rs b/crates/application/src/entities/constructors.rs
deleted file mode 100644
index 24f2f72..0000000
--- a/crates/application/src/entities/constructors.rs
+++ /dev/null
@@ -1,21 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "constructors")]
-pub struct Model {
-    #[sea_orm(column_name = "constructorId", primary_key)]
-    pub constructor_id: i32,
-    #[sea_orm(column_name = "constructorRef")]
-    pub constructor_ref: String,
-    #[sea_orm(unique)]
-    pub name: String,
-    pub nationality: Option<String>,
-    pub url: String,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/driver_standings.rs b/crates/application/src/entities/driver_standings.rs
deleted file mode 100644
index d55d2d3..0000000
--- a/crates/application/src/entities/driver_standings.rs
+++ /dev/null
@@ -1,25 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
-#[sea_orm(table_name = "driverStandings")]
-pub struct Model {
-    #[sea_orm(column_name = "driverStandingsId", primary_key)]
-    pub driver_standings_id: i32,
-    #[sea_orm(column_name = "raceId")]
-    pub race_id: i32,
-    #[sea_orm(column_name = "driverId")]
-    pub driver_id: i32,
-    #[sea_orm(column_type = "Float")]
-    pub points: f32,
-    pub position: Option<i32>,
-    #[sea_orm(column_name = "positionText")]
-    pub position_text: Option<String>,
-    pub wins: i32,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/drivers.rs b/crates/application/src/entities/drivers.rs
deleted file mode 100644
index fb7c216..0000000
--- a/crates/application/src/entities/drivers.rs
+++ /dev/null
@@ -1,25 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "drivers")]
-pub struct Model {
-    #[sea_orm(column_name = "driverId", primary_key)]
-    pub driver_id: i32,
-    #[sea_orm(column_name = "driverRef")]
-    pub driver_ref: String,
-    pub number: Option<i32>,
-    pub code: Option<String>,
-    pub forename: String,
-    pub surname: String,
-    pub dob: Option<Date>,
-    pub nationality: Option<String>,
-    #[sea_orm(unique)]
-    pub url: String,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/lap_times.rs b/crates/application/src/entities/lap_times.rs
deleted file mode 100644
index 8c1eb9d..0000000
--- a/crates/application/src/entities/lap_times.rs
+++ /dev/null
@@ -1,22 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "lapTimes")]
-pub struct Model {
-    #[sea_orm(column_name = "raceId", primary_key, auto_increment = false)]
-    pub race_id: i32,
-    #[sea_orm(column_name = "driverId", primary_key, auto_increment = false)]
-    pub driver_id: i32,
-    #[sea_orm(primary_key, auto_increment = false)]
-    pub lap: i32,
-    pub position: Option<i32>,
-    pub time: Option<String>,
-    pub milliseconds: Option<i32>,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/mod.rs b/crates/application/src/entities/mod.rs
deleted file mode 100644
index 67c810e..0000000
--- a/crates/application/src/entities/mod.rs
+++ /dev/null
@@ -1,18 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-pub mod prelude;
-
-pub mod circuits;
-pub mod constructor_results;
-pub mod constructor_standings;
-pub mod constructors;
-pub mod driver_standings;
-pub mod drivers;
-pub mod lap_times;
-pub mod pit_stops;
-pub mod qualifying;
-pub mod races;
-pub mod results;
-pub mod seasons;
-pub mod sprint_results;
-pub mod status;
diff --git a/crates/application/src/entities/pit_stops.rs b/crates/application/src/entities/pit_stops.rs
deleted file mode 100644
index 635a9c1..0000000
--- a/crates/application/src/entities/pit_stops.rs
+++ /dev/null
@@ -1,23 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "pitStops")]
-pub struct Model {
-    #[sea_orm(column_name = "raceId", primary_key, auto_increment = false)]
-    pub race_id: i32,
-    #[sea_orm(column_name = "driverId", primary_key, auto_increment = false)]
-    pub driver_id: i32,
-    #[sea_orm(primary_key, auto_increment = false)]
-    pub stop: i32,
-    pub lap: i32,
-    pub time: Time,
-    pub duration: Option<String>,
-    pub milliseconds: Option<i32>,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/prelude.rs b/crates/application/src/entities/prelude.rs
deleted file mode 100644
index 4158d93..0000000
--- a/crates/application/src/entities/prelude.rs
+++ /dev/null
@@ -1,16 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-pub use super::circuits::Entity as Circuits;
-pub use super::constructor_results::Entity as ConstructorResults;
-pub use super::constructor_standings::Entity as ConstructorStandings;
-pub use super::constructors::Entity as Constructors;
-pub use super::driver_standings::Entity as DriverStandings;
-pub use super::drivers::Entity as Drivers;
-pub use super::lap_times::Entity as LapTimes;
-pub use super::pit_stops::Entity as PitStops;
-pub use super::qualifying::Entity as Qualifying;
-pub use super::races::Entity as Races;
-pub use super::results::Entity as Results;
-pub use super::seasons::Entity as Seasons;
-pub use super::sprint_results::Entity as SprintResults;
-pub use super::status::Entity as Status;
diff --git a/crates/application/src/entities/qualifying.rs b/crates/application/src/entities/qualifying.rs
deleted file mode 100644
index 4e23306..0000000
--- a/crates/application/src/entities/qualifying.rs
+++ /dev/null
@@ -1,26 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "qualifying")]
-pub struct Model {
-    #[sea_orm(column_name = "qualifyId", primary_key)]
-    pub qualify_id: i32,
-    #[sea_orm(column_name = "raceId")]
-    pub race_id: i32,
-    #[sea_orm(column_name = "driverId")]
-    pub driver_id: i32,
-    #[sea_orm(column_name = "constructorId")]
-    pub constructor_id: i32,
-    pub number: i32,
-    pub position: Option<i32>,
-    pub q1: Option<String>,
-    pub q2: Option<String>,
-    pub q3: Option<String>,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/races.rs b/crates/application/src/entities/races.rs
deleted file mode 100644
index 0e17dda..0000000
--- a/crates/application/src/entities/races.rs
+++ /dev/null
@@ -1,34 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "races")]
-pub struct Model {
-    #[sea_orm(column_name = "raceId", primary_key)]
-    pub race_id: i32,
-    pub year: i32,
-    pub round: i32,
-    #[sea_orm(column_name = "circuitId")]
-    pub circuit_id: i32,
-    pub name: String,
-    pub date: Date,
-    pub time: Option<Time>,
-    #[sea_orm(unique)]
-    pub url: Option<String>,
-    pub fp1_date: Option<Date>,
-    pub fp1_time: Option<Time>,
-    pub fp2_date: Option<Date>,
-    pub fp2_time: Option<Time>,
-    pub fp3_date: Option<Date>,
-    pub fp3_time: Option<Time>,
-    pub quali_date: Option<Date>,
-    pub quali_time: Option<Time>,
-    pub sprint_date: Option<Date>,
-    pub sprint_time: Option<Time>,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/results.rs b/crates/application/src/entities/results.rs
deleted file mode 100644
index eafb024..0000000
--- a/crates/application/src/entities/results.rs
+++ /dev/null
@@ -1,42 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
-#[sea_orm(table_name = "results")]
-pub struct Model {
-    #[sea_orm(column_name = "resultId", primary_key)]
-    pub result_id: i32,
-    #[sea_orm(column_name = "raceId")]
-    pub race_id: i32,
-    #[sea_orm(column_name = "driverId")]
-    pub driver_id: i32,
-    #[sea_orm(column_name = "constructorId")]
-    pub constructor_id: i32,
-    pub number: Option<i32>,
-    pub grid: i32,
-    pub position: Option<i32>,
-    #[sea_orm(column_name = "positionText")]
-    pub position_text: String,
-    #[sea_orm(column_name = "positionOrder")]
-    pub position_order: i32,
-    #[sea_orm(column_type = "Float")]
-    pub points: f32,
-    pub laps: i32,
-    pub time: Option<String>,
-    pub milliseconds: Option<i32>,
-    #[sea_orm(column_name = "fastestLap")]
-    pub fastest_lap: Option<i32>,
-    pub rank: Option<i32>,
-    #[sea_orm(column_name = "fastestLapTime")]
-    pub fastest_lap_time: Option<String>,
-    #[sea_orm(column_name = "fastestLapSpeed")]
-    pub fastest_lap_speed: Option<String>,
-    #[sea_orm(column_name = "statusId")]
-    pub status_id: i32,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/seasons.rs b/crates/application/src/entities/seasons.rs
deleted file mode 100644
index 366e1fb..0000000
--- a/crates/application/src/entities/seasons.rs
+++ /dev/null
@@ -1,17 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "seasons")]
-pub struct Model {
-    #[sea_orm(primary_key, auto_increment = false)]
-    pub year: i32,
-    #[sea_orm(unique)]
-    pub url: String,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/sprint_results.rs b/crates/application/src/entities/sprint_results.rs
deleted file mode 100644
index b8b8bdb..0000000
--- a/crates/application/src/entities/sprint_results.rs
+++ /dev/null
@@ -1,39 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
-#[sea_orm(table_name = "sprintResults")]
-pub struct Model {
-    #[sea_orm(column_name = "sprintResultId", primary_key)]
-    pub sprint_result_id: i32,
-    #[sea_orm(column_name = "raceId")]
-    pub race_id: i32,
-    #[sea_orm(column_name = "driverId")]
-    pub driver_id: i32,
-    #[sea_orm(column_name = "constructorId")]
-    pub constructor_id: i32,
-    pub number: i32,
-    pub grid: i32,
-    pub position: Option<i32>,
-    #[sea_orm(column_name = "positionText")]
-    pub position_text: String,
-    #[sea_orm(column_name = "positionOrder")]
-    pub position_order: i32,
-    #[sea_orm(column_type = "Float")]
-    pub points: f32,
-    pub laps: i32,
-    pub time: Option<String>,
-    pub milliseconds: Option<i32>,
-    #[sea_orm(column_name = "fastestLap")]
-    pub fastest_lap: Option<i32>,
-    #[sea_orm(column_name = "fastestLapTime")]
-    pub fastest_lap_time: Option<String>,
-    #[sea_orm(column_name = "statusId")]
-    pub status_id: i32,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/entities/status.rs b/crates/application/src/entities/status.rs
deleted file mode 100644
index d9b3612..0000000
--- a/crates/application/src/entities/status.rs
+++ /dev/null
@@ -1,16 +0,0 @@
-//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
-
-use sea_orm::entity::prelude::*;
-
-#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
-#[sea_orm(table_name = "status")]
-pub struct Model {
-    #[sea_orm(column_name = "statusId", primary_key)]
-    pub status_id: i32,
-    pub status: String,
-}
-
-#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
-
-impl ActiveModelBehavior for ActiveModel {}
diff --git a/crates/application/src/lib.rs b/crates/application/src/lib.rs
index 460b3eb..0ccf75a 100644
--- a/crates/application/src/lib.rs
+++ b/crates/application/src/lib.rs
@@ -1,3 +1,4 @@
 pub mod circuit;
 pub(crate) mod iden;
 pub mod models;
+mod pagination;
diff --git a/crates/application/src/models.rs b/crates/application/src/models.rs
index ce4e3c3..b7a60eb 100644
--- a/crates/application/src/models.rs
+++ b/crates/application/src/models.rs
@@ -1,16 +1,22 @@
 use mysql::prelude::*;
+use serde::Serialize;
 
-#[derive(FromRow, Debug)]
+#[derive(FromRow, Debug, Serialize)]
 pub struct Circuits {
     #[mysql(rename = "circuitId")]
     circuit_id: i32,
     #[mysql(rename = "circuitRef")]
     circuit_ref: String,
     name: String,
+    #[serde(skip_serializing_if = "Option::is_none")]
     location: Option<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
     country: Option<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
     lat: Option<f32>,
+    #[serde(skip_serializing_if = "Option::is_none")]
     lng: Option<f32>,
+    #[serde(skip_serializing_if = "Option::is_none")]
     alt: Option<i32>,
     url: String,
 }
diff --git a/crates/application/src/pagination.rs b/crates/application/src/pagination.rs
new file mode 100644
index 0000000..61f8657
--- /dev/null
+++ b/crates/application/src/pagination.rs
@@ -0,0 +1,86 @@
+use mysql::prelude::*;
+use mysql::*;
+use sea_query::{Alias, Asterisk, Expr, Func, MysqlQueryBuilder, Query, SelectStatement};
+
+use infrastructure::Connection;
+use shared::models::Pagination;
+
+const DEFAULT_PER_PAGE: u64 = 20;
+
+pub trait Paginate {
+    fn paginate(self, page: u64) -> Paginated;
+}
+
+impl Paginate for SelectStatement {
+    fn paginate(self, page: u64) -> Paginated {
+        Paginated {
+            query: self,
+            page,
+            per_page: DEFAULT_PER_PAGE,
+            offset: offset(page, DEFAULT_PER_PAGE),
+        }
+    }
+}
+
+pub struct Paginated {
+    query: SelectStatement,
+    page: u64,
+    per_page: u64,
+    offset: u64,
+}
+
+impl Paginated {
+    pub fn per_page(self, per_page: u64) -> Self {
+        Paginated {
+            per_page,
+            offset: offset(self.page, per_page),
+            ..self
+        }
+    }
+
+    pub fn query_and_count<U>(self, conn: &mut Connection) -> (Vec<U>, Pagination)
+    where
+        U: FromRow,
+    {
+        let query = self
+            .query
+            .clone()
+            .limit(self.per_page)
+            .offset(self.offset)
+            .to_string(MysqlQueryBuilder);
+
+        let records: Vec<U> = conn.query(query).unwrap();
+        let total = self.num_items(conn);
+        let total_pages = (total as f64 / self.per_page as f64).ceil() as u64;
+
+        let pagination = Pagination {
+            total,
+            limit: self.per_page,
+            page: self.page,
+            max_page: total_pages,
+        };
+
+        (records, pagination)
+    }
+
+    fn num_items(&self, conn: &mut Connection) -> u64 {
+        let query = Query::select()
+            .expr(Expr::cust("COUNT(*) AS num_items"))
+            .from_subquery(
+                self.query
+                    .clone()
+                    .reset_limit()
+                    .reset_offset()
+                    .clear_order_by()
+                    .to_owned(),
+                Alias::new("t"),
+            )
+            .to_string(MysqlQueryBuilder);
+
+        *conn.query(query).unwrap().first().unwrap()
+    }
+}
+
+fn offset(page: u64, per_page: u64) -> u64 {
+    (page.saturating_sub(1)) * per_page
+}
diff --git a/crates/infrastructure/Cargo.toml b/crates/infrastructure/Cargo.toml
index f616d08..a0957de 100644
--- a/crates/infrastructure/Cargo.toml
+++ b/crates/infrastructure/Cargo.toml
@@ -6,6 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-diesel.workspace = true
+mysql.workspace = true
+r2d2.workspace = true
 
 shared.workspace = true
diff --git a/crates/infrastructure/src/error.rs b/crates/infrastructure/src/error.rs
index f15e4e4..3aaf3b8 100644
--- a/crates/infrastructure/src/error.rs
+++ b/crates/infrastructure/src/error.rs
@@ -8,6 +8,7 @@ pub struct Error {
 pub enum ErrorKind {
     MissingEnvVar,
     ConnectionPoolError,
+    ParseIntError,
 }
 
 #[macro_export]
diff --git a/crates/infrastructure/src/lib.rs b/crates/infrastructure/src/lib.rs
index 11db46d..834e6e9 100644
--- a/crates/infrastructure/src/lib.rs
+++ b/crates/infrastructure/src/lib.rs
@@ -1,33 +1,40 @@
-use diesel::mysql::MysqlConnection;
-use diesel::r2d2;
 use std::env;
-use std::ops::{Deref, DerefMut};
 
 use shared::parameters::Series;
 
 mod error;
+mod pool;
+
+pub type Pool = r2d2::Pool<pool::MySqlConnectionManager>;
+pub type Connection = r2d2::PooledConnection<pool::MySqlConnectionManager>;
 
 pub struct ConnectionPool {
-    f1db_pool: DBPool,
+    f1db_pool: Pool,
 }
 
 impl ConnectionPool {
     pub fn try_new() -> Result<Self, error::Error> {
-        let database_url = env::var("DATABASE_URL")
-            .map_err(|_| error!(MissingEnvVar => "DATABASE_URL value is missing"))?;
+        let env_vars = EnvVars::try_new()?;
+
+        let opts = mysql::OptsBuilder::new()
+            .ip_or_hostname(Some(env_vars.ip_or_hostname))
+            .db_name(Some(env_vars.db_name))
+            .user(Some(env_vars.user))
+            .pass(Some(env_vars.password))
+            .tcp_port(env_vars.port.parse().map_err(
+                |_| error!(ParseIntError => "failed to parse port number from env variable"),
+            )?);
 
-        let manager = r2d2::ConnectionManager::<MysqlConnection>::new(database_url);
-        let pool = r2d2::Pool::builder()
+        let manager = pool::MySqlConnectionManager::new(opts);
+        let f1db_pool = r2d2::Pool::builder()
             .max_size(20)
             .build(manager)
             .map_err(|_| error!(ConnectionPoolError => "Failed to create connection pool"))?;
 
-        Ok(Self {
-            f1db_pool: DBPool(pool),
-        })
+        Ok(Self { f1db_pool })
     }
 
-    pub fn from_series(&self, series: Series) -> &DBPool {
+    pub fn from_series(&self, series: Series) -> &Pool {
         match series {
             Series::F1 => &self.f1db_pool,
             Series::F2 => unimplemented!(),
@@ -35,19 +42,27 @@ impl ConnectionPool {
     }
 }
 
-type InnerDBPool = r2d2::Pool<r2d2::ConnectionManager<MysqlConnection>>;
-pub struct DBPool(InnerDBPool);
-
-impl Deref for DBPool {
-    type Target = InnerDBPool;
-
-    fn deref(&self) -> &Self::Target {
-        &self.0
-    }
+struct EnvVars {
+    ip_or_hostname: String,
+    db_name: String,
+    user: String,
+    password: String,
+    port: String,
 }
 
-impl DerefMut for DBPool {
-    fn deref_mut(&mut self) -> &mut Self::Target {
-        &mut self.0
+impl EnvVars {
+    fn try_new() -> Result<Self, error::Error> {
+        Ok(Self {
+            ip_or_hostname: env::var("DB_IP_OR_HOSTNAME")
+                .map_err(|_| error!(MissingEnvVar => "DB_IP_OR_HOSTNAME value is missing"))?,
+            db_name: env::var("DB_NAME")
+                .map_err(|_| error!(MissingEnvVar => "DB_NAME value is missing"))?,
+            user: env::var("DB_USER")
+                .map_err(|_| error!(MissingEnvVar => "DB_USER value is missing"))?,
+            password: env::var("DB_PASSWORD")
+                .map_err(|_| error!(MissingEnvVar => "DB_PASSWORD value is missing"))?,
+            port: env::var("DB_PORT")
+                .map_err(|_| error!(MissingEnvVar => "DB_PORT value is missing"))?,
+        })
     }
 }
diff --git a/crates/infrastructure/src/pool.rs b/crates/infrastructure/src/pool.rs
new file mode 100644
index 0000000..b875a17
--- /dev/null
+++ b/crates/infrastructure/src/pool.rs
@@ -0,0 +1,37 @@
+//! Connection manager implementation for MySQL connections.
+//!
+//! See [`MySqlConnectionManager`].
+
+use mysql::{error::Error, prelude::*, Conn, Opts, OptsBuilder};
+
+/// An [`r2d2`] connection manager for [`mysql`] connections.
+#[derive(Clone, Debug)]
+pub struct MySqlConnectionManager {
+    params: Opts,
+}
+
+impl MySqlConnectionManager {
+    /// Constructs a new MySQL connection manager from `params`.
+    pub fn new(params: OptsBuilder) -> MySqlConnectionManager {
+        MySqlConnectionManager {
+            params: Opts::from(params),
+        }
+    }
+}
+
+impl r2d2::ManageConnection for MySqlConnectionManager {
+    type Connection = Conn;
+    type Error = Error;
+
+    fn connect(&self) -> Result<Conn, Error> {
+        Conn::new(self.params.clone())
+    }
+
+    fn is_valid(&self, conn: &mut Conn) -> Result<(), Error> {
+        conn.query("SELECT version()").map(|_: Vec<String>| ())
+    }
+
+    fn has_broken(&self, conn: &mut Conn) -> bool {
+        self.is_valid(conn).is_err()
+    }
+}
diff --git a/crates/shared/src/models.rs b/crates/shared/src/models.rs
index b0c0518..d962bff 100644
--- a/crates/shared/src/models.rs
+++ b/crates/shared/src/models.rs
@@ -3,10 +3,10 @@ use rocket::serde::Serialize;
 #[derive(Debug, Serialize, Default)]
 #[serde(crate = "rocket::serde")]
 pub struct Pagination {
-    pub limit: i64,
-    pub page: i64,
-    pub max_page: i64,
-    pub total: i64,
+    pub limit: u64,
+    pub page: u64,
+    pub max_page: u64,
+    pub total: u64,
 }
 
 #[derive(Debug, Default, Serialize, Clone, Copy)]
diff --git a/crates/shared/src/parameters.rs b/crates/shared/src/parameters.rs
index 5c9affc..0aa5a71 100644
--- a/crates/shared/src/parameters.rs
+++ b/crates/shared/src/parameters.rs
@@ -43,8 +43,8 @@ impl<'r> FromParam<'r> for Round {
 }
 
 macros::query_parameters! {
-    #[Copy] Page(i32);
-    #[Copy] Limit(i32);
+    #[Copy] Page(u64);
+    #[Copy] Limit(u64);
     DriverRef(String) => str;
     #[Copy] DriverNumber(i32);
     ConstructorRef(String) => str;
diff --git a/crates/shared/src/responses.rs b/crates/shared/src/responses.rs
index 252034c..4a46e82 100644
--- a/crates/shared/src/responses.rs
+++ b/crates/shared/src/responses.rs
@@ -4,44 +4,8 @@ use super::prelude::*;
 
 #[derive(Debug, Serialize)]
 #[serde(crate = "rocket::serde")]
-pub struct DriversResponse {
-    pub drivers: Vec<Driver>,
-
-    #[serde(flatten)]
-    pub pagination: Pagination,
-    pub series: Series,
-}
-
-#[derive(Debug, Serialize)]
-#[serde(crate = "rocket::serde")]
-pub struct ConstructorResponse {
-    pub constructors: Vec<Constructor>,
-
-    #[serde(flatten)]
-    pub pagination: Pagination,
-    pub series: Series,
-}
-
-#[derive(Debug, Serialize)]
-#[serde(crate = "rocket::serde")]
-pub struct StandingsResponse {
-    #[serde(skip_serializing_if = "Vec::is_empty")]
-    pub drivers_standings: Vec<DriverStanding>,
-    #[serde(skip_serializing_if = "Vec::is_empty")]
-    pub constructors_standings: Vec<ConstructorStanding>,
-    #[serde(flatten)]
-    pub pagination: Pagination,
-    pub series: Series,
-
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub season: Option<i32>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub round: Option<i32>,
-}
-
-#[derive(Debug, Serialize)]
-pub struct SeasonsResponse {
-    pub seasons: Vec<Season>,
+pub struct Response<T> {
+    pub data: T,
 
     #[serde(flatten)]
     pub pagination: Pagination,