feat: upsert

flake.nix

@@ -30,6 +30,8 @@
             })
             sqls
             sqlx-cli
+            tree-sitter-grammars.tree-sitter-rust
+            tree-sitter-grammars.tree-sitter-sql
           ];
         };
       });

georm-macros/src/georm/trait_implementation.rs

@@ -56,7 +56,7 @@ fn generate_update_query(
     let update_columns = fields
         .iter()
         .enumerate()
-        .map(|(i, &field)| format!("{} = ${}", field.ident, i + 1))
+        .map(|(i, field)| format!("{} = ${}", field.ident, i + 1))
         .collect::<Vec<String>>()
         .join(", ");
     let update_string = format!(
@@ -79,6 +79,10 @@ fn generate_update_query(
     }
 }
 
+fn generate_upsert_query(table: &str, fields: &[GeormField]) -> proc_macro2::TokenStream {
+}
+
+
 fn generate_delete_query(table: &str, id: &GeormField) -> proc_macro2::TokenStream {
     let delete_string = format!("DELETE FROM {table} WHERE {} = $1", id.ident);
     let ty = &id.ty;

src/georm.rs

@@ -47,21 +47,12 @@ pub trait Georm<Id> {
     ///
     /// # Errors
     /// Returns any error Postgres may have encountered
-    fn create_or_update(
+    fn upsert(
         &self,
         pool: &sqlx::PgPool,
     ) -> impl ::std::future::Future<Output = sqlx::Result<Self>>
     where
-        Self: Sized,
+        Self: Sized;
-    {
-        async {
-            if Self::find(pool, self.get_id()).await?.is_some() {
-                self.update(pool).await
-            } else {
-                self.create(pool).await
-            }
-        }
-    }
 
     /// Delete the entity from the database if it exists.
     ///