Function executeSqlInWorker

packages/browser-db-sqlite-persistence/src/opfs-worker.ts:191–252

(
  sql: string,
  params: ReadonlyArray<unknown>,
)

}

async function executeSqlInWorker(
  sql: string,
  params: ReadonlyArray<unknown>,
): Promise<ReadonlyArray<Record<string, unknown>>> {
  const { sqlite3, dbHandle } = getInitializedDatabaseState()
  const rows = new Array<Record<string, unknown>>()
  let parametersBound = false

  for await (const statement of sqlite3.statements(dbHandle, sql)) {
    if (params.length > 0) {
      if (parametersBound) {
        throw new InvalidPersistedCollectionConfigError(
          `wa-sqlite worker only supports parameter binding for a single SQL statement`,
        )
      }

      sqlite3.bind_collection(
        statement,
        params.map((param) => toBindableValue(param)),
      )
      parametersBound = true
    }

    let columns = [...sqlite3.column_names(statement)]
    for (;;) {
      const stepResult = await sqlite3.step(statement)

      if (stepResult === SQLITE_ROW) {
        if (columns.length === 0) {
          columns = [...sqlite3.column_names(statement)]
        }
        const values = sqlite3.row(statement)
        const row: Record<string, unknown> = {}
        for (let columnIndex = 0; columnIndex < columns.length; columnIndex++) {
          const columnName = columns[columnIndex]
          if (!columnName) {
            continue
          }
          row[columnName] = values[columnIndex]
        }
        rows.push(row)
        continue
      }

      if (stepResult === SQLITE_DONE) {
        break
      }

      throw new InvalidPersistedCollectionConfigError(
        `wa-sqlite step returned unexpected result code: ${String(stepResult)}`,
      )
    }
  }

  if (params.length > 0 && !parametersBound) {
    throw new InvalidPersistedCollectionConfigError(
      `SQL query parameters were provided but no statement accepted bindings`,
    )