Correctly handle the multi statement sql file

penumbra-zone · Jul 25, 2024 · 4c87381 · 4c87381
1 parent 0159700
commit 4c87381
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/crates/bin/pindexer/src/dex/mod.rs b/crates/bin/pindexer/src/dex/mod.rs
@@ -207,9 +207,9 @@ impl AppView for Component {
         dbtx: &mut PgTransaction,
         _app_state: &serde_json::Value,
     ) -> anyhow::Result<()> {
-        sqlx::query(include_str!("dex.sql"))
-            .execute(dbtx.as_mut())
-            .await?;
+        for statement in include_str!("dex.sql").split(";") {
+            sqlx::query(statement).execute(dbtx.as_mut()).await?;
+        }
         Ok(())
     }