From 1aa1d8cb1eafe871c55ae19e838d3bc4186ef46d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ahmet=20Kaan=20G=C3=9CM=C3=9C=C5=9E?=
 <96421894+Tahinli@users.noreply.github.com>
Date: Thu, 5 Dec 2024 02:47:51 +0300
Subject: [PATCH] feat: :sparkles: read_all for post, post_interaction,
 comment_interaction, comment

---
 src/database/comment.rs             | 15 +++++++++++++++
 src/database/comment_interaction.rs | 15 +++++++++++++++
 src/database/post.rs                | 15 +++++++++++++++
 src/database/post_interaction.rs    | 15 +++++++++++++++
 4 files changed, 60 insertions(+)

diff --git a/src/database/comment.rs b/src/database/comment.rs
index 8be1a01..48654a0 100644
--- a/src/database/comment.rs
+++ b/src/database/comment.rs
@@ -72,3 +72,18 @@ pub async fn delete(
     .fetch_one(database_connection)
     .await
 }
+
+pub async fn read_all(
+    post_creation_time: DateTime<Utc>,
+    database_connection: &Pool<Postgres>,
+) -> Result<Vec<Comment>, sqlx::Error> {
+    sqlx::query_as!(
+        Comment,
+        r#"
+            SELECT * FROM "comment" WHERE "post_creation_time" = $1
+        "#,
+        post_creation_time
+    )
+    .fetch_all(database_connection)
+    .await
+}
\ No newline at end of file
diff --git a/src/database/comment_interaction.rs b/src/database/comment_interaction.rs
index 42135f8..e0f00e4 100644
--- a/src/database/comment_interaction.rs
+++ b/src/database/comment_interaction.rs
@@ -72,3 +72,18 @@ pub async fn delete(
     .fetch_one(database_connection)
     .await
 }
+
+pub async fn read_all(
+    comment_creation_time: &DateTime<Utc>,
+    database_connection: &Pool<Postgres>,
+) -> Result<Vec<CommentInteraction>, sqlx::Error> {
+    sqlx::query_as!(
+        CommentInteraction,
+        r#"
+            SELECT * FROM "comment_interaction" WHERE "comment_creation_time" = $1
+        "#,
+        comment_creation_time
+    )
+    .fetch_all(database_connection)
+    .await
+}
\ No newline at end of file
diff --git a/src/database/post.rs b/src/database/post.rs
index 6221b79..784b7a2 100644
--- a/src/database/post.rs
+++ b/src/database/post.rs
@@ -72,3 +72,18 @@ pub async fn delete(
     .fetch_one(database_connection)
     .await
 }
+
+pub async fn read_all(
+    poster_id: i64,
+    database_connection: &Pool<Postgres>,
+) -> Result<Vec<Post>, sqlx::Error> {
+    sqlx::query_as!(
+        Post,
+        r#"
+            SELECT * FROM "post" WHERE "poster_id" = $1
+        "#,
+        poster_id
+    )
+    .fetch_all(database_connection)
+    .await
+}
\ No newline at end of file
diff --git a/src/database/post_interaction.rs b/src/database/post_interaction.rs
index 1adda53..b2e08a0 100644
--- a/src/database/post_interaction.rs
+++ b/src/database/post_interaction.rs
@@ -72,3 +72,18 @@ pub async fn delete(
     .fetch_one(database_connection)
     .await
 }
+
+pub async fn read_all(
+    post_creation_time: &DateTime<Utc>,
+    database_connection: &Pool<Postgres>,
+) -> Result<Vec<PostInteraction>, sqlx::Error> {
+    sqlx::query_as!(
+        PostInteraction,
+        r#"
+            SELECT * FROM "post_interaction" WHERE "post_creation_time" = $1
+        "#,
+        post_creation_time
+    )
+    .fetch_all(database_connection)
+    .await
+}
\ No newline at end of file