Method executeSQL

src/connectors/sqlite/index.ts:451–592

(sql: string, options: ExecuteOptions, parameters?: any[])

  async executeSQL(sql: string, options: ExecuteOptions, parameters?: any[]): Promise<SQLResult> {
    if (!this.db) {
      throw new Error("Not connected to SQLite database");
    }

    // Engine-level read-only backstop: PRAGMA query_only=ON makes SQLite reject any
    // write (including header-writing pragmas like `PRAGMA user_version=N` and
    // `wal_checkpoint(...)`) regardless of what the keyword classifier allowed. The
    // body below runs synchronously (node:sqlite is sync), so no other executeSQL
    // call can interleave between toggling the flag on and restoring it.
    if (options.readonly) {
      this.db.exec("PRAGMA query_only = ON");
    }

    try {
      // Check if this is a multi-statement query
      const statements = splitSQLStatements(sql, "sqlite");

      if (statements.length === 1) {
        // Single statement - determine if it returns data
        let processedStatement = statements[0];
        const trimmedStatement = statements[0].toLowerCase().trim();
        const isReadStatement = trimmedStatement.startsWith('select') ||
                               trimmedStatement.startsWith('with') ||
                               trimmedStatement.startsWith('explain') ||
                               trimmedStatement.startsWith('analyze') ||
                               (trimmedStatement.startsWith('pragma') &&
                                (trimmedStatement.includes('table_info') ||
                                 trimmedStatement.includes('index_info') ||
                                 trimmedStatement.includes('index_list') ||
                                 trimmedStatement.includes('foreign_key_list')));

        // Apply maxRows limit to SELECT queries if specified (not PRAGMA/ANALYZE)
        if (options.maxRows) {
          processedStatement = SQLRowLimiter.applyMaxRows(processedStatement, options.maxRows);
        }

        if (isReadStatement) {
          // Pass parameters if provided
          if (parameters && parameters.length > 0) {
            try {
              const rows = this.prepare(processedStatement).all(...parameters);
              return { rows, rowCount: rows.length };
            } catch (error) {
              console.error(`[SQLite executeSQL] ERROR: ${(error as Error).message}`);
              console.error(`[SQLite executeSQL] SQL: ${processedStatement}`);
              console.error(`[SQLite executeSQL] Parameters: ${JSON.stringify(parameters)}`);
              throw error;
            }
          } else {
            const rows = this.prepare(processedStatement).all();
            return { rows, rowCount: rows.length };
          }
        } else {
          // Use run() for statements that don't return data
          let result;
          if (parameters && parameters.length > 0) {
            try {