execute.ts

import { HybridNitroSQLite } from '../nitro'
import type { QueryResult, QueryResultRow, SQLiteQueryParams } from '../types'
import NitroSQLiteError from '../NitroSQLiteError'

export function execute<Row extends QueryResultRow = never>(
  dbName: string,
  query: string,
  params?: SQLiteQueryParams,
): QueryResult<Row> {
  try {
    const result = HybridNitroSQLite.execute(dbName, query, params)
    return result as QueryResult<Row>
  } catch (error) {
    throw NitroSQLiteError.fromError(error)
  }
}

export async function executeAsync<Row extends QueryResultRow = never>(
  dbName: string,
  query: string,
  params?: SQLiteQueryParams,
): Promise<QueryResult<Row>> {
  try {
    const result = await HybridNitroSQLite.executeAsync(dbName, query, params)
    return result as QueryResult<Row>
  } catch (error) {
    throw NitroSQLiteError.fromError(error)
  }
}