Class OuterbaseQueryable

src/outerbase-cloud/database/query.ts:6–34

import { transformOuterbaseResult } from "./utils";

export class OuterbaseQueryable implements QueryableBaseDriver {
  protected workspaceId: string;
  protected sourceId: string;

  constructor({ workspaceId, sourceId }: OuterbaseDatabaseConfig) {
    this.workspaceId = workspaceId;
    this.sourceId = sourceId;
  }

  async query(stmt: string): Promise<DatabaseResultSet> {
    const jsonResponse = await runOuterbaseQueryRaw(
      this.workspaceId,
      this.sourceId,
      stmt
    );

    return transformOuterbaseResult(jsonResponse);
  }

  async batch(stmts: string[]): Promise<DatabaseResultSet[]> {
    return (
      await runOuterbaseQueryBatch(this.workspaceId, this.sourceId, stmts)
    ).map(transformOuterbaseResult);
  }

  async transaction(stmts: string[]): Promise<DatabaseResultSet[]> {
    return this.batch(stmts);
  }
}