Class SqliteLikeBaseDriver

src/drivers/sqlite-base-driver.ts:29–387

import generateSqlSchemaChange from "./sqlite/sqlite-generate-schema";

export class SqliteLikeBaseDriver extends CommonSQLImplement {
  protected supportPragmaList = false;
  protected supportBigInt = false;

  constructor(
    protected _db: QueryableBaseDriver,
    protected options?: {
      supportPragmaList?: boolean;
      supportBigInt?: boolean;
    }
  ) {
    super();
    this.supportPragmaList = options?.supportPragmaList ?? false;
    this.supportBigInt = options?.supportBigInt ?? false;
  }

  query(stmt: string): Promise<DatabaseResultSet> {
    return this._db.query(stmt);
  }

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

  batch(stmts: string[]): Promise<DatabaseResultSet[]> {
    return this._db.batch ? this._db.batch(stmts) : super.batch(stmts);
  }

  columnTypeSelector: ColumnTypeSelector = {
    type: "dropdown",
    dropdownNormalized: (typeName: string): string => {
      const type = convertSqliteType(typeName);
      if (type === undefined) return "TEXT";
      if (type === ColumnType.INTEGER) return "INTEGER";
      if (type === ColumnType.REAL) return "REAL";
      if (type === ColumnType.BLOB) return "BLOB";
      return "TEXT";
    },
    dropdownOptions: [
      { text: "Integer", value: "INTEGER" },
      { text: "Real", value: "REAL" },
      { text: "Text", value: "TEXT" },
      { text: "Blob", value: "BLOB" },
    ],
  };

  escapeId(id: string) {
    return `"${id.replace(/"/g, '""')}"`;
  }

  escapeValue(value: unknown): string {
    return escapeSqlValue(value);
  }

  getFlags(): DriverFlags {
    return {
      supportRowId: true,
      supportBigInt: this.supportBigInt,