Update an existing record.
(self, *, db_obj: ModelType, obj_in: dict[str, Any])
| 69 | return db_obj |
| 70 | |
| 71 | async def update(self, *, db_obj: ModelType, obj_in: dict[str, Any]) -> ModelType: |
| 72 | """Update an existing record.""" |
| 73 | async with self.session() as db: |
| 74 | for field, value in obj_in.items(): |
| 75 | if hasattr(db_obj, field): |
| 76 | setattr(db_obj, field, value) |
| 77 | db.add(db_obj) |
| 78 | await db.flush() |
| 79 | return db_obj |
| 80 | |
| 81 | async def delete(self, *, id: Any) -> ModelType | None: |
| 82 | """Delete a record by ID.""" |