Method start

examples/tauri-sqlx-vanilla/src-tauri/src/bench.rs:93–146

(root: PathBuf, fresh: bool)

impl DatabaseHarness {
    pub async fn start(root: PathBuf, fresh: bool) -> Result<Self> {
        if fresh && root.exists() {
            fs::remove_dir_all(&root)
                .with_context(|| format!("remove profile dir {}", root.display()))?;
        }
        fs::create_dir_all(&root).with_context(|| format!("create {}", root.display()))?;

        let paths = PglitePaths::with_root(&root);
        let cold_start = !paths.pgdata.join("PG_VERSION").exists();
        let mut startup = Vec::new();

        let install_root = root.clone();
        time_blocking(
            &mut startup,
            "install runtime and pgdata template",
            move || install_into(&install_root).map(|_| ()),
        )
        .await?;

        let preload_paths = paths.clone();
        time_blocking(&mut startup, "load Wasmer AOT module", move || {
            preload_runtime_module(&preload_paths)
        })
        .await?;

        let server_root = root.clone();
        let server = time_blocking(&mut startup, "start pglite server", move || {
            preferred_server(server_root)
        })
        .await?;
        let database_url = server.connection_uri();

        let pool = time_async(&mut startup, "sqlx pool connect", async {
            let options =
                pg_connect_options(&server)?.application_name("pglite-oxide-tauri-sqlx-profile");

            PgPoolOptions::new()
                .max_connections(1)
                .acquire_timeout(Duration::from_secs(30))
                .connect_with(options)
                .await
                .context("connect SQLx pool to pglite proxy")
        })
        .await?;

        Ok(Self {
            root,
            database_url,
            pool,
            _server: server,
            cold_start,
            startup,
        })
    }

    pub async fn profile(&self, row_count: u32) -> Result<BenchReport> {
        let total = Instant::now();