update

Author: hhstore

crates/rs-tauri-vue/src-tauri/migrations/20221029182115_init.sql

@@ -5,7 +5,7 @@ CREATE TABLE IF NOT EXISTS todos
     description TEXT         NOT NULL,
     done        BOOLEAN      NOT NULL DEFAULT 0,
     title       VARCHAR(200) NOT NULL,
-    completed   BOOLEAN               DEFAULT FALSE
+    completed   BOOLEAN      NOT NULL DEFAULT 0
 );
 
 --

crates/rs-tauri-vue/src-tauri/src/storage/sql/db.rs

@@ -78,7 +78,7 @@ impl AppSqlStorage {
 
         match m.run(&self.db).await {
             Ok(_) => {
-                info!("migrations run success");
+                println!("migrations run success");
             },
             Err(e) => {
                 panic!("migrations run error: {:?}", e);

crates/rs-tauri-vue/src-tauri/src/storage/sql/todo.rs

@@ -9,17 +9,65 @@ impl AppSqlStorage {
         // Insert the task, then obtain the ID of this row
         let id = sqlx::query!(
             r#"
-    INSERT INTO todos ( description )
-    VALUES ( ?1 )
+    INSERT INTO todos ( description, title )
+    VALUES ( ?1, ?2 )
             "#,
-            todo.description
+            todo.description,
+            todo.title
         )
         .execute(&mut conn)
         .await?
         .last_insert_rowid();
 
         Ok(id)
     }
+
+    pub async fn list_todo(&self) -> anyhow::Result<Vec<TodoEntity>> {
+        let mut conn = self.db.acquire().await?;
+
+        let rows = sqlx::query!(
+            r#"
+SELECT id, description, title, done, completed
+FROM todos
+ORDER BY id
+        "#
+        )
+        .fetch_all(&mut conn)
+        .await?;
+
+        let mut todos = Vec::new();
+        for row in rows {
+            println!("row: {:?}", row);
+            todos.push(TodoEntity {
+                id: row.id,
+                description: row.description,
+                title: row.title,
+                done: row.done,
+                completed: row.completed,
+            });
+        }
+
+        Ok(todos)
+    }
+
+    pub async fn get_todo(&self, id: i64) -> anyhow::Result<TodoEntity> {
+        let mut conn = self.db.acquire().await?;
+
+        let row =
+            sqlx::query!(r#"SELECT id, title, description, completed FROM todos WHERE id = ?"#, id)
+                .fetch_one(&mut conn)
+                .await?;
+
+        println!("get_todo row: {:?}", row);
+
+        Ok(TodoEntity {
+            id: row.id,
+            description: row.description,
+            title: row.title,
+            done: false,
+            completed: row.completed,
+        })
+    }
 }
 
 #[cfg(test)]
@@ -33,4 +81,51 @@ mod test {
         db.init_migrations().await;
         db
     }
+
+    #[tokio::test]
+    async fn test_add_todo() {
+        let db = setup().await;
+        let todo = TodoEntity {
+            id: 0,
+            title: "test title".to_string(),
+            description: "test desc".to_string(),
+            done: false,
+            completed: false,
+        };
+        let id = db.add_todo(&todo).await.unwrap();
+        assert!(id > 0);
+    }
+
+    #[tokio::test]
+    async fn test_get_todo() {
+        let db = setup().await;
+        let todo = TodoEntity {
+            id: 0,
+            title: "get todo test".to_string(),
+            description: "test desc".to_string(),
+            done: false,
+            completed: false,
+        };
+        let id = db.add_todo(&todo).await.unwrap();
+        let todo = db.get_todo(id).await.unwrap();
+        assert_eq!(todo.description, "test desc");
+    }
+
+    #[tokio::test]
+    async fn test_list_todo() {
+        let db = setup().await;
+        let todo = TodoEntity {
+            id: 0,
+            title: "test title".to_string(),
+            description: "test desc".to_string(),
+            done: false,
+            completed: false,
+        };
+        let id = db.add_todo(&todo).await.unwrap();
+        assert!(id > 0);
+
+        let todos = db.list_todo().await.unwrap();
+
+        println!("todos: {:?}", todos)
+    }
 }