Function multipleQuery

src/lib/sql/multiple-query.ts:32–115

(
  driver: BaseDriver,
  statements: string[],
  onProgress?: (progress: MultipleQueryProgress) => void
)

}

export async function multipleQuery(
  driver: BaseDriver,
  statements: string[],
  onProgress?: (progress: MultipleQueryProgress) => void
): Promise<{
  result: MultipleQueryResult[];
  logs: MultipleQueryProgressItem[];
}> {
  const logs: MultipleQueryProgressItem[] = [];
  const result: MultipleQueryResult[] = [];

  for (let i = 0; i < statements.length; i++) {
    const statement = statements[i] as string;
    const statementType = statement ? getSQLStatementType(statement) : "OTHER";

    const log: MultipleQueryProgressItem = {
      order: i,
      sql: statement,
      start: Date.now(),
      statementType,
    };

    logs.push(log);

    if (onProgress) {
      onProgress({ logs, progress: i, total: statements.length });
    }

    try {
      const r = await driver.query(statement);

      log.end = Date.now();
      log.stats = r.stat;

      if (r.headers.length > 0) {
        result.push({
          sql: statement,
          order: i,
          result: r,
        });
      }

      if (onProgress) {
        onProgress({ logs, progress: i + 1, total: statements.length });
      }
    } catch (e) {
      log.end = Date.now();
      log.error = (e as Error).toString();

      if (onProgress) {
        onProgress({
          logs,
          progress: i,
          total: statements.length,
          error: true,
        });
      }