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, + database_connection: &Pool, +) -> Result, 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, + database_connection: &Pool, +) -> Result, 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, +) -> Result, 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, + database_connection: &Pool, +) -> Result, 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