(pool: &PgPool)
| 174 | ]; |
| 175 | |
| 176 | async fn drop_items(pool: &PgPool) -> Result<()> { |
| 177 | for (type_, name) in DROP_ITEMS { |
| 178 | log::info!("dropping {} {}", type_, name); |
| 179 | sqlx::query(&format!("drop {type_} if exists {name}")) |
| 180 | .execute(pool) |
| 181 | .await?; |
| 182 | } |
| 183 | |
| 184 | Ok(()) |
| 185 | } |
| 186 | |
| 187 | async fn delete_migration_records(pool: &PgPool) -> Result<()> { |
| 188 | log::info!("deleting rows from _sqlx_migrations"); |