itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-29 21:00:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add version information for failed cli migration (#3129) (#3130)

Browse Source
This commit is contained in:
Maciej Flak 2024-04-05 06:45:21 +02:00 committed by GitHub
parent 0aae849657
commit 45b5b61d7b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
sqlx-core/src/migrate/error.rs
View File

@ -6,6 +6,9 @@ pub enum MigrateError {
#[error("while executing migrations: {0}")]
Execute(#[from] Error),
#[error("while executing migration {1}: {0}")]
ExecuteMigration(#[source] Error, i64),
#[error("while resolving migrations: {0}")]
Source(#[source] BoxDynError),

5
sqlx-mysql/src/migrate.rs
View File

@ -199,7 +199,10 @@ CREATE TABLE IF NOT EXISTS _sqlx_migrations (
.execute(&mut *tx)
.await?;
let _ = tx.execute(&*migration.sql).await?;
let _ = tx
.execute(&*migration.sql)
.await
.map_err(|e| MigrateError::ExecuteMigration(e, migration.version))?;
// language=MySQL
let _ = query(

5
sqlx-postgres/src/migrate.rs
View File

@ -216,7 +216,10 @@ CREATE TABLE IF NOT EXISTS _sqlx_migrations (
// The `execution_time` however can only be measured for the whole transaction. This value _only_ exists for
// data lineage and debugging reasons, so it is not super important if it is lost. So we initialize it to -1
// and update it once the actual transaction completed.
let _ = tx.execute(&*migration.sql).await?;
let _ = tx
.execute(&*migration.sql)
.await
.map_err(|e| MigrateError::ExecuteMigration(e, migration.version))?;
// language=SQL
let _ = query(

5
sqlx-sqlite/src/migrate.rs
View File

@ -142,7 +142,10 @@ CREATE TABLE IF NOT EXISTS _sqlx_migrations (
// The `execution_time` however can only be measured for the whole transaction. This value _only_ exists for
// data lineage and debugging reasons, so it is not super important if it is lost. So we initialize it to -1
// and update it once the actual transaction completed.
let _ = tx.execute(&*migration.sql).await?;
let _ = tx
.execute(&*migration.sql)
.await
.map_err(|e| MigrateError::ExecuteMigration(e, migration.version))?;
// language=SQL
let _ = query(