Function createClient

tests/runtimes/edge-runtime/edge-runtime-e2e.test.ts:84–101

(dbName: string)

});

async function createClient(dbName: string) {
    const pgClient = new Client({
        connectionString: TEST_PG_URL,
    });
    await pgClient.connect();
    await pgClient.query(`DROP DATABASE IF EXISTS "${dbName}"`);
    await pgClient.query(`CREATE DATABASE "${dbName}"`);
    await pgClient.end();
    const dialect = new PostgresDialect({
        pool: new Pool({
            connectionString: `${TEST_PG_URL}/${dbName}`,
        }),
    });

    const db = new ZenStackClient(schema, { dialect });
    await db.$pushSchema();
    return db;
}