used compile time query_as! in get_eeg_data_by_range

Author: itang06

backend/shared-logic/src/db.rs

@@ -393,12 +393,13 @@ pub async fn insert_time_labels(client: &DbClient, session_id: i32, labels: Vec<
 pub async fn get_eeg_data_by_range(client: &DbClient, session_id: i32, start: DateTime<Utc>, end: DateTime<Utc>) -> Result<Vec<EegDataRow>, Error> {
     info!("Retrieving EEG data for session {} from {} to {}", session_id, start, end);
 
-    let data = sqlx::query_as::<_, EegDataRow>(
+    let data = sqlx::query_as!(
+        EegDataRow,
         "SELECT time, channel1, channel2, channel3, channel4 FROM eeg_data WHERE session_id = $1 AND time >= $2 AND time <= $3 ORDER BY time",
+        session_id,
+        start,
+        end,
     )
-    .bind(session_id)
-    .bind(start)
-    .bind(end)
     .fetch_all(&**client)
     .await?;
 
@@ -413,14 +414,14 @@ pub async fn export_eeg_data_as_csv(client: &DbClient, session_id: i32, start_ti
     info!("Exporting EEG data for session id {} from {} to {}", session_id, start_time, end_time);
 
     // get the data from the database
-    let data = sqlx::query_as::<_, EegDataRow>(
+    let data = sqlx::query!(
         "SELECT time, channel1, channel2, channel3, channel4 FROM eeg_data
         WHERE session_id = $1 AND time >= $2 AND time <= $3
         ORDER BY time ASC",
+        session_id,
+        start_time,
+        end_time
     )
-    .bind(session_id)
-    .bind(start_time)
-    .bind(end_time)
     .fetch_all(&**client)
     .await?;
 
@@ -462,12 +463,12 @@ pub async fn export_eeg_data_as_csv(client: &DbClient, session_id: i32, start_ti
 ///
 /// Returns the earliest timestamp on success.
 pub async fn get_earliest_eeg_timestamp(client: &DbClient, session_id: i32) -> Result<Option<DateTime<Utc>>, Error> {
-    let earliest = sqlx::query_scalar::<_, Option<DateTime<Utc>>>(
-        "SELECT MIN(time) FROM eeg_data WHERE session_id = $1",
+    let row = sqlx::query!(
+        "SELECT MIN(time) as earliest_time FROM eeg_data WHERE session_id = $1",
+        session_id
     )
-    .bind(session_id)
     .fetch_one(&**client)
     .await?;
 
-    Ok(earliest)
+    Ok(row.earliest_time)
 }