(db: &DbConn)
| 272 | } |
| 273 | |
| 274 | async fn count_fruits_by_cake_json(db: &DbConn) -> Result<(), DbErr> { |
| 275 | print!("count fruits by cake: "); |
| 276 | |
| 277 | let count = Cake::find() |
| 278 | .left_join(Fruit) |
| 279 | .select_only() |
| 280 | .column(cake::Column::Name) |
| 281 | .column_as(fruit::Column::Id.count(), "num_of_fruits") |
| 282 | .group_by(cake::Column::Name) |
| 283 | .into_json() |
| 284 | .all(db) |
| 285 | .await?; |
| 286 | |
| 287 | println!("\n{}\n", serde_json::to_string_pretty(&count).unwrap()); |
| 288 | |
| 289 | Ok(()) |
| 290 | } |
| 291 | |
| 292 | async fn find_all_stream(db: &DbConn) -> Result<(), DbErr> { |
| 293 | use async_std::task::sleep; |
no test coverage detected