(&self, query: &str, version: i32)
| 733 | } |
| 734 | |
| 735 | async fn execute_migration(&self, query: &str, version: i32) -> Result<()> { |
| 736 | self.execute_migration_transaction( |
| 737 | |transaction| { |
| 738 | transaction.execute_batch(query)?; |
| 739 | Ok(()) |
| 740 | }, |
| 741 | version, |
| 742 | ) |
| 743 | .await |
| 744 | } |
| 745 | |
| 746 | async fn execute_migration_transaction( |
| 747 | &self, |