Class SupabaseAdapter

constructor

• new SupabaseAdapter(): SupabaseAdapter

• Returns SupabaseAdapter

Readonlykind

Readonlycapabilities

open

• open(options?): Promise<void>

• Opens the underlying connection or initializes the backing store.

  Parameters

  • Optionaloptions: SupabaseAdapterOptions

  Returns Promise<void>

  Throws

  If connection cannot be established

  Example

  await adapter.open({ filePath: '/path/to/db.sqlite3' });
  Copy

close

• close(): Promise<void>

• Closes the underlying connection and releases resources.

  After calling close(), the adapter should not be used again. Always close adapters when done to prevent resource leaks.

  Returns Promise<void>

  Example

  try {
    await adapter.open();
    // ... use adapter ...
  } finally {
    await adapter.close();
  }
  Copy

run

• run(statement, parameters?): Promise<StorageRunResult>

• Executes a mutation statement (INSERT, UPDATE, DELETE).

  Parameters

  • statement: string

    SQL statement to execute
  • Optionalparameters: StorageParameters

    Optional parameters for the statement

  Returns Promise<StorageRunResult>

  Metadata about affected rows

  Throws

  If statement execution fails

  Example

  const result = await adapter.run('INSERT INTO users (name) VALUES (?)', ['John']);
  console.log(`Inserted with ID: ${result.lastInsertRowid}`);
  Copy

get

• get<T>(statement, parameters?): Promise<null | T>

• Retrieves a single row (or null if none found).

  Type Parameters

  • T = unknown

  Parameters

  • statement: string

    SQL SELECT statement
  • Optionalparameters: StorageParameters

    Optional parameters for the statement

  Returns Promise<null | T>

  First row or null if no results

  Throws

  If query execution fails

  Example

  const user = await adapter.get<User>('SELECT * FROM users WHERE id = ?', [123]);
  Copy

all

• all<T>(statement, parameters?): Promise<T[]>

• Retrieves all rows returned by the statement.

  WARNING: For large result sets, this loads everything into memory. Consider using streaming (if supported) for large queries.

  Type Parameters

  • T = unknown

  Parameters

  • statement: string

    SQL SELECT statement
  • Optionalparameters: StorageParameters

    Optional parameters for the statement

  Returns Promise<T[]>

  Array of all matching rows (empty array if none)

  Throws

  If query execution fails

  Example

  const users = await adapter.all<User>('SELECT * FROM users WHERE age > ?', [18]);
  Copy

exec

• exec(script): Promise<void>

• Executes a script containing multiple SQL statements.

  Statements are typically delimited by semicolons. This is useful for running migrations or initialization scripts. No results are returned.

  Parameters

  • script: string

    SQL script with multiple statements

  Returns Promise<void>

  Throws

  If any statement in the script fails

  Example

  await adapter.exec(`
    CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT);
    CREATE INDEX idx_users_name ON users(name);
  `);
  Copy

transaction

• transaction<T>(fn): Promise<T>

• Executes a callback within a database transaction.

  The transaction is automatically committed on success or rolled back on error. Nested transactions may not be supported by all adapters.

  Type Parameters

  • T

  Parameters

  • fn: ((trx: StorageAdapter) => Promise<T>)

    Async callback to execute within the transaction

    • • (trx): Promise<T>

      • Parameters

        • trx: StorageAdapter

        Returns Promise<T>

  Returns Promise<T>

  Result of the callback function

  Throws

  Transaction is rolled back and error is re-thrown

  Example

  const result = await adapter.transaction(async (trx) => {
    await trx.run('INSERT INTO accounts (balance) VALUES (?)', [100]);
    await trx.run('INSERT INTO logs (action) VALUES (?)', ['account_created']);
    return { success: true };
  });
  Copy

stream

• stream<T>(query, parameters?, options?): AsyncIterableIterator<T, any, any>

• Stream large result sets.

  Type Parameters

  • T = unknown

  Parameters

  • query: string
  • Optionalparameters: unknown
  • Optionaloptions: StreamOptions

  Returns AsyncIterableIterator<T, any, any>

batchWrite

• batchWrite(operations): Promise<BatchResult>

• Parameters

  • operations: ExtendedBatchOperation[]

  Returns Promise<BatchResult>

migrate

• migrate(migrations): Promise<void>

• Apply database migrations.

  Parameters

  • migrations: Migration[]

  Returns Promise<void>

getMigrationStatus

• getMigrationStatus(): Promise<Migration[]>

• Get migration status.

  Returns Promise<Migration[]>

backup

• backup(_destination): Promise<void>

• Parameters

  • _destination: string

  Returns Promise<void>

restore

• restore(_source): Promise<void>

• Parameters

  • _source: string

  Returns Promise<void>

enableProfiling

• enableProfiling(): void

• Returns void

disableProfiling

• disableProfiling(): void

• Returns void

getMetrics

• getMetrics(): PerformanceMetrics

• Get performance metrics.

  Returns PerformanceMetrics

clearMetrics

• clearMetrics(): void

• Returns void

enableCache

• enableCache(maxSize?): void

• Parameters

  • maxSize: number = 100

  Returns void

disableCache

• disableCache(): void

• Returns void

clearCache

• clearCache(): void

• Returns void

getPoolStatus

• getPoolStatus(): {
      active: number;
      idle: number;
      waiting: number;
      max: number;
  }

• Returns {
      active: number;
      idle: number;
      waiting: number;
      max: number;
  }

  • active: number

  • idle: number

  • waiting: number

  • max: number