feat(Model): add wrapper method delete

README.md

@@ -152,12 +152,16 @@ let banana = banana.save(db).await?;
 ```
 ### Delete
 ```rust
+// delete one
 let orange: Option<fruit::Model> = Fruit::find_by_id(1).one(db).await?;
-let orange: fruit::ActiveModel = orange.unwrap().into();
+let orange: fruit::Model = orange.unwrap();
+fruit::Entity::delete(orange.into_active_model())
+    .exec(db)
+    .await?;
 
-// delete one
-fruit::Entity::delete(orange).exec(db).await?;
 // or simply
+let orange: Option<fruit::Model> = Fruit::find_by_id(1).one(db).await?;
+let orange: fruit::Model = orange.unwrap();
 orange.delete(db).await?;
 
 // delete many: DELETE FROM "fruit" WHERE "fruit"."name" LIKE 'Orange'

examples/actix4_example/src/main.rs

@@ -140,12 +140,10 @@ async fn update(
 async fn delete(data: web::Data<AppState>, id: web::Path<i32>) -> Result<HttpResponse, Error> {
     let conn = &data.conn;
 
-    let post: post::ActiveModel = Post::find_by_id(id.into_inner())
+    let post: post::Model = Post::find_by_id(id.into_inner())
         .one(conn)
         .await
-        .unwrap()
-        .unwrap()
-        .into();
+        .unwrap();
 
     post.delete(conn).await.unwrap();
 

examples/actix_example/src/main.rs

@@ -161,12 +161,10 @@ async fn delete(
 ) -> actix_flash::Response<HttpResponse, FlashData> {
     let conn = &data.conn;
 
-    let post: post::ActiveModel = Post::find_by_id(id.into_inner())
+    let post: post::Model = Post::find_by_id(id.into_inner())
         .one(conn)
         .await
-        .unwrap()
-        .unwrap()
-        .into();
+        .unwrap();
 
     post.delete(conn).await.unwrap();
 

examples/axum_example/src/main.rs

@@ -202,12 +202,10 @@ async fn delete_post(
     Path(id): Path<i32>,
     mut cookies: Cookies,
 ) -> Result<PostResponse, (StatusCode, &'static str)> {
-    let post: post::ActiveModel = Post::find_by_id(id)
+    let post: post::Model = Post::find_by_id(id)
         .one(conn)
         .await
-        .unwrap()
-        .unwrap()
-        .into();
+        .unwrap();
 
     post.delete(conn).await.unwrap();
 

examples/rocket_example/src/main.rs

@@ -139,7 +139,7 @@ async fn edit(conn: Connection<'_, Db>, id: i32) -> Template {
 async fn delete(conn: Connection<'_, Db>, id: i32) -> Flash<Redirect> {
     let db = conn.into_inner();
 
-    let post: post::ActiveModel = Post::find_by_id(id).one(db).await.unwrap().unwrap().into();
+    let post: post::Model = Post::find_by_id(id).one(db).await.unwrap();
 
     post.delete(db).await.unwrap();
 

src/entity/model.rs

@@ -1,11 +1,14 @@
 use crate::{
-    DbErr, EntityTrait, Linked, QueryFilter, QueryResult, Related, Select, SelectModel,
-    SelectorRaw, Statement,
+    ActiveModelBehavior, ActiveModelTrait, ConnectionTrait, DbErr, DeleteResult, EntityTrait,
+    IntoActiveModel, Linked, QueryFilter, QueryResult, Related, Select, SelectModel, SelectorRaw,
+    Statement,
 };
+use async_trait::async_trait;
 pub use sea_query::Value;
 use std::fmt::Debug;
 
 /// A Trait for a Model
+#[async_trait]
 pub trait ModelTrait: Clone + Send + Debug {
     #[allow(missing_docs)]
     type Entity: EntityTrait;
@@ -33,6 +36,16 @@ pub trait ModelTrait: Clone + Send + Debug {
         let tbl_alias = &format!("r{}", l.link().len() - 1);
         l.find_linked().belongs_to_tbl_alias(self, tbl_alias)
     }
+
+    /// Delete an model
+    async fn delete<'a, A, C>(self, db: &'a C) -> Result<DeleteResult, DbErr>
+    where
+        Self: IntoActiveModel<A>,
+        C: ConnectionTrait<'a>,
+        A: ActiveModelTrait<Entity = Self::Entity> + ActiveModelBehavior + Send + 'a,
+    {
+        self.into_active_model().delete(db).await
+    }
 }
 
 /// A Trait for implementing a [QueryResult]

src/lib.rs

@@ -221,13 +221,16 @@
 //! ```
 //! # use sea_orm::{DbConn, error::*, entity::*, query::*, tests_cfg::*};
 //! # async fn function(db: &DbConn) -> Result<(), DbErr> {
+//! // delete one
 //! let orange: Option<fruit::Model> = Fruit::find_by_id(1).one(db).await?;
-//! let orange: fruit::ActiveModel = orange.unwrap().into();
+//! let orange: fruit::Model = orange.unwrap();
+//! fruit::Entity::delete(orange.into_active_model())
+//!     .exec(db)
+//!     .await?;
 //!
-//! // delete one
-//! fruit::Entity::delete(orange).exec(db).await?;
 //! // or simply
-//! # let orange: fruit::ActiveModel = Fruit::find_by_id(1).one(db).await.unwrap().unwrap().into();
+//! let orange: Option<fruit::Model> = Fruit::find_by_id(1).one(db).await?;
+//! let orange: fruit::Model = orange.unwrap();
 //! orange.delete(db).await?;
 //!
 //! // delete many: DELETE FROM "fruit" WHERE "fruit"."name" LIKE 'Orange'

tests/active_enum_tests.rs

@@ -89,7 +89,7 @@ pub async fn insert_active_enum(db: &DatabaseConnection) -> Result<(), DbErr> {
             .unwrap()
     );
 
-    let res = model.into_active_model().delete(db).await?;
+    let res = model.delete(db).await?;
 
     assert_eq!(res.rows_affected, 1);
     assert_eq!(Entity::find().one(db).await?, None);

tests/basic.rs

@@ -81,7 +81,7 @@ async fn crud_cake(db: &DbConn) -> Result<(), DbErr> {
         apple
     );
 
-    let apple: cake::ActiveModel = apple.unwrap().into();
+    let apple: cake::Model = apple.unwrap();
 
     let result = apple.delete(db).await?;
 

tests/crud/deletes.rs

@@ -29,11 +29,7 @@ pub async fn test_delete_cake(db: &DbConn) {
     let cakes = Cake::find().all(db).await.unwrap();
     assert_eq!(cakes.len(), initial_cakes + 1);
 
-    let _result = cake
-        .into_active_model()
-        .delete(db)
-        .await
-        .expect("failed to delete cake");
+    let _result = cake.delete(db).await.expect("failed to delete cake");
 
     let cakes = Cake::find().all(db).await.unwrap();
     assert_eq!(cakes.len(), initial_cakes);
@@ -56,11 +52,7 @@ pub async fn test_delete_bakery(db: &DbConn) {
         initial_bakeries + 1
     );
 
-    let _result = bakery
-        .into_active_model()
-        .delete(db)
-        .await
-        .expect("failed to delete bakery");
+    let _result = bakery.delete(db).await.expect("failed to delete bakery");
 
     assert_eq!(
         Bakery::find().all(db).await.unwrap().len(),

tests/crud/updates.rs

@@ -110,7 +110,7 @@ pub async fn test_update_deleted_customer(db: &DbConn) {
 
     let customer_id = customer.id;
 
-    let _ = customer.into_active_model().delete(db).await;
+    let _ = customer.delete(db).await;
     assert_eq!(Customer::find().count(db).await.unwrap(), init_n_customers);
 
     let customer = customer::ActiveModel {

tests/sequential_op_tests.rs

@@ -276,8 +276,7 @@ pub async fn test_delete_bakery(db: &DatabaseConnection) {
     }
     .save(db)
     .await
-    .expect("could not insert bakery")
-    .into_active_model();
+    .expect("could not insert bakery");
 
     assert_eq!(
         Bakery::find().all(db).await.unwrap().len(),

tests/transaction_tests.rs

@@ -408,7 +408,7 @@ pub async fn transaction_with_active_model_behaviour() -> Result<(), DbErr> {
         assert_eq!(cake::Entity::find().all(&txn).await?.len(), 2);
 
         assert_eq!(
-            readonly_cake_1.into_active_model().delete(&txn).await.err(),
+            readonly_cake_1.delete(&txn).await.err(),
             Some(DbErr::Custom(
                 "[before_delete] Cannot be deleted".to_owned()
             ))
@@ -428,7 +428,7 @@ pub async fn transaction_with_active_model_behaviour() -> Result<(), DbErr> {
         assert_eq!(cake::Entity::find().all(&txn).await?.len(), 3);
 
         assert_eq!(
-            readonly_cake_2.into_active_model().delete(&txn).await.err(),
+            readonly_cake_2.delete(&txn).await.err(),
             Some(DbErr::Custom("[after_delete] Cannot be deleted".to_owned()))
         );