Function createClient

tests/runtimes/bun/bun-e2e.test.ts:91–118

(provider: 'sqlite' | 'postgresql', dbName: string)

});

async function createClient(provider: 'sqlite' | 'postgresql', dbName: string) {
    const _schema = clone(schema);
    let dialect: Dialect;
    if (provider === 'sqlite') {
        (_schema as any).provider.type = 'sqlite';
        dialect = new BunSqliteDialect({
            database: new Database(':memory:'),
        });
    } else {
        (_schema as any).provider.type = 'postgresql';
        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();
        dialect = new PostgresDialect({
            pool: new Pool({
                connectionString: `${TEST_PG_URL}/${dbName}`,
            }),
        });
    }

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