graphile_worker_migrations 0.4.18

Migrations package for graphile_worker, a high performance Rust/PostgreSQL job queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use std::future::Future;

use graphile_worker_database::{DbError, DbExecutorArg, DbParams, Schema};
use graphile_worker_migrations_core::GraphileWorkerMigration;

pub trait MigrationExecuteExt {
    fn execute<'a, E, S>(
        &'a self,
        executor: E,
        schema: S,
    ) -> impl Future<Output = Result<(), DbError>> + 'a
    where
        E: DbExecutorArg + 'a,
        S: Into<Schema> + 'a;
}

impl MigrationExecuteExt for GraphileWorkerMigration {
    async fn execute<'a, E, S>(&'a self, mut executor: E, schema: S) -> Result<(), DbError>
    where
        E: DbExecutorArg + 'a,
        S: Into<Schema> + 'a,
    {
        let schema = schema.into();
        for stmt in self.stmts {
            let stmt = stmt.replace(":GRAPHILE_WORKER_SCHEMA", schema.escaped());
            executor.execute(&stmt, DbParams::new()).await?;
        }

        Ok(())
    }
}