feat(postgres): allow running multiple statements in no tx migrations

sqlx-postgres/src/migrate.rs

@@ -276,10 +276,17 @@ async fn execute_migration(
     conn: &mut PgConnection,
     migration: &Migration,
 ) -> Result<(), MigrateError> {
-    let _ = conn
-        .execute(&*migration.sql)
-        .await
-        .map_err(|e| MigrateError::ExecuteMigration(e, migration.version))?;
+    let sql = migration.sql.trim();
+    let split_migrations = sql.split("/* sqlx: split */");
+    for part in split_migrations {
+        if part.trim().is_empty() {
+            continue;
+        }
+        let _ = conn
+            .execute(&*part.trim())
+            .await
+            .map_err(|e| MigrateError::ExecuteMigration(e, migration.version))?;
+    }
 
     // language=SQL
     let _ = query(

tests/postgres/migrate.rs

@@ -85,6 +85,26 @@ async fn no_tx(mut conn: PoolConnection<Postgres>) -> anyhow::Result<()> {
     Ok(())
 }
 
+
+#[sqlx::test(migrations = false)]
+async fn split(mut conn: PoolConnection<Postgres>) -> anyhow::Result<()> {
+    clean_up(&mut conn).await?;
+    let migrator = Migrator::new(Path::new("tests/postgres/migrations_split")).await?;
+
+    // run migration
+    migrator.run(&mut conn).await?;
+
+    // check outcome
+    let res: i32 = conn
+        .fetch_one("SELECT * FROM test_table")
+        .await?
+        .get(0);
+
+    assert_eq!(res, 1);
+
+    Ok(())
+}
+
 /// Ensure that we have a clean initial state.
 async fn clean_up(conn: &mut PgConnection) -> anyhow::Result<()> {
     conn.execute("DROP DATABASE IF EXISTS test_db").await.ok();

tests/postgres/migrations_split/0_create_table.sql

@@ -0,0 +1,7 @@
+-- no-transaction
+
+CREATE TABLE test_table (x int);
+/* sqlx: split */
+CREATE INDEX CONCURRENTLY test_table_x_idx ON test_table (x);
+/* sqlx: split */
+INSERT INTO test_table (x) VALUES (1);