use sea_orm::{ConnectionTrait, DatabaseBackend, DatabaseConnection}; pub async fn sync_schema(db: &DatabaseConnection) -> Result<(), sea_orm::DbErr> { if db.get_database_backend() == DatabaseBackend::Postgres { db.execute_unprepared(include_str!("../../schema_pre_sync.sql")) .await?; } db.get_schema_registry("models::").sync(db).await?; if db.get_database_backend() == DatabaseBackend::Postgres { db.execute_unprepared(include_str!("../../schema_extras.sql")) .await?; } Ok(()) }